This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 13d7e55 [FLINK-21796][FLINK-17510] Disable tests that use
KafkaResource
add c4678d8 [FLINK-22133][core] Add checkpointID to
'SplitEnumerator.snapshotState()'
add 8256213 [hotfix][rocksdb] Properly adjust RocksDB config options to
new builder pattern
add 861a46e [FLINK-21694][rocksdb] Increase default value for
'state.backend.rocksdb.checkpoint.transfer.thread.num'
No new revisions were added by this update.
Summary of changes:
.../base/source/reader/mocks/MockSplitEnumerator.java | 2 +-
.../file/src/impl/ContinuousFileSplitEnumerator.java | 3 ++-
.../file/src/impl/StaticFileSplitEnumerator.java | 2 +-
.../src/impl/ContinuousFileSplitEnumeratorTest.java | 6 +++---
.../file/src/impl/StaticFileSplitEnumeratorTest.java | 6 +++---
.../connectors/hive/ContinuousHiveSplitEnumerator.java | 3 ++-
.../kafka/source/enumerator/KafkaSourceEnumerator.java | 2 +-
.../kafka/source/enumerator/KafkaEnumeratorTest.java | 4 ++--
.../flink/api/connector/source/SplitEnumerator.java | 18 ++++++++++++++++--
.../source/lib/util/IteratorSourceEnumerator.java | 2 +-
.../connector/source/mocks/MockSplitEnumerator.java | 2 +-
.../runtime/source/coordinator/SourceCoordinator.java | 9 +++++----
.../source/coordinator/SourceCoordinatorTest.java | 4 ++--
.../source/coordinator/TestingSplitEnumerator.java | 2 +-
.../flink/contrib/streaming/state/RocksDBOptions.java | 6 +++++-
.../OperatorEventSendingCheckpointITCase.java | 4 ++--
.../checkpointing/UnalignedCheckpointTestBase.java | 2 +-
17 files changed, 49 insertions(+), 28 deletions(-)
