[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16965265#comment-16965265 ] Leo Zhang commented on FLINK-14319: --- Once this issue gets enough votes and the community reaches an

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Fix Version/s: (was: 1.10.0) > Register user jar files in {Stream}ExecutionEnvironment >

[jira] [Updated] (FLINK-14729) Multi-topics consuming from KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14729: -- Fix Version/s: (was: 1.10.0) > Multi-topics consuming from KafkaTableSource >

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement applications

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993116#comment-16993116 ] Leo Zhang commented on FLINK-14055: --- The committer requires a discussion first. So please join the

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement applications

[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993113#comment-16993113 ] Leo Zhang commented on FLINK-14319: --- Please join the discussion on dev mailing list: [DISCUSS]

[jira] [Created] (FLINK-14729) Multi-topics consuming from KafkaTableSource

Leo Zhang created FLINK-14729: - Summary: Multi-topics consuming from KafkaTableSource Key: FLINK-14729 URL: https://issues.apache.org/jira/browse/FLINK-14729 Project: Flink Issue Type: New

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:06 AM: - PR on github

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:05 AM: - -PR on github

[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947284#comment-16947284 ] Leo Zhang commented on FLINK-14319: --- Thanks. The PR is closed for now. And I proposed a plan for

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Docs Text: Design - 1 - 2 - 3 Labels: (was: pull-request-available) > Register user jar

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Docs Text: (was: Design - 1 - 2 - 3) Description:  I see that there are some use cases in

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:08 AM: - PR on github

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:08 AM: - PR on github

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:07 AM: - PR on github

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement their own SQL

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943304#comment-16943304 ] Leo Zhang edited comment on FLINK-14055 at 10/3/19 3:50 AM: Hi, everyone. I

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943304#comment-16943304 ] Leo Zhang edited comment on FLINK-14055 at 10/3/19 4:23 AM: Hi, everyone. I

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944912#comment-16944912 ] Leo Zhang commented on FLINK-14055: --- PR on github https://github.com/apache/flink/pull/9841

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944912#comment-16944912 ] Leo Zhang edited comment on FLINK-14055 at 10/4/19 11:40 PM: - PR on github

[jira] [Comment Edited] (FLINK-10232) Add a SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944458#comment-16944458 ] Leo Zhang edited comment on FLINK-10232 at 10/5/19 10:05 AM: - I feel like

[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944911#comment-16944911 ] Leo Zhang commented on FLINK-14319: --- PR on github https://github.com/apache/flink/pull/9841 >

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944595#comment-16944595 ] Leo Zhang commented on FLINK-14055: --- Yeah. I totally agree with you [~twalthr] that this sub-task may

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944595#comment-16944595 ] Leo Zhang edited comment on FLINK-14055 at 10/4/19 3:28 PM: Yeah. I totally

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943304#comment-16943304 ] Leo Zhang edited comment on FLINK-14055 at 10/3/19 3:47 AM: Hi, everyone. I

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943311#comment-16943311 ] Leo Zhang commented on FLINK-14055: --- You're right that we should follow the design doc FLINK-10232.

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943304#comment-16943304 ] Leo Zhang edited comment on FLINK-14055 at 10/3/19 3:46 AM: Hi, everyone. I

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943304#comment-16943304 ] Leo Zhang edited comment on FLINK-14055 at 10/3/19 3:45 AM: Hi, everyone. I

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943304#comment-16943304 ] Leo Zhang commented on FLINK-14055: --- Hi, everyone. I have implemented

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement their own SQL

[jira] [Commented] (FLINK-10232) Add a SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944458#comment-16944458 ] Leo Zhang commented on FLINK-10232: --- I feel like it's better to split this task FLINK-14055 into two

[jira] [Comment Edited] (FLINK-10232) Add a SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944458#comment-16944458 ] Leo Zhang edited comment on FLINK-10232 at 10/4/19 12:29 PM: - I feel like

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement their own SQL

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement their own SQL

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement their own SQL

[jira] [Created] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

Leo Zhang created FLINK-14319: - Summary: Register user jar files in {Stream}ExecutionEnvironment Key: FLINK-14319 URL: https://issues.apache.org/jira/browse/FLINK-14319 Project: Flink Issue

[jira] [Created] (FLINK-28475) kafka connector won't stop when the stopping offset is zero

Leo zhang created FLINK-28475: - Summary: kafka connector won't stop when the stopping offset is zero Key: FLINK-28475 URL: https://issues.apache.org/jira/browse/FLINK-28475 Project: Flink Issue

[jira] [Created] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

Leo zhang created FLINK-29128: - Summary: Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader Key: FLINK-29128 URL: https://issues.apache.org/jira/browse/FLINK-29128

[jira] [Comment Edited] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

[ https://issues.apache.org/jira/browse/FLINK-29128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598157#comment-17598157 ] Leo zhang edited comment on FLINK-29128 at 8/31/22 4:05 AM: Actually, for

[jira] [Commented] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

[ https://issues.apache.org/jira/browse/FLINK-29128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598157#comment-17598157 ] Leo zhang commented on FLINK-29128: --- Actually, for unbounded case, we do assign the empty splits since

[jira] [Comment Edited] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

[ https://issues.apache.org/jira/browse/FLINK-29128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598157#comment-17598157 ] Leo zhang edited comment on FLINK-29128 at 8/31/22 4:10 AM: Actually, for