У меня есть реализация задания Flink, в которой используется драйвер Cassandra (com.datastax.driver) и разъем Cassandra-Flink. В особой ситуации, когда постоянство должно блокировать (при запуске) драйвер Cassandra, а во всех других случаях используется CassandraRowWriteAheadSink . Но в драйвере Cassandra каждая мутация имеет отметку времени с точностью до микросекунды , которая используется для упорядочения операций относительно друг друга, в то время как при использовании соединителя cassandra-flink GenericWriteAheadSink использует точность в миллисекунда (поскольку используется context.getCheckpointTimestamp ()), и это создает проблемы. Мы отвергли это поведение, но есть ли лучший способ справиться с этим делом?