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

["Maciej Bryński (Jira)" <ji...@apache.org>]

Maciej Bryński created FLINK-22927:
--------------------------------------

             Summary: Exception on JobClient.get_job_status().result()
                 Key: FLINK-22927
                 URL: https://issues.apache.org/jira/browse/FLINK-22927
             Project: Flink
          Issue Type: Bug
          Components: API / Python
    Affects Versions: 1.13.0
            Reporter: Maciej Bryński


Following code finish with exception
{code:java}
result = table_env.execute_sql("INSERT INTO print SELECT * FROM datagen")
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
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)