public boolean isAfterFlink114() {
    return flinkInterpreter.getFlinkVersion().isAfterFlink114();
  }
@Test
  void testBatchIPyFlink() throws InterpreterException, IOException {
    if (!flinkInnerInterpreter.getFlinkVersion().isAfterFlink114()) {
      testBatchPyFlink(interpreter, flinkScalaInterpreter);
    }
  }