[jira] [Assigned] (FLINK-31849) Enforce some some simple validation directly through the CRD

2023-05-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-31849: -- Assignee: Zhenqiu Huang > Enforce some some simple validation directly through the CRD >

[jira] [Commented] (FLINK-31849) Enforce some some simple validation directly through the CRD

2023-05-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722442#comment-17722442 ] Gyula Fora commented on FLINK-31849: Sure:) > Enforce some some simple validation directly through

[jira] [Commented] (FLINK-31849) Enforce some some simple validation directly through the CRD

2023-05-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722435#comment-17722435 ] Zhenqiu Huang commented on FLINK-31849: --- [~gyfora] May I take this? > Enforce some some simple

[jira] [Commented] (FLINK-31998) Flink Operator Deadlock on run job Failure

2023-05-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722434#comment-17722434 ] Zhenqiu Huang commented on FLINK-31998: --- [~gyfora] Technically, if a session job is created, it is

[GitHub] [flink-kubernetes-operator] huaxk opened a new pull request, #596: fix: flink account cannot get resource "services" in API group

2023-05-13 Thread via GitHub
huaxk opened a new pull request, #596: URL: https://github.com/apache/flink-kubernetes-operator/pull/596 ## What is the purpose of the change When I remotely connected to the Flink cluster using local SQL client, I encountered an error while submitting an SQL statement: ```

[jira] [Commented] (FLINK-28842) Add client.id.prefix for the KafkaSink

2023-05-13 Thread Valentina Predtechenskaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722386#comment-17722386 ] Valentina Predtechenskaya commented on FLINK-28842: --- Is there any progress on this

[GitHub] [flink] LadyForest commented on a diff in pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and StateMetadataJson SerDe

2023-05-13 Thread via GitHub
LadyForest commented on code in PR #22492: URL: https://github.com/apache/flink/pull/22492#discussion_r1193015588 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/StateMetadataJsonSerializer.java: ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink] LadyForest commented on a diff in pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and StateMetadataJson SerDe

2023-05-13 Thread via GitHub
LadyForest commented on code in PR #22492: URL: https://github.com/apache/flink/pull/22492#discussion_r1193015588 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/StateMetadataJsonSerializer.java: ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink-connector-aws] dannycranmer commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-13 Thread via GitHub
dannycranmer commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1192958496 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.java: ## @@ -0,0 +1,56 @@ +/* + *

[jira] [Comment Edited] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-13 Thread Vishaal Selvaraj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722352#comment-17722352 ] Vishaal Selvaraj edited comment on FLINK-20794 at 5/13/23 9:45 AM: --- As

[jira] [Comment Edited] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-13 Thread Vishaal Selvaraj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722352#comment-17722352 ] Vishaal Selvaraj edited comment on FLINK-20794 at 5/13/23 9:43 AM: --- As

[jira] [Commented] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-13 Thread Vishaal Selvaraj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722352#comment-17722352 ] Vishaal Selvaraj commented on FLINK-20794: -- As for the table API equivalency, I can see that we

[jira] [Comment Edited] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-13 Thread Vishaal Selvaraj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722345#comment-17722345 ] Vishaal Selvaraj edited comment on FLINK-20794 at 5/13/23 8:42 AM: ---

[jira] [Commented] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-13 Thread Vishaal Selvaraj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722345#comment-17722345 ] Vishaal Selvaraj commented on FLINK-20794: -- Looks like this feature is already available in

[jira] [Updated] (FLINK-20794) Support to select distinct columns in the Table API

2023-05-13 Thread Vishaal Selvaraj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vishaal Selvaraj updated FLINK-20794: - Attachment: screenshot-1.png > Support to select distinct columns in the Table API >