class_docstr: We need to start these Java tests from python process to make sure that Python environment is
  available when the tests are running.
class_docstr_tok: ["We","need","to","start","these","Java","tests","from","python","process","to","make","sure","that","Python","environment","is","available","when","the","tests","are","running","."]
code: def test_java_sql_ddl(self):
      test_class = (
          "org.apache.flink.client.python.PythonFunctionFactoryTest"
      )
      test_jar_pattern = "flink-python/target/artifacts/testJavaDdl.jar"
      test_jar_path = self.get_jar_path(test_jar_pattern)
      test_classpath = self.get_classpath() + os.pathsep + test_jar_path
      java_executable = self.get_java_executable()
      subprocess.check_output(
          [
              java_executable,
              "-XX:+IgnoreUnrecognizedVMOptions",
              "--add-opens=java.base/java.lang=ALL-UNNAMED",
              "-cp",
              test_classpath,
              test_class,
          ],
          shell=False,
      )
  
file_path: flink/flink-python/pyflink/table/tests/test_sql.py
imports: import glob
  import os
  import subprocess
  from pyflink.find_flink_home import _find_flink_source_root
  from pyflink.java_gateway import get_gateway
  from pyflink.table import ResultKind, ExplainDetail
  from pyflink.table import expressions
  from pyflink.testing import source_sink_utils
  from pyflink.testing.test_case_utils import PyFlinkStreamTableTestCase, PyFlinkTestCase
label_desc: Use image node_id 4 for calling the JavaSqlTests obj's underlying member method code with example usage: obj.test_java_sql_ddl() without return types