[jira] [Closed] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-31402. -- Resolution: Fixed > Remove ConverterUtils Deprecated Method > ---

[jira] [Commented] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699186#comment-17699186 ] Lijie Wang commented on FLINK-31402: Fix via master: a7b0c2707518a8b7f589e50fa4eafad791d7179f >

[jira] [Comment Edited] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699186#comment-17699186 ] Lijie Wang edited comment on FLINK-31402 at 3/11/23 7:57 AM: - Done via

[jira] [Assigned] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-31402: -- Assignee: Shilun Fan > Remove ConverterUtils Deprecated Method >

[jira] [Updated] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-31402: --- Fix Version/s: 1.18.0 > Remove ConverterUtils Deprecated Method >

[GitHub] [flink] wanglijie95 merged pull request #22159: [FLINK-31402][yarn] Remove usage of deprecated ConverterUtils method.

2023-03-10 Thread via GitHub
wanglijie95 merged PR #22159: URL: https://github.com/apache/flink/pull/22159 -- 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:

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-10 Thread via GitHub
lindong28 commented on code in PR #218: URL: https://github.com/apache/flink-ml/pull/218#discussion_r1133042094 ## flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java: ## @@ -95,4 +109,59 @@ public void testPipeline() throws Exception { // Executes

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-10 Thread via GitHub
lindong28 commented on code in PR #218: URL: https://github.com/apache/flink-ml/pull/218#discussion_r1133042094 ## flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java: ## @@ -95,4 +109,59 @@ public void testPipeline() throws Exception { // Executes

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-10 Thread via GitHub
lindong28 commented on code in PR #218: URL: https://github.com/apache/flink-ml/pull/218#discussion_r1130430131 ## flink-ml-core/src/test/java/org/apache/flink/ml/api/IntegrateWithServableTest.java: ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-30640) Unstable test in CliClientITCase

2023-03-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699161#comment-17699161 ] Shengkai Fang commented on FLINK-30640: --- Because the current problem is much different with the

[jira] [Closed] (FLINK-30640) Unstable test in CliClientITCase

2023-03-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30640. - Resolution: Fixed > Unstable test in CliClientITCase > > >

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-03-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699160#comment-17699160 ] Yun Tang commented on FLINK-31238: -- [~mayuehappy] Thanks for the reply. Considering the efforts to

[jira] [Updated] (FLINK-31403) CliClientITCase print unexpected border when printing explain results

2023-03-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-31403: -- Description: The CliClientITCase fails in the

[jira] [Created] (FLINK-31403) CliClientITCase print unexpected border when printing explain results

2023-03-10 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-31403: - Summary: CliClientITCase print unexpected border when printing explain results Key: FLINK-31403 URL: https://issues.apache.org/jira/browse/FLINK-31403 Project:

[jira] [Updated] (FLINK-30640) Unstable test in CliClientITCase

2023-03-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-30640: -- Priority: Major (was: Blocker) > Unstable test in CliClientITCase >

[jira] [Commented] (FLINK-30640) Unstable test in CliClientITCase

2023-03-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699159#comment-17699159 ] Shengkai Fang commented on FLINK-30640: --- SQL Client infers the column width from the input size

[GitHub] [flink] flinkbot commented on pull request #22159: FLINK-31402. Remove ConverterUtils Deprecated Method.

2023-03-10 Thread via GitHub
flinkbot commented on PR #22159: URL: https://github.com/apache/flink/pull/22159#issuecomment-1464818200 ## CI report: * 52bf5080c464417b229a339245b8015785fae7ec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Shilun Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shilun Fan updated FLINK-31402: --- Description: Many methods in ConverterUtils have been Deprecated, we can replace the Deprecated

[jira] [Updated] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31402: --- Labels: pull-request-available (was: ) > Remove ConverterUtils Deprecated Method >

[GitHub] [flink] slfan1989 opened a new pull request, #22159: FLINK-31402. Remove ConverterUtils Deprecated Method.

2023-03-10 Thread via GitHub
slfan1989 opened a new pull request, #22159: URL: https://github.com/apache/flink/pull/22159 ## What is the purpose of the change JIRA: FLINK-31402. Remove ConverterUtils Deprecated Method. Many methods in ConverterUtils have been Deprecated, we can replace the

