[GitHub] [flink] Aitozi commented on pull request #15137: [FLINK-21396][table] Resolve tables when calling Catalog.createTable/alterTable

2022-12-17 Thread GitBox
Aitozi commented on PR #15137: URL: https://github.com/apache/flink/pull/15137#issuecomment-1356124138 Hi @twalthr. Sorry to ping you here. When I am doing some migration work for the hive connector from `TableSchema` to `ResolvedSchema `. I have a question about the `Catalog`'s

[GitHub] [flink] gaborgsomogyi commented on pull request #21128: [FLINK-29710] Bump minimum supported Hadoop version to 2.10.2

2022-12-17 Thread GitBox
gaborgsomogyi commented on PR #21128: URL: https://github.com/apache/flink/pull/21128#issuecomment-1356122504 I'm having vacation till end of the year but had a look to help here :) I've tested that the following works locally: ``` @BeforeClass public static void

[GitHub] [flink] liyubin117 commented on pull request #21521: [FLINK-30435][table] `SHOW CREATE TABLE` statement shows column comment

2022-12-17 Thread GitBox
liyubin117 commented on PR #21521: URL: https://github.com/apache/flink/pull/21521#issuecomment-1356123545 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] link3280 commented on pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

2022-12-17 Thread GitBox
link3280 commented on PR #21292: URL: https://github.com/apache/flink/pull/21292#issuecomment-1356147691 Updated as suggested. CI turns great. cc @fsk119 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] qingwei91 commented on pull request #21403: [FLINK-29984][flink-metrics] Prometheus histogram minmax

2022-12-17 Thread GitBox
qingwei91 commented on PR #21403: URL: https://github.com/apache/flink/pull/21403#issuecomment-1356473916 I will reopen once its ready -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] 1996fanrui commented on pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2022-12-17 Thread GitBox
1996fanrui commented on PR #20151: URL: https://github.com/apache/flink/pull/20151#issuecomment-1356266198 > Thanks for your patience @1996fanrui , I've looked through most of the production code and I've left some comments. But I think I haven't spotted anything major. Hi

[GitHub] [flink] 1996fanrui commented on pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2022-12-17 Thread GitBox
1996fanrui commented on PR #20151: URL: https://github.com/apache/flink/pull/20151#issuecomment-1356316350 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] rohankumardubey closed pull request #16680: Update README.md

2022-12-17 Thread GitBox
rohankumardubey closed pull request #16680: Update README.md URL: https://github.com/apache/flink/pull/16680 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe,

[GitHub] [flink] qingwei91 closed pull request #21403: [FLINK-29984][flink-metrics] Prometheus histogram minmax

2022-12-17 Thread GitBox
qingwei91 closed pull request #21403: [FLINK-29984][flink-metrics] Prometheus histogram minmax URL: https://github.com/apache/flink/pull/21403 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] 1996fanrui commented on pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2022-12-17 Thread GitBox
1996fanrui commented on PR #20151: URL: https://github.com/apache/flink/pull/20151#issuecomment-1356350601 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-25003) RestClientTest#testConnectionTimeout fails on Java 17

2022-12-17 Thread Gunnar Morling (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648939#comment-17648939 ] Gunnar Morling commented on FLINK-25003: I'll take a look, can any of the committers assign this

[jira] [Commented] (FLINK-15736) Support Java 17 (LTS)

2022-12-17 Thread Gunnar Morling (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648938#comment-17648938 ] Gunnar Morling commented on FLINK-15736: [~martijnvisser], thank you so much for the quick

[jira] [Created] (FLINK-30447) Scylladb SQL sink connector

2022-12-17 Thread Krish Narukulla (Jira)
Krish Narukulla created FLINK-30447: --- Summary: Scylladb SQL sink connector Key: FLINK-30447 URL: https://issues.apache.org/jira/browse/FLINK-30447 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-17 Thread Kumar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648972#comment-17648972 ] Kumar commented on FLINK-30411: --- [~gyfora] Could you assign this issue to me? I can send a PR right away

[GitHub] [flink] flinkbot commented on pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2022-12-17 Thread GitBox
flinkbot commented on PR #21522: URL: https://github.com/apache/flink/pull/21522#issuecomment-1356710756 ## CI report: * 860fe43a26f94bc5b5905f20fc59ea2e0e69574f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Aitozi opened a new pull request, #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2022-12-17 Thread GitBox
Aitozi opened a new pull request, #21522: URL: https://github.com/apache/flink/pull/21522 ## What is the purpose of the change This PR is meant to migrate the `TableSchema` to the `Schema` and `ResolvedSchema`. Most `TableSchema` have been moved out of the hive connector module.

[jira] [Updated] (FLINK-29585) Migrate TableSchema to Schema for Hive connector

2022-12-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29585: --- Labels: pull-request-available (was: ) > Migrate TableSchema to Schema for Hive connector

[jira] [Closed] (FLINK-29066) Reconsider the runtime property of the BuiltInFunctionDefinition

2022-12-17 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-29066. -- Resolution: Won't Fix > Reconsider the runtime property of the BuiltInFunctionDefinition >

[jira] [Closed] (FLINK-29085) Add the name for test as hint for the current test case in BuiltInFunctionTestBase

2022-12-17 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-29085. -- Resolution: Won't Fix > Add the name for test as hint for the current test case in > BuiltInFunctionTestBase

[jira] [Assigned] (FLINK-30447) Scylladb SQL sink connector

2022-12-17 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-30447: - Assignee: Krish Narukulla > Scylladb SQL sink connector > --- > >

[GitHub] [flink] fsk119 commented on a diff in pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

2022-12-17 Thread GitBox
fsk119 commented on code in PR #21292: URL: https://github.com/apache/flink/pull/21292#discussion_r1051520363 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -405,4 +426,115 @@ private Set

[GitHub] [flink] fsk119 merged pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

2022-12-17 Thread GitBox
fsk119 merged PR #21292: URL: https://github.com/apache/flink/pull/21292 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-28617) Support stop job statement in SqlGatewayService

2022-12-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648964#comment-17648964 ] Shengkai Fang commented on FLINK-28617: --- Merged into master:

[jira] [Closed] (FLINK-28617) Support stop job statement in SqlGatewayService

2022-12-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-28617. - Resolution: Implemented > Support stop job statement in SqlGatewayService >

[jira] [Assigned] (FLINK-28617) Support stop job statement in SqlGatewayService

2022-12-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-28617: - Assignee: Paul Lin > Support stop job statement in SqlGatewayService >

[jira] [Created] (FLINK-30448) "filter(Objects::nonNull)" will bring down task with failure cause: ClassCastException

2022-12-17 Thread Wang Yong (Jira)
Wang Yong created FLINK-30448: - Summary: "filter(Objects::nonNull)" will bring down task with failure cause: ClassCastException Key: FLINK-30448 URL: https://issues.apache.org/jira/browse/FLINK-30448