[jira] [Created] (FLINK-28797) Hive source should also support verctor reading for complex data type when with parquet format

2022-08-03 Thread luoyuxia (Jira)
luoyuxia created FLINK-28797: Summary: Hive source should also support verctor reading for complex data type when with parquet format Key: FLINK-28797 URL: https://issues.apache.org/jira/browse/FLINK-28797

[GitHub] [flink] Myracle commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-08-03 Thread GitBox
Myracle commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r937401173 ## flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java: ## @@ -220,6 +220,7 @@ public void submit

[GitHub] [flink] Myracle commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-08-03 Thread GitBox
Myracle commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r937400491 ## flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/SessionContextTest.java: ## @@ -156,13 +156,7 @@ public void testAddJarWithRe

[GitHub] [flink] Myracle commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-08-03 Thread GitBox
Myracle commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r937399265 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -461,6 +463,23 @@ public boolean dropTemporaryFunc

[GitHub] [flink] Myracle commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-08-03 Thread GitBox
Myracle commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r937398787 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -461,6 +463,23 @@ public boolean dropTemporaryFunc

[jira] [Assigned] (FLINK-28139) Add documentation for speculative execution

2022-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28139: --- Assignee: Zhu Zhu > Add documentation for speculative execution > -

[GitHub] [flink] fredia commented on a diff in pull request #20420: [FLINK-28626][tests] Refactor RescaleCheckpointManuallyITCase

2022-08-03 Thread GitBox
fredia commented on code in PR #20420: URL: https://github.com/apache/flink/pull/20420#discussion_r937394800 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescaleCheckpointManuallyITCase.java: ## @@ -150,54 +137,33 @@ public void testCheckpointRescalingKeyedSt

[jira] [Commented] (FLINK-28529) ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode failed with CheckpointException: Checkpoint expired before comple

2022-08-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575048#comment-17575048 ] Huang Xingbo commented on FLINK-28529: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] fredia commented on a diff in pull request #20420: [FLINK-28626][tests] Refactor RescaleCheckpointManuallyITCase

2022-08-03 Thread GitBox
fredia commented on code in PR #20420: URL: https://github.com/apache/flink/pull/20420#discussion_r937393519 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescaleCheckpointManuallyITCase.java: ## @@ -150,54 +137,33 @@ public void testCheckpointRescalingKeyedSt

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937383257 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java: ## @@ -26,30 +26,49 @@ import org.apache.flink.core.me

[jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

2022-08-03 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bo zhao updated FLINK-26559: Description: This is an umbrella issue for tracking the work for supporting Volcano on FLink Kubernetes.

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937388343 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java: ## @@ -26,30 +26,49 @@ import org.apache.flink.core.me

[jira] [Updated] (FLINK-27710) Improve logs to better display Execution

2022-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27710: Fix Version/s: (was: 1.16.0) > Improve logs to better display Execution >

[GitHub] [flink] nyingping commented on pull request #20337: [FLINK-28504][streaming] Update watermarks across multiple oneinputstreams.

2022-08-03 Thread GitBox
nyingping commented on PR #20337: URL: https://github.com/apache/flink/pull/20337#issuecomment-1204806986 @pnowojski Thanks for reviewing! My understanding is that if subtasks of the same vertex can send watermarks downstream without alignment, then the problem does not exist, it is not a

[jira] [Commented] (FLINK-28767) SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedError

2022-08-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575049#comment-17575049 ] Huang Xingbo commented on FLINK-28767: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-28767) SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedError

2022-08-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28767: - Fix Version/s: 1.16.0 > SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedE

[GitHub] [flink] flinkbot commented on pull request #20448: field-level lineage infer

2022-08-03 Thread GitBox
flinkbot commented on PR #20448: URL: https://github.com/apache/flink/pull/20448#issuecomment-1204805321 ## CI report: * ec7e21b3fd37e0eb69852b2c0354edcd14116499 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937383257 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java: ## @@ -26,30 +26,49 @@ import org.apache.flink.core.me

[jira] [Commented] (FLINK-28789) TPC-DS tests failed due to release input gate for task failure

2022-08-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575042#comment-17575042 ] Huang Xingbo commented on FLINK-28789: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-28789) TPC-DS tests failed due to release input gate for task failure

2022-08-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28789: - Priority: Blocker (was: Critical) > TPC-DS tests failed due to release input gate for task fa

[GitHub] [flink] fsk119 commented on pull request #20334: [FLINK-28629][sql-gateway][hive] Allow to getCatalogs in the HiveServer2 Endpoint

2022-08-03 Thread GitBox
fsk119 commented on PR #20334: URL: https://github.com/apache/flink/pull/20334#issuecomment-1204798442 @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. T

[GitHub] [flink] Myasuka commented on a diff in pull request #20420: [FLINK-28626][tests] Refactor RescaleCheckpointManuallyITCase

2022-08-03 Thread GitBox
Myasuka commented on code in PR #20420: URL: https://github.com/apache/flink/pull/20420#discussion_r937369884 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescaleCheckpointManuallyITCase.java: ## @@ -150,54 +137,33 @@ public void testCheckpointRescalingKeyedS

[GitHub] [flink] godfreyhe commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
godfreyhe commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937368986 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

[GitHub] [flink] wangqinghuan opened a new pull request, #20448: field-level lineage

2022-08-03 Thread GitBox
wangqinghuan opened a new pull request, #20448: URL: https://github.com/apache/flink/pull/20448 This pr introduces an explainLineage function to get field-level lineage relationship about Flink SQL task. For example, ``` create table src (a String,b String, c String) with ( 'connect

[jira] [Updated] (FLINK-28796) Add Statement Completement API for sql gateway rest endpoint

2022-08-03 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-28796: Description: SQL Gateway supports various clients: sql client, rest, hiveserver2, etc. Given the

[jira] [Created] (FLINK-28796) Add Statement Completement API for sql gateway rest endpoint

2022-08-03 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28796: --- Summary: Add Statement Completement API for sql gateway rest endpoint Key: FLINK-28796 URL: https://issues.apache.org/jira/browse/FLINK-28796 Project: Flink I

[GitHub] [flink] godfreyhe commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
godfreyhe commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937365940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java: ## @@ -26,30 +26,49 @@ import org.apache.flink.core

[GitHub] [flink] Tartarus0zm commented on a diff in pull request #20392: [FLINK-28459][table-planner] Supports non-atomic CREATE TABLE AS SELECT

2022-08-03 Thread GitBox
Tartarus0zm commented on code in PR #20392: URL: https://github.com/apache/flink/pull/20392#discussion_r937356970 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TableSinkITCase.scala: ## @@ -192,4 +193,41 @@ class TableSinkITC

[GitHub] [flink] flinkbot commented on pull request #20447: Flink 28532

2022-08-03 Thread GitBox
flinkbot commented on PR #20447: URL: https://github.com/apache/flink/pull/20447#issuecomment-1204770675 ## CI report: * 76a2792d897bf3f6591ade52756bb8714259a963 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hehuiyuan closed pull request #20425: [FLINK-28750][Hive]Add field comment parse for hive ddl

2022-08-03 Thread GitBox
hehuiyuan closed pull request #20425: [FLINK-28750][Hive]Add field comment parse for hive ddl URL: https://github.com/apache/flink/pull/20425 -- 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 spec

[GitHub] [flink] hehuiyuan commented on pull request #20425: [FLINK-28750][Hive]Add field comment parse for hive ddl

2022-08-03 Thread GitBox
hehuiyuan commented on PR #20425: URL: https://github.com/apache/flink/pull/20425#issuecomment-1204763509 @luoyuxia thanks. It shoud have been supported. ![image](https://user-images.githubusercontent.com/18002496/182767010-d27407f4-199a-4ed4-a446-b47424cec49a.png) -- This is a

[GitHub] [flink] SmirAlex opened a new pull request, #20447: Flink 28532

2022-08-03 Thread GitBox
SmirAlex opened a new pull request, #20447: URL: https://github.com/apache/flink/pull/20447 ## What is the purpose of the change This pull request introduces support of lookup join using FullCachingLookupProvider that uses InputFormats for data loading. Also it contains chang

[GitHub] [flink] flinkbot commented on pull request #20446: [FLINK-28795][hive] Fix unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-03 Thread GitBox
flinkbot commented on PR #20446: URL: https://github.com/apache/flink/pull/20446#issuecomment-1204751398 ## CI report: * 791f77044d41d8e6dd0d86412dac383e42a9bb05 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] luoyuxia commented on pull request #20060: [FLINK-28212][hive] Trim the project node with window expressions to fix IndexOutOfBoundsException when using Hive dialect.

2022-08-03 Thread GitBox
luoyuxia commented on PR #20060: URL: https://github.com/apache/flink/pull/20060#issuecomment-1204743277 @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-28795) Unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28795: --- Labels: pull-request-available (was: ) > Unstable test for HiveDialectQueryITCase#testInser

[GitHub] [flink] luoyuxia opened a new pull request, #20446: [FLINK-28795][hive] Fix unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-03 Thread GitBox
luoyuxia opened a new pull request, #20446: URL: https://github.com/apache/flink/pull/20446 ## What is the purpose of the change Fix unstable test for HiveDialectQueryITCase#testInsertDirectory ## Brief change log Wait the inserting finish before querying the table.

[jira] [Created] (FLINK-28795) Unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-03 Thread luoyuxia (Jira)
luoyuxia created FLINK-28795: Summary: Unstable test for HiveDialectQueryITCase#testInsertDirectory Key: FLINK-28795 URL: https://issues.apache.org/jira/browse/FLINK-28795 Project: Flink Issue T

[GitHub] [flink] pltbkd commented on pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on PR #20374: URL: https://github.com/apache/flink/pull/20374#issuecomment-1204737427 Hi @godfreyhe , Thanks for the suggestions! I suppose I've resolved most of the comments, and the failover case is coming soon. Would you please take another look? -- This is an au

[GitHub] [flink] fsk119 commented on pull request #20334: [FLINK-28629][sql-gateway][hive] Allow to getCatalogs in the HiveServer2 Endpoint

2022-08-03 Thread GitBox
fsk119 commented on PR #20334: URL: https://github.com/apache/flink/pull/20334#issuecomment-1204735914 @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. T

[GitHub] [flink] luoyuxia commented on pull request #20394: [FLINK-28720][hive][connectors] Add Hive partition when flink has no data to write

2022-08-03 Thread GitBox
luoyuxia commented on PR #20394: URL: https://github.com/apache/flink/pull/20394#issuecomment-1204734039 LGTM. -- 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 unsubscrib

[GitHub] [flink] flinkbot commented on pull request #20445: [FLINK-27908][network] HsSubpartitionView should calculate backlog no less than true value

2022-08-03 Thread GitBox
flinkbot commented on PR #20445: URL: https://github.com/apache/flink/pull/20445#issuecomment-1204732058 ## CI report: * df3eaa0cfc0fd1b65d7ec0b380ea1bc2ab75bd37 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937324901 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java: ## @@ -0,0 +1,183 @

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937326667 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java: ## @@ -0,0 +1,183 @

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937325378 ## flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperatorTest.java: ## @@ -0,0 +1,1

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937324901 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java: ## @@ -0,0 +1,183 @

[jira] [Updated] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2022-08-03 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-28786: Description: I have tested it with 2 m1 machines. i will reproduce the bug 100%. 1.m1 machine macos bigsu

[GitHub] [flink] reswqa opened a new pull request, #20445: [FLINK-27908][network] HsSubpartitionView should calculate backlog no less than true value

2022-08-03 Thread GitBox
reswqa opened a new pull request, #20445: URL: https://github.com/apache/flink/pull/20445 ## What is the purpose of the change *HsSubpartitionView calculate backlog no less than true value* ## Brief change log - *Change logical of calculate backlog in HsSubpartition

[GitHub] [flink] swuferhong commented on a diff in pull request #20432: [FLINK-28753][table-planner] Improve FilterIntoJoinRule which could push some predicates to another side

2022-08-03 Thread GitBox
swuferhong commented on code in PR #20432: URL: https://github.com/apache/flink/pull/20432#discussion_r937319412 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/JoinITCase.scala: ## @@ -66,6 +68,29 @@ class JoinITCase(state: St

[GitHub] [flink] SmirAlex commented on pull request #20382: [FLINK-28419][table] Add runtime provider interface for full caching lookup + implement Periodic and Timed cache reload triggers

2022-08-03 Thread GitBox
SmirAlex commented on PR #20382: URL: https://github.com/apache/flink/pull/20382#issuecomment-1204717241 @PatrickRen There were multiple failed pipelines, but they were because of unrelated issues. Latest pipeline was successful - https://dev.azure.com/asmirnov1/Flink/_build/results?buildId

[GitHub] [flink] pltbkd commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
pltbkd commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937316474 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] yunfengzhou-hub commented on a diff in pull request #20275: [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