[GitHub] [flink] luoyuxia commented on pull request #22106: [FLINK-30659][hive] Drop flink-sql-parser-hive module

2023-03-10 Thread via GitHub
luoyuxia commented on PR #22106: URL: https://github.com/apache/flink/pull/22106#issuecomment-1464817133 @Aitozi Thanks for your reviewing. I have fixed your comments. PTAL again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] luoyuxia commented on a diff in pull request #22106: [FLINK-30659][hive] Drop flink-sql-parser-hive module

2023-03-10 Thread via GitHub
luoyuxia commented on code in PR #22106: URL: https://github.com/apache/flink/pull/22106#discussion_r1133025171 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/validate/FlinkSqlConformance.java: ## @@ -60,24 +54,12 @@ public boolean isHavingAlias() {

[jira] [Closed] (FLINK-31292) User HadoopUtils to get Configuration in CatalogContext

2023-03-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31292. Resolution: Fixed master: d2d4dd0bf8d206307eb2c93aa97e7c1cb750f187 > User HadoopUtils to get

[GitHub] [flink-table-store] JingsongLi merged pull request #592: [FLINK-31292] Introduce HadoopUtils to get Configuration in CatalogContext

2023-03-10 Thread via GitHub
JingsongLi merged PR #592: URL: https://github.com/apache/flink-table-store/pull/592 -- 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] [Created] (FLINK-31402) Remove ConverterUtils Deprecated Method

2023-03-10 Thread Shilun Fan (Jira)
Shilun Fan created FLINK-31402: -- Summary: Remove ConverterUtils Deprecated Method Key: FLINK-31402 URL: https://issues.apache.org/jira/browse/FLINK-31402 Project: Flink Issue Type: Improvement

[GitHub] [flink] wsry commented on pull request #22155: [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread via GitHub
wsry commented on PR #22155: URL: https://github.com/apache/flink/pull/22155#issuecomment-1464796764 This patch is picked. CI [SUCCESS]. Merging. -- 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

[GitHub] [flink] wsry merged pull request #22155: [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread via GitHub
wsry merged PR #22155: URL: https://github.com/apache/flink/pull/22155 -- 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:

[GitHub] [flink-table-store] liyubin117 commented on pull request #592: [FLINK-31292] Correct the default hadoopConf in CatalogContext

2023-03-10 Thread via GitHub
liyubin117 commented on PR #592: URL: https://github.com/apache/flink-table-store/pull/592#issuecomment-1464752148 @JingsongLi I have added more tests, please take a look -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[jira] [Comment Edited] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics

2023-03-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699131#comment-17699131 ] Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 11:57 PM:

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] lightzhao commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
lightzhao commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132969427 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[jira] [Updated] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31102: - Description: Remove all elements that equal to element from array. Syntax: array_remove(array, needle)

[jira] [Updated] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31102: - Description: Remove all elements that equal to element from array. Syntax: array_remove(array, needle)

[jira] [Comment Edited] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics

2023-03-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699131#comment-17699131 ] Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 11:04 PM:

[jira] [Commented] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699136#comment-17699136 ] jackylau commented on FLINK-31102: -- [~Sergey Nuyanzin] ,thanks for your suggestion and have fixed. and

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132948153 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[jira] [Comment Edited] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics

2023-03-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699131#comment-17699131 ] Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 10:38 PM:

[jira] [Comment Edited] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics

2023-03-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699131#comment-17699131 ] Tzu-Li (Gordon) Tai edited comment on FLINK-31363 at 3/10/23 10:36 PM:

[jira] [Commented] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics

2023-03-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699131#comment-17699131 ] Tzu-Li (Gordon) Tai commented on FLINK-31363: - Looking at the KafkaProducer code, the

[GitHub] [flink] mohsenrezaeithe commented on pull request #21849: [FLINK-30596][Runtime/REST] Fix duplicate jobs when submitting with the same jobId

2023-03-10 Thread via GitHub
mohsenrezaeithe commented on PR #21849: URL: https://github.com/apache/flink/pull/21849#issuecomment-1464450206 + @zentol, since the latest commits seem to have removed the assignment. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

2023-03-10 Thread via GitHub
tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132772741 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

