fix

Author: yuzelin

pypaimon/py4j/gateway_server.py

@@ -74,7 +74,7 @@ def preexec_func():
                  stdin=PIPE, stderr=PIPE, preexec_fn=preexec_fn, env=env)
 
 
-_JAVA_IMPL_MODULE = 'paimon_python_java'
+_JAVA_IMPL_MODULE = 'pypaimon.py4j'
 _JAVA_DEPS = 'java_dependencies'
 _JAVA_BRIDGE = 'paimon-python-java-bridge'
 

pypaimon/py4j/tests/test_data_types.py

@@ -27,8 +27,7 @@
 from pypaimon import Schema
 from pypaimon.py4j import Catalog
 from pypaimon.py4j.tests import utils
-from pypaimon.py4j.util import java_utils
-from setup_utils import java_setuputils
+from pypaimon.py4j.util import java_utils, java_setuputils
 
 
 class DataTypesTest(unittest.TestCase):

pypaimon/py4j/tests/test_preicates.py

@@ -27,7 +27,7 @@
 from pypaimon import Schema
 from pypaimon.py4j import Catalog
 from pypaimon.py4j.tests import utils
-from setup_utils import java_setuputils
+from pypaimon.py4j.util import java_setuputils
 
 
 def _check_filtered_result(read_builder, expected_df):

pypaimon/py4j/tests/test_write_and_read.py

@@ -28,8 +28,7 @@
 from pypaimon.py4j import Catalog
 from pypaimon.py4j.java_gateway import get_gateway
 from pypaimon.py4j.tests import utils
-from pypaimon.py4j.util import java_utils
-from setup_utils import java_setuputils
+from pypaimon.py4j.util import java_utils, java_setuputils
 
 
 class TableWriteReadTest(unittest.TestCase):