This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 80c1e71 [hotfix][docs][pyflink] Regenerate docs and adjust PyFlink
tests fpr FLINK-21694
80c1e71 is described below
commit 80c1e713c56ef8d0455e508c1b45f61b878493c8
Author: Stephan Ewen <[email protected]>
AuthorDate: Tue Apr 20 20:40:34 2021 +0200
[hotfix][docs][pyflink] Regenerate docs and adjust PyFlink tests fpr
FLINK-21694
---
docs/layouts/shortcodes/generated/expert_rocksdb_section.html | 2 +-
docs/layouts/shortcodes/generated/rocksdb_configuration.html | 2 +-
flink-python/pyflink/datastream/tests/test_state_backend.py | 6 ++----
3 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/docs/layouts/shortcodes/generated/expert_rocksdb_section.html
b/docs/layouts/shortcodes/generated/expert_rocksdb_section.html
index 3344e53..ce02013 100644
--- a/docs/layouts/shortcodes/generated/expert_rocksdb_section.html
+++ b/docs/layouts/shortcodes/generated/expert_rocksdb_section.html
@@ -10,7 +10,7 @@
<tbody>
<tr>
<td><h5>state.backend.rocksdb.checkpoint.transfer.thread.num</h5></td>
- <td style="word-wrap: break-word;">1</td>
+ <td style="word-wrap: break-word;">4</td>
<td>Integer</td>
<td>The number of threads (per stateful operator) used to transfer
(download and upload) files in RocksDBStateBackend.</td>
</tr>
diff --git a/docs/layouts/shortcodes/generated/rocksdb_configuration.html
b/docs/layouts/shortcodes/generated/rocksdb_configuration.html
index 74b1236..d936815 100644
--- a/docs/layouts/shortcodes/generated/rocksdb_configuration.html
+++ b/docs/layouts/shortcodes/generated/rocksdb_configuration.html
@@ -10,7 +10,7 @@
<tbody>
<tr>
<td><h5>state.backend.rocksdb.checkpoint.transfer.thread.num</h5></td>
- <td style="word-wrap: break-word;">1</td>
+ <td style="word-wrap: break-word;">4</td>
<td>Integer</td>
<td>The number of threads (per stateful operator) used to transfer
(download and upload) files in RocksDBStateBackend.</td>
</tr>
diff --git a/flink-python/pyflink/datastream/tests/test_state_backend.py
b/flink-python/pyflink/datastream/tests/test_state_backend.py
index e9ae8ec..1d13fc2 100644
--- a/flink-python/pyflink/datastream/tests/test_state_backend.py
+++ b/flink-python/pyflink/datastream/tests/test_state_backend.py
@@ -182,11 +182,9 @@ class RocksDBStateBackendTests(PyFlinkTestCase):
state_backend = RocksDBStateBackend("file://var/checkpoints/")
- self.assertEqual(state_backend.get_number_of_transfering_threads(), 1)
+ state_backend.set_number_of_transfering_threads(7)
- state_backend.set_number_of_transfering_threads(4)
-
- self.assertEqual(state_backend.get_number_of_transfering_threads(), 4)
+ self.assertEqual(state_backend.get_number_of_transfering_threads(), 7)
class CustomStateBackendTests(PyFlinkTestCase):