2023-03-10 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699077#comment-17699077 ] Mason Chen commented on FLINK-31305: BTW, I had a mishap with git and so this is the proper Github

[jira] [Commented] (FLINK-31401) testTransformationSetParallelism fails on 10 core machines

2023-03-10 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699072#comment-17699072 ] Junrui Li commented on FLINK-31401: --- [~mbalassi] Thanks so much for your volunteering and

[jira] [Commented] (FLINK-31385) Introduce extended Assertj Matchers for completable futures

2023-03-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699037#comment-17699037 ] David Morávek commented on FLINK-31385: --- master: 8424ed2c02e2cc23003919eda53c0fda9e9b353a >

[jira] [Resolved] (FLINK-31385) Introduce extended Assertj Matchers for completable futures

2023-03-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-31385. --- Fix Version/s: 1.18.0 Resolution: Fixed > Introduce extended Assertj Matchers for

[GitHub] [flink] dmvk merged pull request #22140: [FLINK-31385] Introduce extended Assertj matchers for completable fut…

2023-03-10 Thread via GitHub
dmvk merged PR #22140: URL: https://github.com/apache/flink/pull/22140 -- 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:

[GitHub] [flink] flinkbot commented on pull request #22158: [FLINK-25347][table] Replace deprecated TableSchema with Schema in MergeTableLikeUtil

2023-03-10 Thread via GitHub
flinkbot commented on PR #22158: URL: https://github.com/apache/flink/pull/22158#issuecomment-1464043867 ## CI report: * 5e485d67acf67ceeff4e9b49f4bd3d8e2444d816 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-25347) Replace deprecated TableSchema with Schema in MergeTableLikeUtil

2023-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25347: --- Labels: pull-request-available (was: ) > Replace deprecated TableSchema with Schema in

[GitHub] [flink] wuchong opened a new pull request, #22158: [FLINK-25347][table] Replace deprecated TableSchema with Schema in MergeTableLikeUtil

2023-03-10 Thread via GitHub
wuchong opened a new pull request, #22158: URL: https://github.com/apache/flink/pull/22158 ## What is the purpose of the change Replace deprecated `TableSchema` with `Schema` in `MergeTableLikeUtil`. ## Brief change log - Replace deprecated `TableSchema`

[jira] [Assigned] (FLINK-25347) Replace deprecated TableSchema with Schema in MergeTableLikeUtil

2023-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25347: --- Assignee: Jark Wu > Replace deprecated TableSchema with Schema in MergeTableLikeUtil >

[jira] [Comment Edited] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699005#comment-17699005 ] Sergey Nuyanzin edited comment on FLINK-31102 at 3/10/23 4:02 PM: --

[jira] [Commented] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699005#comment-17699005 ] Sergey Nuyanzin commented on FLINK-31102: - Thanks, it already looks better however there is

[jira] [Commented] (FLINK-31363) KafkaSink failed to commit transactions under EXACTLY_ONCE semantics

2023-03-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699003#comment-17699003 ] Tzu-Li (Gordon) Tai commented on FLINK-31363: - Thanks for reporting this [~lightzhao], I

[GitHub] [flink] flinkbot commented on pull request #22157: [FLINK-31401][streaming][tests] Make parallelism assumption explicit in StreamingJobGraphGeneratorTest

2023-03-10 Thread via GitHub
flinkbot commented on PR #22157: URL: https://github.com/apache/flink/pull/22157#issuecomment-1464004662 ## CI report: * 64d5f54076a4f8f8505e9b726ff6e886bf590462 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22153: [FLINK-31317] Introduce JobResourceRequirements and JobVertexResourceRequirements data structures.

2023-03-10 Thread via GitHub
rkhachatryan commented on code in PR #22153: URL: https://github.com/apache/flink/pull/22153#discussion_r1132534295 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResourceRequirements.java: ## @@ -0,0 +1,204 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-31401) testTransformationSetParallelism fails on 10 core machines

2023-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31401: --- Labels: pull-request-available (was: ) > testTransformationSetParallelism fails on 10 core

[GitHub] [flink] mbalassi opened a new pull request, #22157: [FLINK-31401][streaming][tests] Make parallelism assumption explicit in StreamingJobGraphGeneratorTest

