Hello I've been trying to setup StateTtl for my PyFlink application using thread mode. I was following the examples in the docs (needed to use Time instead of Duration) -- https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/#state-in-the-scala-datastream-api .
This seems to work without thread mode enabled, but with it enabled getting the following exception. Any ideas what is going on? pemja.core.PythonException: <class 'RuntimeError'>: There are no matched Java Methods. at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/embedded/operations.open(operations.py:33) ~[?:?] at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/datastream/embedded/operations.open(operations.py:48) ~[?:?] at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/datastream/embedded/operations.open_func(operations.py:119) ~[?:?] ... at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/datastream/embedded/runtime_context.get_map_state(runtime_context.py:90) ~[?:?] at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/embedded/state_impl.get_map_state(state_impl.py:65) ~[?:?] at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/embedded/state_impl._get_or_create_keyed_state(state_impl.py:87) ~[?:?] at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/embedded/java_utils.to_java_state_descriptor(java_utils.py:202) ~[?:?] at /usr/local/lib/python3.11/site-packages/pyflink/fn_execution/embedded/java_utils.to_java_state_ttl_config(java_utils.py:176) ~[?:?] at pemja.core.PythonInterpreter.invokeMethodNoArgs(Native Method) ~[?:?] at pemja.core.PythonInterpreter.invokeMethod(PythonInterpreter.java:114) ~[?:?] at org.apache.flink.streaming.api.operators.python.embedded.AbstractOneInputEmbeddedPythonFunctionOperator.openPythonInterpreter(AbstractOneInputEmbeddedPythonFunctionOperator.java:138) ~[?:?] at org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedPythonFunctionOperator.open(AbstractEmbeddedPythonFunctionOperator.java:103) ~[?:?] at org.apache.flink.streaming.api.operators.python.embedded.AbstractEmbeddedDataStreamPythonFunctionOperator.open(AbstractEmbeddedDataStreamPythonFunctionOperator.java:88) ~[?:?] at org.apache.flink.streaming.api.operators.python.embedded.AbstractOneInputEmbeddedPythonFunctionOperator.open(AbstractOneInputEmbeddedPythonFunctionOperator.java:68) ~[?:?] at org.apache.flink.streaming.api.operators.python.embedded.EmbeddedPythonKeyedProcessOperator.open(EmbeddedPythonKeyedProcessOperator.java:94) ~[?:?]
