Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.13.0, 1.14.0
-
None
Description
=================================== FAILURES ===================================
_____ RocksDBStateBackendTests.test_get_set_number_of_transfering_threads ______
self = <pyflink.datastream.tests.test_state_backend.RocksDBStateBackendTests testMethod=test_get_set_ number_of_transfering_threads>
def test_get_set_number_of_transfering_threads(self):
state_backend = RocksDBStateBackend("file://var/checkpoints/")
> self.assertEqual(state_backend.get_number_of_transfering_threads(), 1)
E AssertionError: 4 != 1
pyflink/datastream/tests/test_state_backend.py:185: AssertionError
[ERROR] Failures: [ERROR] ConfigOptionsDocsCompletenessITCase.testCompleteness:76->compareDocumentedAndExistingOption s:220 Documentation is outdated, please regenerate it according to the instructions in flink-docs/README.md. Problems: Documentation of state.backend.rocksdb.checkpoint.transfer.thread.num in RocksDBOptions is outdated. Expected: default=(4) description=(The number of threads (per stateful operator) used to transfer (download and upload) files in RocksD BStateBackend.). Documented option state.backend.rocksdb.checkpoint.transfer.thread.num does not exist. Documented option state.backend.rocksdb.checkpoint.transfer.thread.num does not exist.
Attachments
Issue Links
- is caused by
-
FLINK-21694 Increase default value of "state.backend.rocksdb.checkpoint.transfer.thread.num"
- Closed