2022-08-03 Thread GitBox
yunfengzhou-hub commented on code in PR #20275: URL: https://github.com/apache/flink/pull/20275#discussion_r937314000 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.java: ## @@ -0,0 +1,54

[GitHub] [flink] godfreyhe commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
godfreyhe commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937312617 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java: ## @@ -0,0 +1,18

[jira] [Updated] (FLINK-28794) Publish flink-table-store snapshot artifacts

2022-08-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28794: --- Labels: pull-request-available (was: ) > Publish flink-table-store snapshot artifacts > ---

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #261: [FLINK-28794] Publish flink-table-store snapshot artifacts

2022-08-03 Thread GitBox
JingsongLi opened a new pull request, #261: URL: https://github.com/apache/flink-table-store/pull/261 It is better to publish the Maven artifacts, so that downstream Java projects can use this. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] lindong28 commented on a diff in pull request #20275: [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

2022-08-03 Thread GitBox
lindong28 commented on code in PR #20275: URL: https://github.com/apache/flink/pull/20275#discussion_r937256425 ## flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactlyOnceITCase.java: ## @@ -378,6 +373,10 @@ public void handleEvent

[jira] [Commented] (FLINK-28793) Allow to GetInfo for HiveServer2 Endpoint

2022-08-03 Thread WeiNan Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17574996#comment-17574996 ] WeiNan Zhao commented on FLINK-28793: - hi, [~fsk119]. please assign to me . thanks.

