[
https://issues.apache.org/jira/browse/FLINK-22927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maciej Bryński updated FLINK-22927:
-----------------------------------
Description:
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}
was:
Following code finish with exception
{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}
> 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
> Priority: Major
>
> 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)
