[flink-ml] branch master updated: [hotfix] Update python tests to set execution.attached=True

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhangzp pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git


The following commit(s) were added to refs/heads/master by this push:
     new 7a4a2f5  [hotfix] Update python tests to set execution.attached=True
7a4a2f5 is described below

commit 7a4a2f5dba78c504b883a532826909d0906895aa
Author: Dong Lin <li...@gmail.com>
AuthorDate: Tue Nov 29 14:36:05 2022 +0800

    [hotfix] Update python tests to set execution.attached=True
    
    This closes #184.
---
 flink-ml-python/pyflink/ml/tests/test_utils.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-ml-python/pyflink/ml/tests/test_utils.py b/flink-ml-python/pyflink/ml/tests/test_utils.py
index 442de7d..68a43dc 100644
--- a/flink-ml-python/pyflink/ml/tests/test_utils.py
+++ b/flink-ml-python/pyflink/ml/tests/test_utils.py
@@ -44,6 +44,7 @@ class PyFlinkMLTestCase(unittest.TestCase):
         config = Configuration(
             j_configuration=get_j_env_configuration(self.env._j_stream_execution_environment))
         config.set_boolean("execution.checkpointing.checkpoints-after-tasks-finish.enabled", True)
+        config.set_boolean("execution.attached", True)
 
         self.env.set_parallelism(4)
         self.env.enable_checkpointing(100)