[
https://issues.apache.org/jira/browse/FLINK-35249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Yuan closed FLINK-35249.
Release Note: There is a sample date gererator in Java code. I thought we
only need complete the doc.
[
https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842295#comment-17842295
]
Wei Yuan commented on FLINK-35212:
--
Hi Biao Geng, as you say, maybe the exception which
[
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
"flink-connectors/flink-connector-
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
[
https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840036#comment-17840036
]
Wei Yuan edited comment on FLINK-35212 at 4/23/24 11:10 AM:
[
https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840036#comment-17840036
]
Wei Yuan commented on FLINK-35212:
--
After debug this test case, I found an "Native Libr
[
https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839926#comment-17839926
]
Wei Yuan commented on FLINK-35212:
--
I also tested this issue with Java8 and Python 3.8.
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
[
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 does
[
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 i
[
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 i
[
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 im
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
13 matches
Mail list logo