2023-03-10 Thread via GitHub
mbalassi opened a new pull request, #22157: URL: https://github.com/apache/flink/pull/22157 Minor improvement to the test, so that it does not fail on 10 core machines. cc @JunRuiLee -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Created] (FLINK-31401) testTransformationSetParallelism fails on 10 core machines

2023-03-10 Thread Jira
Márton Balassi created FLINK-31401: -- Summary: testTransformationSetParallelism fails on 10 core machines Key: FLINK-31401 URL: https://issues.apache.org/jira/browse/FLINK-31401 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #22156: [FLINK-30129][table] Push projection through ChangelogNormalize

2023-03-10 Thread via GitHub
flinkbot commented on PR #22156: URL: https://github.com/apache/flink/pull/22156#issuecomment-1463935653 ## CI report: * d585109ec39d802dea485dd363c3c21c553383b3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-18958) Lose column comment when create table

2023-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18958. --- Fix Version/s: (was: 1.17.0) Assignee: (was: Feng Jin) Resolution: Fixed > Lose

[GitHub] [flink] wuchong closed pull request #13177: [FLINK-18958] Lose column comment when create table

2023-03-10 Thread via GitHub
wuchong closed pull request #13177: [FLINK-18958] Lose column comment when create table URL: https://github.com/apache/flink/pull/13177 -- 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-web] leonardBang commented on a diff in pull request #618: Announcement blogpost for the 1.17 release

2023-03-10 Thread via GitHub
leonardBang commented on code in PR #618: URL: https://github.com/apache/flink-web/pull/618#discussion_r1132492657 ## docs/content/posts/2023-03-09-release-1.17.0.md: ## @@ -0,0 +1,481 @@ +--- +authors: +- LeonardXu: + name: "Leonard Xu" + twitter: Leonardxbj +date:

[jira] [Updated] (FLINK-30129) Push projection through ChangelogNormalize

2023-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30129: --- Labels: pull-request-available (was: ) > Push projection through ChangelogNormalize >

[GitHub] [flink] wuchong opened a new pull request, #22156: [FLINK-30129][table] Push projection through ChangelogNormalize

2023-03-10 Thread via GitHub
wuchong opened a new pull request, #22156: URL: https://github.com/apache/flink/pull/22156 ## What is the purpose of the change Currently, the `ChangelogNormalize` node is generated during the physical optimization phase. That means the projection is not pushed through

[GitHub] [flink] flinkbot commented on pull request #22155: [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread via GitHub
flinkbot commented on PR #22155: URL: https://github.com/apache/flink/pull/22155#issuecomment-1463919298 ## CI report: * 55e4310d5b00b2bc6a294db1ee3c62b28ce0ff8f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698956#comment-17698956 ] jackylau edited comment on FLINK-31102 at 3/10/23 2:48 PM: --- [~Sergey Nuyanzin]

[jira] [Commented] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698956#comment-17698956 ] jackylau commented on FLINK-31102: -- [~jackylau] yeap, it is a misspelling and i have fixed description

[jira] [Updated] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

2023-03-10 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31102: - Description: Remove all elements that equal to element from array. Syntax: array_remove(array, needle)

[GitHub] [flink] wsry opened a new pull request, #22155: [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread via GitHub
wsry opened a new pull request, #22155: URL: https://github.com/apache/flink/pull/22155 ## What is the purpose of the change Currently, the SortMergeResultPartition may allocate more network buffers than the guaranteed size of the LocalBufferPool. As a result, some result partitions

[jira] [Closed] (FLINK-31396) Occasional inaccurate timeout time calculation with System.nanotime in batch read buffer pool

2023-03-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31396. -- Fix Version/s: 1.18.0 Resolution: Fixed master(1.18) via

[GitHub] [flink] reswqa closed pull request #22151: [FLINK-31396][network] Replace the nano time by milliseconds as the timeout time for batch read buffer pool

2023-03-10 Thread via GitHub
reswqa closed pull request #22151: [FLINK-31396][network] Replace the nano time by milliseconds as the timeout time for batch read buffer pool URL: https://github.com/apache/flink/pull/22151 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Closed] (FLINK-31386) Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-31386. --- Resolution: Fixed > Fix the potential deadlock issue of blocking shuffle >

