[
https://issues.apache.org/jira/browse/FLINK-22927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-22927.
----------------------------------
Resolution: Fixed
Merged into master via f998ec73158657ac1ea7fc09a670dc39b925b6e2
Merged into release-1.13 via d755fa945632c135a6179a837d776d21ec28f63c
Merged into release-1.12 via cdec22eec857e24508dc67099c5d4fef70a3200b
> 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, 1.12.4
> Reporter: Maciej Bryński
> Assignee: Huang Xingbo
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.14.0, 1.12.5, 1.13.2
>
>
> Following code finish with exception
> {code:java}
> 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'
> )
> """){code}
> {code:java}
> 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
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
