[jira] [Commented] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842295#comment-17842295 ] Wei Yuan commented on FLINK-35212: -- Hi Biao Geng, as you say, maybe the exception which I submitted

[jira] [Updated] (FLINK-35249) Support DataGeneratorSource in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-35249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35249: - Description: I notice DataGeneratorSource with Java has submitted in

[jira] [Created] (FLINK-35249) Support DataGeneratorSource in PyFlink

Wei Yuan created FLINK-35249: Summary: Support DataGeneratorSource in PyFlink Key: FLINK-35249 URL: https://issues.apache.org/jira/browse/FLINK-35249 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840036#comment-17840036 ] Wei Yuan edited comment on FLINK-35212 at 4/23/24 11:10 AM: After debug this

[jira] [Commented] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840036#comment-17840036 ] Wei Yuan commented on FLINK-35212: -- After debug this test case, I found an "Native Library

[jira] [Commented] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839926#comment-17839926 ] Wei Yuan commented on FLINK-35212: -- I also tested this issue with Java8 and Python 3.8.6 and another

[jira] [Created] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

Wei Yuan created FLINK-35212: Summary: PyFlink thread mode process just can run once in standalonesession mode Key: FLINK-35212 URL: https://issues.apache.org/jira/browse/FLINK-35212 Project: Flink

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python thread mode

[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Summary: Instant in row doesn't convert to correct type in python thread mode (was: Instant in row

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Description: {code:java} from pyflink.datastream import StreamExecutionEnvironment from pyflink.common

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Description: {code:java} from pyflink.datastream import StreamExecutionEnvironment from pyflink.common

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Description: use  ``` from pyflink.datastream import StreamExecutionEnvironment from pyflink.common

[jira] [Created] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

Wei Yuan created FLINK-35180: Summary: Instant in row doesn't convert to correct type in python process mode Key: FLINK-35180 URL: https://issues.apache.org/jira/browse/FLINK-35180 Project: Flink