[FLINK-22927] Exception on JobClient.get_job_status().result()

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.0, 1.12.4
• Fix Version/s: 1.14.0, 1.12.5, 1.13.2
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Huang Xingbo
• Reporter: Maciej Bryński
• Created: 08/Jun/21 13:40
• Updated: 23/Sep/21 17:28
• Resolved: 24/Jun/21 03:04

Description

Following code finish with exception

table_env.execute_sql("""
    CREATE TABLE IF NOT EXISTS datagen (
        id INT,
        data STRING
    ) WITH (
        'connector' = 'datagen'
    )
table_env.execute_sql("""
    CREATE TABLE IF NOT EXISTS print (
        id INT,
        data STRING
    ) WITH (
        'connector' = 'print'
    )
""")

table_result = table_env.execute_sql("INSERT INTO print SELECT * FROM datagen")
table_result.get_job_client().get_job_status().result()

---------------------------------------------------------------------------
ValueError                                Traceback (most recent call last)
ValueError: JavaObject id=o125 is not a valid JobStatus

During handling of the above exception, another exception occurred:

ValueError                                Traceback (most recent call last)
<ipython-input-16-ee785b26d044> in <module>
----> 1 result.get_job_client().get_job_status().result()

/usr/local/lib/python3.8/dist-packages/pyflink/common/completable_future.py in result(self)
     76             return self._j_completable_future.get()
     77         else:
---> 78             return self._py_class(self._j_completable_future.get())
     79 
     80     def exception(self):

/usr/lib/python3.8/enum.py in __call__(cls, value, names, module, qualname, type, start)
    307         """
    308         if names is None:  # simple value lookup
--> 309             return cls.__new__(cls, value)
    310         # otherwise, functional API: we're creating a new Enum type
    311         return cls._create_(value, names, module=module, qualname=qualname, type=type, start=start)

/usr/lib/python3.8/enum.py in __new__(cls, value)
    598                         )
    599             exc.__context__ = ve_exc
--> 600             raise exc
    601 
    602     def _generate_next_value_(name, start, count, last_values):

/usr/lib/python3.8/enum.py in __new__(cls, value)
    582         try:
    583             exc = None
--> 584             result = cls._missing_(value)
    585         except Exception as e:
    586             exc = e

/usr/lib/python3.8/enum.py in _missing_(cls, value)
    611     @classmethod
    612     def _missing_(cls, value):
--> 613         raise ValueError("%r is not a valid %s" % (value, cls.__name__))
    614 
    615     def __repr__(self):

ValueError: JavaObject id=o125 is not a valid JobStatus

Issue Links

• links to: GitHub Pull Request #16146