[hotfix][docs][pyflink] Regenerate docs and adjust PyFlink tests fpr …

…FLINK-21694
bbejeck · Apr 20, 2021 · 80c1e71 · 80c1e71
1 parent 9e4e14a
commit 80c1e71
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 6 deletions.
diff --git 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
@@ -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
@@ -182,11 +182,9 @@ def test_get_set_number_of_transfering_threads(self):
 
  state_backend = RocksDBStateBackend("file:https://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):