[jira] [Commented] (FLINK-31386) Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698953#comment-17698953 ] Yingjie Cao commented on FLINK-31386: - Merged into 1.17 to unblock release. Will pick to master

[GitHub] [flink] flinkbot commented on pull request #22154: [BP-1.17][FLINK-31393] Fix the bug that HsFileDataManager use an incorrect default timeout.

2023-03-10 Thread via GitHub
flinkbot commented on PR #22154: URL: https://github.com/apache/flink/pull/22154#issuecomment-1463895360 ## CI report: * 7bbfe65d88e8a643b0824965f0308e35ce4ccb85 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-web] leonardBang commented on a diff in pull request #618: Announcement blogpost for the 1.17 release

2023-03-10 Thread via GitHub
leonardBang commented on code in PR #618: URL: https://github.com/apache/flink-web/pull/618#discussion_r1132459372 ## docs/content/posts/2023-03-09-release-1.17.0.md: ## @@ -0,0 +1,481 @@ +--- +authors: +- LeonardXu: + name: "Leonard Xu" + twitter: Leonardxbj +date:

[GitHub] [flink] reswqa opened a new pull request, #22154: [BP-1.17][FLINK-31393] Fix the bug that HsFileDataManager use an incorrect default timeout.

2023-03-10 Thread via GitHub
reswqa opened a new pull request, #22154: URL: https://github.com/apache/flink/pull/22154 Backport FLINK-31393 to release-1.17. -- 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] wsry merged pull request #22148: [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle

2023-03-10 Thread via GitHub
wsry merged PR #22148: URL: https://github.com/apache/flink/pull/22148 -- 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:

[GitHub] [flink] reswqa commented on pull request #22147: [FLINK-31393][runtime] Fix the bug that HsFileDataManager use an incorrect default timeout.

2023-03-10 Thread via GitHub
reswqa commented on PR #22147: URL: https://github.com/apache/flink/pull/22147#issuecomment-1463884228 @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 comment.

[GitHub] [flink-connector-hbase] ferenc-csaky commented on pull request #5: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-03-10 Thread via GitHub
ferenc-csaky commented on PR #5: URL: https://github.com/apache/flink-connector-hbase/pull/5#issuecomment-1463882888 > @ferenc-csaky With @zentol his comments, do you think you could continue working on this? Yep, definitely. -- This is an automated message from the Apache Git

[GitHub] [flink-web] leonardBang commented on a diff in pull request #618: Announcement blogpost for the 1.17 release

2023-03-10 Thread via GitHub
leonardBang commented on code in PR #618: URL: https://github.com/apache/flink-web/pull/618#discussion_r1132433420 ## docs/content/posts/2023-03-09-release-1.17.0.md: ## @@ -0,0 +1,481 @@ +--- +authors: +- LeonardXu: + name: "Leonard Xu" + twitter: Leonardxbj +date:

[GitHub] [flink-web] leonardBang commented on a diff in pull request #618: Announcement blogpost for the 1.17 release

2023-03-10 Thread via GitHub
leonardBang commented on code in PR #618: URL: https://github.com/apache/flink-web/pull/618#discussion_r1132430851 ## docs/content/posts/2023-03-09-release-1.17.0.md: ## @@ -0,0 +1,481 @@ +--- +authors: +- LeonardXu: + name: "Leonard Xu" + twitter: Leonardxbj +date:

[jira] [Created] (FLINK-31400) Add autoscaler integration for Iceberg source

2023-03-10 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-31400: -- Summary: Add autoscaler integration for Iceberg source Key: FLINK-31400 URL: https://issues.apache.org/jira/browse/FLINK-31400 Project: Flink

[jira] [Updated] (FLINK-31400) Add autoscaler integration for Iceberg source

2023-03-10 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-31400: --- Description: A very critical part in the scaling algorithm is setting the source

[jira] [Commented] (FLINK-31395) AbstractPartitionDiscoverer.discoverPartitions calls remove on immutable collection

2023-03-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698939#comment-17698939 ] Matthias Pohl commented on FLINK-31395: --- # Is it a test-code-only issue or does it reveal a

[jira] [Updated] (FLINK-31399) AdaptiveScheduler is able to handle changes in job resource requirements

2023-03-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-31399: -- Description: In FLINK-31317, we've introduced data structures for setting job resource

