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