[jira] [Commented] (FLINK-17920) Add the Python example of Time-windowed join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115864#comment-17115864 ] shuiqiangchen commented on FLINK-17920: --- Hi [~hxbks2ks]， thank you for reporting t

[jira] [Created] (FLINK-17700) The callback client of JavaGatewayServer should run in a daemon thread

shuiqiangchen created FLINK-17700: - Summary: The callback client of JavaGatewayServer should run in a daemon thread Key: FLINK-17700 URL: https://issues.apache.org/jira/browse/FLINK-17700 Project: Fli

[jira] [Updated] (FLINK-17609) Execute the script directly when user specified the entry script with "-py" rather than run as module.

[ https://issues.apache.org/jira/browse/FLINK-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen updated FLINK-17609: -- Description: Currently, the PythonDriver will always construct the python execution command w

[jira] [Created] (FLINK-17609) Execute the script directly when user specified the entry script with "-py" rather than run as module.

shuiqiangchen created FLINK-17609: - Summary: Execute the script directly when user specified the entry script with "-py" rather than run as module. Key: FLINK-17609 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Commented] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095279#comment-17095279 ] shuiqiangchen commented on FLINK-17254: --- Hi [~sunjincheng121], I would like to tak

[jira] [Updated] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen updated FLINK-17254: -- Description: Currently there are two ways to register a table sink/source in PyFlink table AP

[jira] [Updated] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen updated FLINK-17254: -- Description: Currently there are two ways to register a table sink/source in PyFlink table AP

[jira] [Commented] (FLINK-14369) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018784#comment-17018784 ] shuiqiangchen commented on FLINK-14369: --- Hi [~gjy] I'm watching this issue, could

[jira] [Assigned] (FLINK-11264) Fail to start scala shell

[ https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen reassigned FLINK-11264: - Assignee: shuiqiangchen > Fail to start scala shell > - > >

[jira] [Commented] (FLINK-11263) yarn session script doesn't boot up task managers

[ https://issues.apache.org/jira/browse/FLINK-11263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733757#comment-16733757 ] shuiqiangchen commented on FLINK-11263: --- Hi HongTao，when started the yarn session,

[jira] [Commented] (FLINK-11244) flink web.port can not be configured correctly in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-11244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16731824#comment-16731824 ] shuiqiangchen commented on FLINK-11244: --- Hi Kaicheng, when launched flink on yarn,

[jira] [Assigned] (FLINK-11161) Unable to import java packages in scala-shell

[ https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen reassigned FLINK-11161: - Assignee: shuiqiangchen > Unable to import java packages in scala-shell > -

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688983#comment-16688983 ] shuiqiangchen commented on FLINK-9555: -- Hi [~zjffdu] and [~sunjincheng121], I have e

[jira] [Assigned] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen reassigned FLINK-9555: Assignee: shuiqiangchen > Support table api in scala shell > -