[GitHub] [flink-table-store] tsreaper merged pull request #491: [FLINK-30861] Fix java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList in Table Store Hive catalog

2023-01-31 Thread via GitHub
tsreaper merged PR #491: URL: https://github.com/apache/flink-table-store/pull/491 -- 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: issues-unsubscr...@fl

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-01-31 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1092862838 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java: ## @@ -197,9 +199,23 @@ public ExecutionGraph createAndRestoreE

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-01-31 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682896#comment-17682896 ] Feifan Wang commented on FLINK-28440: - [~Yanfei Lei] , Thank you for your reminder,

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-01-31 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1092862838 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java: ## @@ -197,9 +199,23 @@ public ExecutionGraph createAndRestoreE

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-01-31 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1092860438 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/jsonplan/JsonPlanGenerator.java: ## @@ -117,10 +118,27 @@ public static String generatePlan(

[GitHub] [flink] leonardBang commented on a diff in pull request #21806: [FLINK-29427][table] Fix unstable test LookupJoinITCase by compiling Projection class in advance and run reload task using user

2023-01-31 Thread via GitHub
leonardBang commented on code in PR #21806: URL: https://github.com/apache/flink/pull/21806#discussion_r1092856636 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/keyselector/GenericRowDataKeySelector.java: ## @@ -44,7 +44,23 @@ public GenericRowD

[GitHub] [flink] flinkbot commented on pull request #21815: [FLINK-28326][test] fix unstable test testIdleAndBackPressuredTime.

2023-01-31 Thread via GitHub
flinkbot commented on PR #21815: URL: https://github.com/apache/flink/pull/21815#issuecomment-1411587097 ## CI report: * 71e2be23edda8984fbcb93146510fcfb993385a2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa commented on a diff in pull request #21815: [FLINK-28326][test] fix unstable test testIdleAndBackPressuredTime.

2023-01-31 Thread via GitHub
reswqa commented on code in PR #21815: URL: https://github.com/apache/flink/pull/21815#discussion_r1092842665 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java: ## @@ -399,6 +399,10 @@ void testIdleAndBackPressuredTime() throws

[jira] [Updated] (FLINK-30861) Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment

2023-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30861: --- Labels: pull-request-available (was: ) > Table Store Hive Catalog throws java.lang.ClassNot

[GitHub] [flink-table-store] tsreaper opened a new pull request, #491: [FLINK-30861] Fix java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList in Table Store Hive catalog

2023-01-31 Thread via GitHub
tsreaper opened a new pull request, #491: URL: https://github.com/apache/flink-table-store/pull/491 Table Store Hive catalog throws `java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList` under certain environment. We need to package `hive-storage-api` dependency.

[jira] [Created] (FLINK-30861) Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment

2023-01-31 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-30861: --- Summary: Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment Key: FLINK-30861 URL: https://is

[jira] [Closed] (FLINK-30819) Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30819. - Fix Version/s: 1.17.0 Resolution: Fixed Fixed in mater: db82f82bd94a0af059bcfd6e85b3ae31b

[jira] [Updated] (FLINK-30819) Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30819: --- Labels: pull-request-available (was: ) > Fix sql client print an empty line between the mul

[jira] [Updated] (FLINK-30819) Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-30819: -- Component/s: Table SQL / Client > Fix sql client print an empty line between the multi-line st

[jira] [Assigned] (FLINK-30819) Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-30819: - Assignee: Shengkai Fang > Fix sql client print an empty line between the multi-line sta

[GitHub] [flink] fsk119 closed pull request #21786: [FLINK-30819][sql-client] Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread via GitHub
fsk119 closed pull request #21786: [FLINK-30819][sql-client] Fix sql client print an empty line between the multi-line statements URL: https://github.com/apache/flink/pull/21786 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-01-31 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1092837627 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java: ## @@ -197,9 +199,23 @@ public ExecutionGraph createAndRestoreE