[GitHub] [flink] godfreyhe commented on a diff in pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
godfreyhe commented on code in PR #20374: URL: https://github.com/apache/flink/pull/20374#discussion_r937308705 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java: ## @@ -0,0 +1,18

[jira] [Created] (FLINK-28794) Publish flink-table-store snapshot artifacts

2022-08-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28794: Summary: Publish flink-table-store snapshot artifacts Key: FLINK-28794 URL: https://issues.apache.org/jira/browse/FLINK-28794 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

2022-08-03 Thread Stephan Weinwurm (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575006#comment-17575006 ] Stephan Weinwurm commented on FLINK-28747: -- Yes, you're right, that seems like

[GitHub] [flink] gaoyunhaii commented on pull request #20374: [FLINK-28709] Implement dynamic filtering operators

2022-08-03 Thread GitBox
gaoyunhaii commented on PR #20374: URL: https://github.com/apache/flink/pull/20374#issuecomment-1204703556 @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-28769) Flink History Server show wrong name of batch jobs

2022-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575001#comment-17575001 ] Zhu Zhu commented on FLINK-28769: - Loos to me the the specified name does work after che

[GitHub] [flink] flinkbot commented on pull request #20444: [FLINK-28793] Allow to GetInfo for HiveServer2 Endpoint

2022-08-03 Thread GitBox
flinkbot commented on PR #20444: URL: https://github.com/apache/flink/pull/20444#issuecomment-1204701319 ## CI report: * cc26779be4d6fcd2e160327da83345c72a3c63d0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28493) Add document to describe "ANALYZE TABLE" syntax

2022-08-03 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575004#comment-17575004 ] Yunhong Zheng commented on FLINK-28493: --- Hi [~godfreyhe] , could you assign this t

[jira] [Updated] (FLINK-28793) Allow to GetInfo for HiveServer2 Endpoint

2022-08-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28793: --- Labels: pull-request-available (was: ) > Allow to GetInfo for HiveServer2 Endpoint > --

[GitHub] [flink] chaozwn opened a new pull request, #20444: [FLINK-28793] Allow to GetInfo for HiveServer2 Endpoint

2022-08-03 Thread GitBox
chaozwn opened a new pull request, #20444: URL: https://github.com/apache/flink/pull/20444 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Closed] (FLINK-28708) Introduce planner rules to optimize dpp pattern

2022-08-03 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28708. -- Resolution: Fixed Fixed in master: ae186e8650f137d624812c79f1bc33325e72 > Introduce planner rules

[GitHub] [flink] godfreyhe closed pull request #20388: [FLINK-28708][table-planner] Introduce planner rules to optimize dpp pattern

2022-08-03 Thread GitBox
godfreyhe closed pull request #20388: [FLINK-28708][table-planner] Introduce planner rules to optimize dpp pattern URL: https://github.com/apache/flink/pull/20388 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] godfreyhe commented on pull request #20388: [FLINK-28708][table-planner] Introduce planner rules to optimize dpp pattern

2022-08-03 Thread GitBox
godfreyhe commented on PR #20388: URL: https://github.com/apache/flink/pull/20388#issuecomment-1204693707 merged -- 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 unsubscr

[GitHub] [flink] xintongsong commented on a diff in pull request #20426: [FLINK-28781][network] Hybrid Shuffle should support compression

2022-08-03 Thread GitBox
xintongsong commented on code in PR #20426: URL: https://github.com/apache/flink/pull/20426#discussion_r937295256 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionType.java: ## @@ -196,4 +196,8 @@ public boolean isBounded() { publi

[GitHub] [flink] luoyuxia commented on pull request #20425: [FLINK-28750][Hive]Add field comment parse for hive ddl

2022-08-03 Thread GitBox
luoyuxia commented on PR #20425: URL: https://github.com/apache/flink/pull/20425#issuecomment-1204689351 I haven't checked. But I go through the source code, and I think It should have been supported. -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Created] (FLINK-28793) Allow to GetInfo for HiveServer2 Endpoint

2022-08-03 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28793: - Summary: Allow to GetInfo for HiveServer2 Endpoint Key: FLINK-28793 URL: https://issues.apache.org/jira/browse/FLINK-28793 Project: Flink Issue Type: Sub-t

[jira] [Closed] (FLINK-28492) Support "ANALYZE TABLE" execution

2022-08-03 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28492. -- Resolution: Fixed Fixed in master: 8236644816a8070499ff4327b7ee71cbb4660afa > Support "ANALYZE TABLE"

[GitHub] [flink] godfreyhe closed pull request #20363: [FLINK-28492][table-planner] Support "ANALYZE TABLE" execution

2022-08-03 Thread GitBox
godfreyhe closed pull request #20363: [FLINK-28492][table-planner] Support "ANALYZE TABLE" execution URL: https://github.com/apache/flink/pull/20363 -- 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 t

[GitHub] [flink] JasonLeeCoding commented on pull request #20327: [FLINK-28595][Connectors/kafka] KafkaSource should not read metadata of unmatched regex topics

2022-08-03 Thread GitBox
JasonLeeCoding commented on PR #20327: URL: https://github.com/apache/flink/pull/20327#issuecomment-1204686180 @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 co

[GitHub] [flink] swuferhong commented on a diff in pull request #20303: [FLINK-28599][table-planner] Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join

2022-08-03 Thread GitBox
swuferhong commented on code in PR #20303: URL: https://github.com/apache/flink/pull/20303#discussion_r937292379 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/MultiJoinOptimizeTest.scala: ## @@ -0,0 +1,170 @@ +/* + * Licensed

[GitHub] [flink] reswqa commented on pull request #20433: [FLINK-27909] Add document for hybrid shuffle

2022-08-03 Thread GitBox
reswqa commented on PR #20433: URL: https://github.com/apache/flink/pull/20433#issuecomment-1204683732 @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. T

[GitHub] [flink] luoyuxia commented on a diff in pull request #20394: [FLINK-28720][hive][connectors] Add Hive partition when flink has no data to write

2022-08-03 Thread GitBox
luoyuxia commented on code in PR #20394: URL: https://github.com/apache/flink/pull/20394#discussion_r937290113 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java: ## @@ -441,6 +441,61 @@ public void testCustomPartitio

[jira] [Closed] (FLINK-28161) Introduce the session related API for REST endpoint

2022-08-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28161. Fix Version/s: 1.16.0 Resolution: Done master (1.16): 687e061fd5d8cce6bf7258c2d18421bb0

[GitHub] [flink] xintongsong closed pull request #20418: [FLINK-28161][sql-gateway]Introduce the session related API for REST endpoint

2022-08-03 Thread GitBox
xintongsong closed pull request #20418: [FLINK-28161][sql-gateway]Introduce the session related API for REST endpoint URL: https://github.com/apache/flink/pull/20418 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] deadwind4 commented on pull request #18469: [FLINK-25485][connector/jdbc] Append default JDBC URL option of batch writing in MySQL.

2022-08-03 Thread GitBox
deadwind4 commented on PR #18469: URL: https://github.com/apache/flink/pull/18469#issuecomment-1204663752 @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] lsyldliu commented on a diff in pull request #20392: [FLINK-28459][table-planner] Supports non-atomic CREATE TABLE AS SELECT

2022-08-03 Thread GitBox
lsyldliu commented on code in PR #20392: URL: https://github.com/apache/flink/pull/20392#discussion_r937274957 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TableSinkITCase.scala: ## @@ -192,4 +193,41 @@ class TableSinkITCase

[GitHub] [flink] lsyldliu commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-08-03 Thread GitBox
lsyldliu commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r937269900 ## flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/AddRemoteJarITCase.java: ## @@ -0,0 +1,280 @@ +/* + * Licensed to

[GitHub] [flink] lsyldliu commented on pull request #20442: [FLINK-24614][Connectors/PARQUET] Add Complex types support for parquet reader

2022-08-03 Thread GitBox
lsyldliu commented on PR #20442: URL: https://github.com/apache/flink/pull/20442#issuecomment-1204653044 @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-28571) Add AlgoOperator for Chi-squared test

2022-08-03 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-28571. --- Resolution: Fixed fixed via df58dbee68131c967ce927825cd710280cfda1ce > Add AlgoOperator for

[GitHub] [flink-ml] zhipeng93 merged pull request #132: [FLINK-28571] Add AlgoOperator for Chi-squared test

2022-08-03 Thread GitBox
zhipeng93 merged PR #132: URL: https://github.com/apache/flink-ml/pull/132 -- 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.apac

[GitHub] [flink-ml] zhipeng93 commented on pull request #132: [FLINK-28571] Add AlgoOperator for Chi-squared test

2022-08-03 Thread GitBox
zhipeng93 commented on PR #132: URL: https://github.com/apache/flink-ml/pull/132#issuecomment-1204646476 Thanks for the update @taosiyuan163 . LGTM :) -- 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

[GitHub] [flink] luoyuxia commented on pull request #20060: [FLINK-28212][hive] Trim the project node with window expressions to fix IndexOutOfBoundsException when using Hive dialect.

2022-08-03 Thread GitBox
luoyuxia commented on PR #20060: URL: https://github.com/apache/flink/pull/20060#issuecomment-1204640387 @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] rkhachatryan commented on pull request #20404: [FLINK-28529][changelog] refactor ChangelogPeriodicMaterializationSwitchStateBackendITCase#testSwitchFromDisablingToEnablingInClaimMode

2022-08-03 Thread GitBox
rkhachatryan commented on PR #20404: URL: https://github.com/apache/flink/pull/20404#issuecomment-1204559117 Thanks a lot for the fix @fredia Could you please briefly describe the root cause of the failure in the ticket? Besides of changing the source, this PR refactors the te

[jira] [Updated] (FLINK-24457) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails with NoSuchElement

2022-08-03 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24457: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-22741) Hide Flink complexity from Stateful Functions