[GitHub] [flink] flinkbot commented on pull request #22153: [FLINK-31317] Introduce JobResourceRequirements and JobVertexResourceRequirements data structures.

2023-03-10 Thread via GitHub
flinkbot commented on PR #22153: URL: https://github.com/apache/flink/pull/22153#issuecomment-1463787619 ## CI report: * ae1018adab6c66c589cefaa7ea47e9eaa6515ca1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-31399) AdaptiveScheduler is able to handle changes in job resource requirements

2023-03-10 Thread Jira
David Morávek created FLINK-31399: - Summary: AdaptiveScheduler is able to handle changes in job resource requirements Key: FLINK-31399 URL: https://issues.apache.org/jira/browse/FLINK-31399 Project:

[jira] [Updated] (FLINK-31317) Introduce data structures for managing resource requirements of a job

2023-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31317: --- Labels: pull-request-available (was: ) > Introduce data structures for managing resource

[jira] [Updated] (FLINK-31317) Introduce data structures for managing resource requirements of a job

2023-03-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-31317: -- Description: We need to introduce new data structures - JobResourceRequirements and

[GitHub] [flink] dmvk opened a new pull request, #22153: [FLINK-31317] Introduce JobResourceRequirements and JobVertexResourceRequirements data structures.

2023-03-10 Thread via GitHub
dmvk opened a new pull request, #22153: URL: https://github.com/apache/flink/pull/22153 https://issues.apache.org/jira/browse/FLINK-31317 We need to introduce new data structures - JobResourceRequirements and JobVertexResource requirements and the corresponding tooling, that we'll

[GitHub] [flink] dmvk commented on a diff in pull request #22140: [FLINK-31385] Introduce extended Assertj matchers for completable fut…

2023-03-10 Thread via GitHub
dmvk commented on code in PR #22140: URL: https://github.com/apache/flink/pull/22140#discussion_r1132331319 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/core/testutils/FlinkAssertionsTest.java: ## @@ -0,0 +1,121 @@ +/* + * Licensed to the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22140: [FLINK-31385] Introduce extended Assertj matchers for completable fut…

2023-03-10 Thread via GitHub
rkhachatryan commented on code in PR #22140: URL: https://github.com/apache/flink/pull/22140#discussion_r1132327002 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/core/testutils/FlinkAssertionsTest.java: ## @@ -0,0 +1,121 @@ +/* + * Licensed to

[GitHub] [flink] dmvk commented on pull request #22140: [FLINK-31385] Introduce extended Assertj matchers for completable fut…

2023-03-10 Thread via GitHub
dmvk commented on PR #22140: URL: https://github.com/apache/flink/pull/22140#issuecomment-1463745907 Thank you, @rkhachatryan, @reswqa, and @snuyanzin, for looking into this! I've addressed all your comments. PTAL -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] dmvk commented on a diff in pull request #22140: [FLINK-31385] Introduce extended Assertj matchers for completable fut…

2023-03-10 Thread via GitHub
dmvk commented on code in PR #22140: URL: https://github.com/apache/flink/pull/22140#discussion_r1132309980 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/FlinkAssertions.java: ## @@ -25,11 +25,11 @@ import

[GitHub] [flink] dmvk commented on a diff in pull request #22140: [FLINK-31385] Introduce extended Assertj matchers for completable fut…

2023-03-10 Thread via GitHub
dmvk commented on code in PR #22140: URL: https://github.com/apache/flink/pull/22140#discussion_r1132307750 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/FlinkCompletableFutureAssert.java: ## @@ -0,0 +1,104 @@ +/* + * Licensed

[jira] [Comment Edited] (FLINK-31135) ConfigMap DataSize went > 1 MB and cluster stopped working

2023-03-10 Thread Sriram Ganesh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698917#comment-17698917 ] Sriram Ganesh edited comment on FLINK-31135 at 3/10/23 12:25 PM: -

[jira] [Commented] (FLINK-31135) ConfigMap DataSize went > 1 MB and cluster stopped working

2023-03-10 Thread Sriram Ganesh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698917#comment-17698917 ] Sriram Ganesh commented on FLINK-31135: --- [~Swathi Chandrashekar] - it is a pod template config

  1   2   >