[jira] [Updated] (FLINK-30819) Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-30819: -- Summary: Fix sql client print an empty line between the multi-line statements (was: Fix histo

[GitHub] [flink] fsk119 commented on pull request #21786: [FLINK-30816][sql-client] Fix sql client print an empty line between the multi-line statements

2023-01-31 Thread via GitHub
fsk119 commented on PR #21786: URL: https://github.com/apache/flink/pull/21786#issuecomment-1411563426 The failed test is not releated to the change. I also verify the results in my local machine. Merging... -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #484: [FLINK-30516] Introduce files table in table store

2023-01-31 Thread via GitHub
JingsongLi commented on code in PR #484: URL: https://github.com/apache/flink-table-store/pull/484#discussion_r1092829860 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsConverters.java: ## @@ -0,0 +1,92 @@ +/* + * Licensed to the Apache

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #484: [FLINK-30516] Introduce files table in table store

2023-01-31 Thread via GitHub
JingsongLi commented on code in PR #484: URL: https://github.com/apache/flink-table-store/pull/484#discussion_r1092828531 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AppendOnlyFileStoreScan.java: ## @@ -102,25 +101,6 @@ protected boolean f

[GitHub] [flink] masteryhx commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-31 Thread via GitHub
masteryhx commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1092823807 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java: ## @@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVi

[jira] [Commented] (FLINK-30811) Fix sql gateway can not stop job correctly

2023-01-31 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682881#comment-17682881 ] Paul Lin commented on FLINK-30811: -- [~qingyue] [~fsk119] Sorry for introducing this bug

[GitHub] [flink] masteryhx commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-31 Thread via GitHub
masteryhx commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1092823807 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java: ## @@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVi

[GitHub] [flink] JunRuiLee commented on pull request #21814: [FLINK-30846][runtime] Fix the getSchedulerType when test with flink.tests.enable-adaptive-scheduler

2023-01-31 Thread via GitHub
JunRuiLee commented on PR #21814: URL: https://github.com/apache/flink/pull/21814#issuecomment-1411543322 @zhuzhurk @wanglijie95 Could you help to review this fix? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[jira] [Created] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler

2023-01-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-30860: -- Summary: Add document for hybrid shuffle with adaptive batch scheduler Key: FLINK-30860 URL: https://issues.apache.org/jira/browse/FLINK-30860 Project: Flink Is

[jira] [Commented] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682875#comment-17682875 ] Shengkai Fang commented on FLINK-27344: --- [~Paul Lin]  After refactoring the SQL Cl

[jira] [Assigned] (FLINK-30811) Fix sql gateway can not stop job correctly

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-30811: - Assignee: Jane Chan > Fix sql gateway can not stop job correctly >

[jira] [Resolved] (FLINK-28363) Support drop savepoint statement in SQL client

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang resolved FLINK-28363. --- Resolution: Resolved > Support drop savepoint statement in SQL client >

[jira] [Resolved] (FLINK-28362) Support savepoint statements in SQL client

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang resolved FLINK-28362. --- Resolution: Resolved > Support savepoint statements in SQL client >

[jira] [Resolved] (FLINK-28361) Support show jobs statement in SQL client

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang resolved FLINK-28361. --- Resolution: Resolved > Support show jobs statement in SQL client > -

[jira] [Closed] (FLINK-30538) Improve error handling of stop job operation

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30538. - Resolution: Fixed Merged into master: d657395248c4cb189ee11356aa596dd84093b3d3 > Improve error

[GitHub] [flink] flinkbot commented on pull request #21814: [FLINK-30846][runtime] Fix the getSchedulerType when test with flink.tests.enable-adaptive-scheduler

2023-01-31 Thread via GitHub
flinkbot commented on PR #21814: URL: https://github.com/apache/flink/pull/21814#issuecomment-1411538178 ## CI report: * 452b7c640add78c9469436565831b27e8757dc7f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-30538) Improve error handling of stop job operation

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-30538: - Assignee: Paul Lin > Improve error handling of stop job operation > ---

[GitHub] [flink] fsk119 merged pull request #21581: [FLINK-30538][SQL gateway/client] Improve error handling of stop job operation

2023-01-31 Thread via GitHub
fsk119 merged PR #21581: URL: https://github.com/apache/flink/pull/21581 -- 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: issues-unsubscr...@flink.apache

[GitHub] [flink-table-store] zjureel commented on pull request #484: [FLINK-30516] Introduce files table in table store

2023-01-31 Thread via GitHub
zjureel commented on PR #484: URL: https://github.com/apache/flink-table-store/pull/484#issuecomment-1411532814 Thanks @JingsongLi I have updated the code, please have a look again, THX -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Updated] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30846: --- Labels: pull-request-available test-stability (was: test-stability) > SpeculativeSchedulerI

[GitHub] [flink] JunRuiLee opened a new pull request, #21814: [FLINK-30846][runtime] Fix the getSchedulerType when test with flink.tests.enable-adaptive-scheduler

2023-01-31 Thread via GitHub
JunRuiLee opened a new pull request, #21814: URL: https://github.com/apache/flink/pull/21814 ## What is the purpose of the change Fix the getSchedulerType when test with flink.tests.enable-adaptive-scheduler ## Verifying this change This change is a tr

[jira] [Commented] (FLINK-30817) ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown

2023-01-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682867#comment-17682867 ] luoyuxia commented on FLINK-30817: -- [~csq] Thanks for reporting. Would you like to help

[jira] [Commented] (FLINK-30817) ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown

2023-01-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682868#comment-17682868 ] luoyuxia commented on FLINK-30817: -- Introuduced by FLINK-24717 > ClassCastException in

[jira] [Commented] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682866#comment-17682866 ] Junrui Li commented on FLINK-30846: --- [~wanglijie] This issue will not be a block to pr

[jira] [Created] (FLINK-30859) Remove flink-connector-kafka rom master branch

2023-01-31 Thread Mason Chen (Jira)
Mason Chen created FLINK-30859: -- Summary: Remove flink-connector-kafka rom master branch Key: FLINK-30859 URL: https://issues.apache.org/jira/browse/FLINK-30859 Project: Flink Issue Type: Techni

[jira] [Commented] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682862#comment-17682862 ] Lijie Wang commented on FLINK-30846: [~JunRuiLi] Would you take a look? > Speculati

[jira] [Comment Edited] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682858#comment-17682858 ] Lijie Wang edited comment on FLINK-30846 at 2/1/23 6:14 AM:

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682860#comment-17682860 ] Shengkai Fang commented on FLINK-30727: --- I meet mulitple times in the pipeline: [

[jira] [Assigned] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-30846: -- Assignee: Junrui Li (was: Li Pi) > SpeculativeSchedulerITCase.testSpeculativeExecutionOfInpu

[jira] [Closed] (FLINK-30624) Performance regression in stateBackends.FS / FS_ASYNC / MEMORY on 05.01.2023

2023-01-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30624. --- Resolution: Fixed > Performance regression in stateBackends.FS / FS_ASYNC / MEMORY on 05.01.2023 > -

[jira] [Commented] (FLINK-30624) Performance regression in stateBackends.FS / FS_ASYNC / MEMORY on 05.01.2023

2023-01-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682859#comment-17682859 ] Zhu Zhu commented on FLINK-30624: - The performance regression is gone. > Performance re

[jira] [Assigned] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-30846: -- Assignee: Li Pi (was: Lijie Wang) > SpeculativeSchedulerITCase.testSpeculativeExecutionOfInp

[jira] [Commented] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682858#comment-17682858 ] Lijie Wang commented on FLINK-30846: In FLINK-30683, we removed the logic of manual

[jira] [Commented] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682856#comment-17682856 ] Lijie Wang commented on FLINK-30846: If we don't set {{jobmangaer.scheduler}} manual

[GitHub] [flink] 1996fanrui commented on pull request #21547: [FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exception

2023-01-31 Thread via GitHub
1996fanrui commented on PR #21547: URL: https://github.com/apache/flink/pull/21547#issuecomment-1411461596 > Thanks for the PR! I have just noticed this issue and it is important to clean up the left-over files and maintain HDFS availability. Overall it LGTM. I left some minor comments, PTA

[jira] [Assigned] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

2023-01-31 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-30846: -- Assignee: Lijie Wang > SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource

[GitHub] [flink] fsk119 commented on a diff in pull request #21786: [FLINK-30816][sql-client] Improve the printing of the multi-line sta…

2023-01-31 Thread via GitHub
fsk119 commented on code in PR #21786: URL: https://github.com/apache/flink/pull/21786#discussion_r1092736383 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/Printer.java: ## @@ -0,0 +1,252 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [flink] fsk119 commented on a diff in pull request #21786: [FLINK-30816][sql-client] Improve the printing of the multi-line sta…

2023-01-31 Thread via GitHub
fsk119 commented on code in PR #21786: URL: https://github.com/apache/flink/pull/21786#discussion_r1092736059 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/Printer.java: ## @@ -0,0 +1,252 @@ +/* + * Licensed to the Apache Software Foundation (AS

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-01-31 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682833#comment-17682833 ] Yanfei Lei commented on FLINK-28440: [~Feifan Wang] Thanks for the investigation, I

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #484: [FLINK-30516] Introduce files table in table store

2023-01-31 Thread via GitHub
JingsongLi commented on code in PR #484: URL: https://github.com/apache/flink-table-store/pull/484#discussion_r1092727338 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsConverters.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #484: [FLINK-30516] Introduce files table in table store

2023-01-31 Thread via GitHub
JingsongLi commented on code in PR #484: URL: https://github.com/apache/flink-table-store/pull/484#discussion_r1092727188 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsConverters.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache

[GitHub] [flink] lincoln-lil commented on pull request #21799: [FLINK-30841][table-planner] Fix incorrect calc merge to avoid wrong plans

2023-01-31 Thread via GitHub
lincoln-lil commented on PR #21799: URL: https://github.com/apache/flink/pull/21799#issuecomment-1411407653 I'll rebase the lastest master after reviewing, considering there'll be some adapting work to the new rule config changes(the new immutable annotation may cause some inconvenience in

[GitHub] [flink] Zakelly commented on a diff in pull request #21547: [FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exception

2023-01-31 Thread via GitHub
Zakelly commented on code in PR #21547: URL: https://github.com/apache/flink/pull/21547#discussion_r1092716236 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateUploaderTest.java: ## @@ -67,50 +70,125 @@ public

[jira] [Commented] (FLINK-30854) Expose periodic compaction to RocksdbCompactFilterCleanupStrategy

2023-01-31 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682824#comment-17682824 ] Yun Tang commented on FLINK-30854: -- I think this is a valid ticket, already assigned to

[jira] [Assigned] (FLINK-30854) Expose periodic compaction to RocksdbCompactFilterCleanupStrategy

2023-01-31 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-30854: Assignee: Hangxiang Yu > Expose periodic compaction to RocksdbCompactFilterCleanupStrategy >

[jira] [Commented] (FLINK-30567) Wrong insert overwrite behavior when the table contains uppercase character with Hive dialect

2023-01-31 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682825#comment-17682825 ] Jing Zhang commented on FLINK-30567: [~mapohl] [~luoyuxia] It's my fault. Sorry. I'

[jira] [Assigned] (FLINK-23411) Expose Flink checkpoint details metrics

2023-01-31 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-23411: Assignee: Hangxiang Yu > Expose Flink checkpoint details metrics > --

[GitHub] [flink] NightRunner commented on a diff in pull request #21722: [FLINK-30747][docs]Translate "Window Deduplication" page of "Querys"

2023-01-31 Thread via GitHub
NightRunner commented on code in PR #21722: URL: https://github.com/apache/flink/pull/21722#discussion_r1092709088 ## docs/content.zh/docs/dev/table/sql/queries/window-deduplication.md: ## @@ -101,15 +102,16 @@ Flink SQL> SELECT * +--+---+--+---

[GitHub] [flink] Myasuka commented on pull request #21778: [FLINK-30328][tests] Fix unstable TaskManagerWideRocksDbMemorySharingITCase

2023-01-31 Thread via GitHub
Myasuka commented on PR #21778: URL: https://github.com/apache/flink/pull/21778#issuecomment-1411377032 RocksDB actually cannot limit the native memory usage perfectly, why we can make the test stable if not leveraging metrics to detect the memory usage? -- This is an automated message fr

[jira] [Commented] (FLINK-30848) Enable CatalogTableITCase#testAlterTable

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682812#comment-17682812 ] Shengkai Fang commented on FLINK-30848: --- Merged into master: 009a9e5ce7dc967cb3a1e

[jira] [Closed] (FLINK-30848) Enable CatalogTableITCase#testAlterTable

2023-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30848. - Resolution: Fixed > Enable CatalogTableITCase#testAlterTable > -

[GitHub] [flink] fsk119 merged pull request #21803: [FLINK-30848][table-planner] Enable CatalogTableITCase#testAlterTable

2023-01-31 Thread via GitHub
fsk119 merged PR #21803: URL: https://github.com/apache/flink/pull/21803 -- 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: issues-unsubscr...@flink.apache

[jira] [Updated] (FLINK-30841) Incorrect calc merge generate wrong plan

2023-01-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30841: Description: currently we have a `FlinkCalcMergeRuleTest`, take one test as example: {code:java}

[jira] [Updated] (FLINK-30841) Incorrect calc merge generate wrong plan

2023-01-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30841: Summary: Incorrect calc merge generate wrong plan (was: Incorrect calc merge in streaming) > Inc

[GitHub] [flink] wuchong commented on a diff in pull request #21322: [FLINK-30025][table] Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-01-31 Thread via GitHub
wuchong commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1092680435 ## flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/DisplayMaxColumnWidthSQLExample.java: ## @@ -0,0 +1,132 @@ +/* + * Lice

[GitHub] [flink] wuchong commented on a diff in pull request #21322: [FLINK-30025][table] Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-01-31 Thread via GitHub
wuchong commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1092678586 ## flink-table/flink-sql-client/src/test/resources/sql/select.q: ## @@ -221,3 +221,72 @@ FROM (VALUES +--+-+-+

[GitHub] [flink] LadyForest commented on a diff in pull request #21786: [FLINK-30816][sql-client] Improve the printing of the multi-line sta…

2023-01-31 Thread via GitHub
LadyForest commented on code in PR #21786: URL: https://github.com/apache/flink/pull/21786#discussion_r1091695542 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/Printer.java: ## @@ -0,0 +1,252 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

2023-01-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682804#comment-17682804 ] Jingsong Lee commented on FLINK-30419: -- Sorry for late reply. I was on vacation bef

[jira] [Assigned] (FLINK-30419) Allow tuning of transaction timeout

2023-01-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-30419: Assignee: Alex Sorokoumov > Allow tuning of transaction timeout > ---

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

2023-01-31 Thread via GitHub
liyubin117 commented on PR #21521: URL: https://github.com/apache/flink/pull/21521#issuecomment-1411324758 @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

[jira] [Commented] (FLINK-30567) Wrong insert overwrite behavior when the table contains uppercase character with Hive dialect

2023-01-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682802#comment-17682802 ] luoyuxia commented on FLINK-30567: -- [~mapohl] Thanks for reminder. I think it's created

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-31 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682801#comment-17682801 ] Yunhong Zheng commented on FLINK-30727: --- Hi, [~mapohl] , The root cause of this er

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682800#comment-17682800 ] lincoln lee commented on FLINK-30727: - The build failure has included the fix https

[jira] [Commented] (FLINK-30858) Kubernetes operator does not update reconciled generation

2023-01-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682798#comment-17682798 ] Thomas Weise commented on FLINK-30858: -- https://lists.apache.org/thread/8y1zp4ogssy

[GitHub] [flink] swuferhong commented on pull request #21810: [WIP] Do not merge, just for CI test

2023-01-31 Thread via GitHub
swuferhong commented on PR #21810: URL: https://github.com/apache/flink/pull/21810#issuecomment-1411288940 @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

[jira] [Updated] (FLINK-30806) Bump protobuf-java dependency version for aws connectors

2023-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30806: --- Labels: pull-request-available (was: ) > Bump protobuf-java dependency version for aws conn

[GitHub] [flink-connector-aws] z3d1k opened a new pull request, #51: [FLINK-30806][Protobuf] Bump protobuf-java dependency version to 3.21.7

2023-01-31 Thread via GitHub
z3d1k opened a new pull request, #51: URL: https://github.com/apache/flink-connector-aws/pull/51 ## Purpose of the change Bump protobuf-java dependency to 3.21.7 ## Brief change log - Updated version in POM - Updated NOTICE file for `flink-connector-kinesis`

[jira] [Created] (FLINK-30858) Kubernetes operator does not update reconciled generation

2023-01-31 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-30858: Summary: Kubernetes operator does not update reconciled generation Key: FLINK-30858 URL: https://issues.apache.org/jira/browse/FLINK-30858 Project: Flink Iss

[jira] [Closed] (FLINK-24456) Support bounded offset in the Kafka table connector

2023-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24456. Fix Version/s: 1.17.0 Resolution: Fixed Implemented in 9e8a99c12ce939418086fa9555c1

[GitHub] [flink] dawidwys closed pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound…

2023-01-31 Thread via GitHub
dawidwys closed pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound… URL: https://github.com/apache/flink/pull/17994 -- 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

[GitHub] [flink] dawidwys commented on pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound…

2023-01-31 Thread via GitHub
dawidwys commented on PR #17994: URL: https://github.com/apache/flink/pull/17994#issuecomment-1411180948 Closed in #21808 -- 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. T

[GitHub] [flink] dawidwys closed pull request #21808: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bounded offset in the Kafka table connector

2023-01-31 Thread via GitHub
dawidwys closed pull request #21808: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bounded offset in the Kafka table connector URL: https://github.com/apache/flink/pull/21808 -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] dawidwys commented on pull request #21808: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bounded offset in the Kafka table connector

2023-01-31 Thread via GitHub
dawidwys commented on PR #21808: URL: https://github.com/apache/flink/pull/21808#issuecomment-1411180102 Passed in my private azure: https://dev.azure.com/wysakowiczdawid/Flink/_build/results?buildId=1550&view=results -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink-kubernetes-operator] HuangZhenQiu commented on a diff in pull request #520: [FLINK-27831][example] add apache beam example for operator

2023-01-31 Thread via GitHub
HuangZhenQiu commented on code in PR #520: URL: https://github.com/apache/flink-kubernetes-operator/pull/520#discussion_r1092475561 ## examples/flink-beam-example/README.md: ## @@ -0,0 +1,67 @@ + + +# Flink Kubernetes Operator Beam application example + +## Overview + +This is

[GitHub] [flink] flinkbot commented on pull request #21813: [Documentation] Fix ALL_EXCHANGES_BLOCKING (vs ALL-EXCHANGES-BLOCKING)

2023-01-31 Thread via GitHub
flinkbot commented on PR #21813: URL: https://github.com/apache/flink/pull/21813#issuecomment-1411047806 ## CI report: * 0483ef3bf270b6f7fdcf4081d8a0d80ccd8e166a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] noahshpak opened a new pull request, #21813: [Documentation] Fix ALL_EXCHANGES_BLOCKING (vs ALL-EXCHANGES-BLOCKING)

2023-01-31 Thread via GitHub
noahshpak opened a new pull request, #21813: URL: https://github.com/apache/flink/pull/21813 Minor documentation fix: `ALL_EXCHANGES_BLOCKING` != `ALL-EXCHANGES-BLOCKING` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Updated] (FLINK-30812) YARN with S3 resource storage fails for Hadoop 3.3.2

2023-01-31 Thread Mate Czagany (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mate Czagany updated FLINK-30812: - Affects Version/s: 1.17.0 1.17 > YARN with S3 resource storage fails for

[jira] [Created] (FLINK-30857) Create table does not create topic with multiple partitions

2023-01-31 Thread Vicky Papavasileiou (Jira)
Vicky Papavasileiou created FLINK-30857: --- Summary: Create table does not create topic with multiple partitions Key: FLINK-30857 URL: https://issues.apache.org/jira/browse/FLINK-30857 Project: Fl

[jira] [Updated] (FLINK-30857) Create table does not create topic with multiple partitions

2023-01-31 Thread Vicky Papavasileiou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vicky Papavasileiou updated FLINK-30857: Component/s: Table Store > Create table does not create topic with multiple partit

[jira] [Closed] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2023-01-31 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi closed FLINK-29871. - Resolution: Fixed Fixed via aab14232721d49fe985ffaca5a8d175cd0f156df merged to main > Upgrade o

[GitHub] [flink-kubernetes-operator] morhidi merged pull request #521: [FLINK-29871] Upgraded flink dependencies to 1.16

2023-01-31 Thread via GitHub
morhidi merged PR #521: URL: https://github.com/apache/flink-kubernetes-operator/pull/521 -- 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: issues-unsubsc

[GitHub] [flink] dawidwys commented on pull request #21808: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bounded offset in the Kafka table connector

2023-01-31 Thread via GitHub
dawidwys commented on PR #21808: URL: https://github.com/apache/flink/pull/21808#issuecomment-1410942280 @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.

[jira] [Resolved] (FLINK-30718) Cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.connector.opensearch.sink.OpensearchSink.emitter

2023-01-31 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko resolved FLINK-30718. -- Resolution: Won't Fix > Cannot assign instance of java.lang.invoke.SerializedLambda to field

  1   2   3   4   >