2022-08-03 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22741: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-27775) FlinkKafkaProducer VS KafkaSink

2022-08-03 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27775: --- Labels: auto-deprioritized-major features (was: features stale-major) Priority: Minor

[jira] [Updated] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

2022-08-03 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26465: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-24731) Add a blank space for TransitiveClosureNaive

2022-08-03 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24731: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritize

[jira] [Updated] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

2022-08-03 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24482: --- Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor test-stability (wa

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

2022-08-03 Thread GitBox
rkhachatryan commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r937093155 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java: ## @@ -517,7 +527,16 @@ public void failJobDueToTaskFailure(

[jira] [Updated] (FLINK-28341) Fix comment in BytesKeyNormalizationUtil.java

2022-08-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28341: --- Labels: comment pull-request-available starter (was: comment starter) > Fix comment in Byte

[GitHub] [flink] flinkbot commented on pull request #20443: [hotfix] [FLINK-28341] [streaming-java] Change the MIN and MAX value for Byte data type

2022-08-03 Thread GitBox
flinkbot commented on PR #20443: URL: https://github.com/apache/flink/pull/20443#issuecomment-1204429889 ## CI report: * 7dd394348b817468a5f58bdde3c8b93b4c628022 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] ravening opened a new pull request, #20443: [hotfix] [FLINK-28341] [streaming-java] Change the MIN and MAX value for Byte data type

2022-08-03 Thread GitBox
ravening opened a new pull request, #20443: URL: https://github.com/apache/flink/pull/20443 The MIN value should be -128 and max value is 127 ## What is the purpose of the change Change the Byte min and max values in the description ## Verifying this chang

[GitHub] [flink] rkhachatryan commented on pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

2022-08-03 Thread GitBox
rkhachatryan commented on PR #20103: URL: https://github.com/apache/flink/pull/20103#issuecomment-1204372419 Sorry for the delay @zoltar9264 . I still don't see the changes when running locally (commit SHA shown in the UI: 7259856). In the logs, I see messages like this: ```

[GitHub] [flink] snuyanzin commented on pull request #19916: [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5

2022-08-03 Thread GitBox
snuyanzin commented on PR #19916: URL: https://github.com/apache/flink/pull/19916#issuecomment-1204345414 @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 speci

  1   2   3   >