[GitHub] [flink] swuferhong commented on a diff in pull request #20462: [FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp

swuferhong commented on code in PR #20462: URL: https://github.com/apache/flink/pull/20462#discussion_r939615682 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -0,0 +1,342 @@ +/* + * Licensed to the

[GitHub] [flink] swuferhong commented on a diff in pull request #20462: [FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp

swuferhong commented on code in PR #20462: URL: https://github.com/apache/flink/pull/20462#discussion_r939614785 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -0,0 +1,342 @@ +/* + * Licensed to the

[GitHub] [flink] swuferhong commented on a diff in pull request #20462: [FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp

swuferhong commented on code in PR #20462: URL: https://github.com/apache/flink/pull/20462#discussion_r939614545 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdRowCount.scala: ## @@ -335,10 +336,19 @@ class FlinkRelMdRowC

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

gaoyunhaii commented on code in PR #20472: URL: https://github.com/apache/flink/pull/20472#discussion_r939606554 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecDynamicFilteringDataCollector.java: ## @@ -0,0 +1,105 @

[GitHub] [flink] godfreyhe commented on a diff in pull request #20359: [FLINK-28682][table-planner] support join hint in batch rules

godfreyhe commented on code in PR #20359: URL: https://github.com/apache/flink/pull/20359#discussion_r939603077 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala: ## @@ -437,7 +442,21 @@ abstract class TableTestUtilBase(te

[jira] [Updated] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module

[ https://issues.apache.org/jira/browse/FLINK-28847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Wen updated FLINK-28847: Description: There is a redundant semicolon in [FileSinkProgram.java|https://github.com/apache/flink/blob

[jira] [Created] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module

Xin Wen created FLINK-28847: --- Summary: Typo in FileSinkProgram.java in file-sink-file-test module Key: FLINK-28847 URL: https://issues.apache.org/jira/browse/FLINK-28847 Project: Flink Issue Type:

[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

swuferhong commented on code in PR #20303: URL: https://github.com/apache/flink/pull/20303#discussion_r939601228 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRuleTest.scala: ## @@ -50,19 +50,214 @@ class

[GitHub] [flink] xuyangzhong commented on pull request #20359: [FLINK-28682][table-planner] support join hint in batch rules

xuyangzhong commented on PR #20359: URL: https://github.com/apache/flink/pull/20359#issuecomment-1207322711 @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 commen

[GitHub] [flink] godfreyhe commented on a diff in pull request #20324: [FLINK-28568][table-runtime] Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism

godfreyhe commented on code in PR #20324: URL: https://github.com/apache/flink/pull/20324#discussion_r939599197 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java: ## @@ -329,8 +340,59 @@ private Trans

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

lsyldliu commented on PR #20442: URL: https://github.com/apache/flink/pull/20442#issuecomment-1207321130 @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] [Closed] (FLINK-28709) Implement dynamic filtering operators

[ https://issues.apache.org/jira/browse/FLINK-28709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28709. -- Resolution: Fixed Fixed in master: 9bda67795628576aa4f161df6cb976ba71c3936d 3a8e71e286d1d097fe6cfc8b7f

[jira] [Assigned] (FLINK-28709) Implement dynamic filtering operators

[ https://issues.apache.org/jira/browse/FLINK-28709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-28709: -- Assignee: Gen Luo > Implement dynamic filtering operators > -

[GitHub] [flink] godfreyhe closed pull request #20374: [FLINK-28709] Implement dynamic filtering operators

godfreyhe closed pull request #20374: [FLINK-28709] Implement dynamic filtering operators URL: https://github.com/apache/flink/pull/20374 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-28773) Allow to write a success file after finish writing for Hive sink in batch mode

[ https://issues.apache.org/jira/browse/FLINK-28773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28773: --- Labels: pull-request-available (was: ) > Allow to write a success file after finish writing

[GitHub] [flink] luoyuxia commented on a diff in pull request #20469: [FLINK-28773][hive]Allow to write a success file after finish for Hive sink in batch mode

luoyuxia commented on code in PR #20469: URL: https://github.com/apache/flink/pull/20469#discussion_r939595765 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/PartitionLoader.java: ## @@ -52,17 +52,27 @@ public class PartitionLoader

[GitHub] [flink] godfreyhe commented on pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

godfreyhe commented on PR #20472: URL: https://github.com/apache/flink/pull/20472#issuecomment-1207317462 Thanks for the review @gaoyunhaii , I have updated the pr -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [flink] godfreyhe commented on a diff in pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

godfreyhe commented on code in PR #20472: URL: https://github.com/apache/flink/pull/20472#discussion_r939596677 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java: ## @@ -960,11 +997,12 @@ protected Collection c

[GitHub] [flink] godfreyhe commented on a diff in pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

godfreyhe commented on code in PR #20472: URL: https://github.com/apache/flink/pull/20472#discussion_r939596332 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/enumerator/DynamicFilteringValuesSourceEnumerator.java: ## @@ -0,0 +1,149 @@ +/* + *

[jira] [Closed] (FLINK-28816) Include some metrics for the pod created in operator

[ https://issues.apache.org/jira/browse/FLINK-28816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-28816. -- Resolution: Won't Fix > Include some metrics for the pod created in operator > ---

[jira] [Commented] (FLINK-28816) Include some metrics for the pod created in operator

[ https://issues.apache.org/jira/browse/FLINK-28816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576306#comment-17576306 ] Aitozi commented on FLINK-28816: [~wangyang0918] Thanks for your valuable insight, will

[GitHub] [flink] godfreyhe commented on a diff in pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

godfreyhe commented on code in PR #20472: URL: https://github.com/apache/flink/pull/20472#discussion_r939595953 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/ValuesSourceReader.java: ## @@ -0,0 +1,148 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576303#comment-17576303 ] Aitozi commented on FLINK-26721: https://dev.azure.com/apache-flink/apache-flink/_build/

[GitHub] [flink] lindong28 commented on a diff in pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

lindong28 commented on code in PR #20454: URL: https://github.com/apache/flink/pull/20454#discussion_r93947 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java: ## @@ -135,6 +147,8 @@ private GlobalFailureHandler

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

gaoyunhaii commented on code in PR #20472: URL: https://github.com/apache/flink/pull/20472#discussion_r939545370 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecTableSourceScan.java: ## @@ -64,7 +103,48 @@ protected

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

gaoyunhaii commented on PR #20374: URL: https://github.com/apache/flink/pull/20374#issuecomment-1207299221 @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-25756) Dedicated Opensearch connectors

[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25756: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-27928) External Resource Framework: 'external-resources' name delimitation not working as expected

[ https://issues.apache.org/jira/browse/FLINK-27928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27928: --- Labels: external-resources stale-major (was: external-resources) I am the [Flink Jira Bot|h

[jira] [Closed] (FLINK-28807) Various components don't respect schema lifecycle

[ https://issues.apache.org/jira/browse/FLINK-28807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28807. Resolution: Fixed master: fb95798b1c301152b912c4b8ec4a737ea16d8641 > Various components d

[GitHub] [flink] zentol merged pull request #20473: [FLINK-28807] Honor schema lifecycle

zentol merged PR #20473: URL: https://github.com/apache/flink/pull/20473 -- 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] [Created] (FLINK-28846) Trigger event on validation error

Gyula Fora created FLINK-28846: -- Summary: Trigger event on validation error Key: FLINK-28846 URL: https://issues.apache.org/jira/browse/FLINK-28846 Project: Flink Issue Type: Improvement

[GitHub] [flink] sap1ens commented on pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

sap1ens commented on PR #20475: URL: https://github.com/apache/flink/pull/20475#issuecomment-1207261388 @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] gaoyunhaii commented on pull request #20374: [FLINK-28709] Implement dynamic filtering operators

gaoyunhaii commented on PR #20374: URL: https://github.com/apache/flink/pull/20374#issuecomment-1207254955 @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] [Assigned] (FLINK-28333) GlueSchemaRegistryAvroKinesisITCase is being Ignored due to `Access key not configured`

[ https://issues.apache.org/jira/browse/FLINK-28333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-28333: - Assignee: Danny Cranmer > GlueSchemaRegistryAvroKinesisITCase is being Ignored due to `

[jira] [Closed] (FLINK-28834) Add TemporalJoin example and ITCase

[ https://issues.apache.org/jira/browse/FLINK-28834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28834. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 62786320eb555e36fe9fb82168fe97855dc54056 >

[jira] [Updated] (FLINK-28834) Add TemporalJoin example and ITCase

[ https://issues.apache.org/jira/browse/FLINK-28834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28834: Component/s: Examples > Add TemporalJoin example and ITCase > --- > >

[jira] [Updated] (FLINK-28834) Add TemporalJoin example and ITCase

[ https://issues.apache.org/jira/browse/FLINK-28834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28834: Component/s: Table SQL / API > Add TemporalJoin example and ITCase > --- >

[GitHub] [flink] wuchong merged pull request #20464: [FLINK-28834][examples-table] Add temporal join example and IT test

wuchong merged PR #20464: URL: https://github.com/apache/flink/pull/20464 -- 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.apach

[GitHub] [flink] wuchong commented on pull request #20464: [FLINK-28834][examples-table] Add temporal join example and IT test

wuchong commented on PR #20464: URL: https://github.com/apache/flink/pull/20464#issuecomment-1207240151 CI is passed. 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 the specific comme

[jira] [Commented] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576255#comment-17576255 ] lincoln lee commented on FLINK-28844: - https://dev.azure.com/apache-flink/apache-fli

[GitHub] [flink] JasonLeeCoding commented on pull request #20466: [FLINK-28837][chinese-translation] Translate "Hybrid Source" page of …

JasonLeeCoding commented on PR #20466: URL: https://github.com/apache/flink/pull/20466#issuecomment-1207237054 @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 com

[jira] [Closed] (FLINK-28772) Hive dialect supports add jar

[ https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28772. --- Resolution: Fixed Fixed in master: 6d06cdaa1633035c127483af1dc4b45e57cbc035 and 1a094eb3619e9696759eaf1a5a0

[GitHub] [flink] wuchong merged pull request #20413: [FLINK-28772][hive] Hive dialect supports "ADD JAR"

wuchong merged PR #20413: URL: https://github.com/apache/flink/pull/20413 -- 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.apach

[GitHub] [flink] wuchong commented on pull request #20413: [FLINK-28772][hive] Hive dialect supports "ADD JAR"

wuchong commented on PR #20413: URL: https://github.com/apache/flink/pull/20413#issuecomment-1207235115 The failed case is cased by FLINK-28789 and FLINK-28844. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

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

[ https://issues.apache.org/jira/browse/FLINK-28789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576251#comment-17576251 ] Jark Wu commented on FLINK-28789: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot commented on pull request #20479: [FLINK-28631][sql-gateway][hive] Support to GetFunctions in the HiveServer2Endpoint

flinkbot commented on PR #20479: URL: https://github.com/apache/flink/pull/20479#issuecomment-1207229669 ## CI report: * bb28a6b95f769c44eacd1e1fafd9f3b6213bb610 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28631) Allow to GetFunctions in the HiveServer2 Endpoint

[ https://issues.apache.org/jira/browse/FLINK-28631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28631: --- Labels: pull-request-available (was: ) > Allow to GetFunctions in the HiveServer2 Endpoint

[GitHub] [flink] fsk119 opened a new pull request, #20479: [FLINK-28631][sql-gateway][hive] Support to GetFunctions in the HiveServer2Endpoint

fsk119 opened a new pull request, #20479: URL: https://github.com/apache/flink/pull/20479 ## What is the purpose of the change *Implement the `GetFunctions` in the `HiveServer2Endpoint`.* ## Brief change log - *Allow to `getUserDefinedFunctions/getSystemFunc

[jira] [Closed] (FLINK-27524) Introduce cache API to DataStream

[ https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27524. --- Fix Version/s: 1.16.0 Resolution: Resolved > Introduce cache API to DataStream >

[jira] [Commented] (FLINK-27524) Introduce cache API to DataStream

[ https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576243#comment-17576243 ] Yun Gao commented on FLINK-27524: - Merged on master via cf1a29d47a5bb4fb92e98a36934e525d

[GitHub] [flink] gaoyunhaii closed pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream

gaoyunhaii closed pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream URL: https://github.com/apache/flink/pull/20147 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] godfreyhe commented on a diff in pull request #20462: [FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp

godfreyhe commented on code in PR #20462: URL: https://github.com/apache/flink/pull/20462#discussion_r939532490 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -0,0 +1,342 @@ +/* + * Licensed to the A

[GitHub] [flink] wuchong 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

wuchong commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r939529472 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/command/AddJarOperation.java: ## @@ -19,22 +19,23 @@ package org.apache.flink.table.

[GitHub] [flink] TanYuxin-tyx commented on pull request #20457: [FLINK-28373][network] Read a full buffer of data per file IO read request for sort-shuffle

TanYuxin-tyx commented on PR #20457: URL: https://github.com/apache/flink/pull/20457#issuecomment-1207220058 @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 comme

[jira] [Commented] (FLINK-28845) InitialSavepointPath might be ignored if first deployment fails

[ https://issues.apache.org/jira/browse/FLINK-28845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576225#comment-17576225 ] Gyula Fora commented on FLINK-28845: cc [~jeesmon]  > InitialSavepointPath might be

[jira] [Created] (FLINK-28845) InitialSavepointPath might be ignored if first deployment fails

Gyula Fora created FLINK-28845: -- Summary: InitialSavepointPath might be ignored if first deployment fails Key: FLINK-28845 URL: https://issues.apache.org/jira/browse/FLINK-28845 Project: Flink

[GitHub] [flink] godfreyhe commented on pull request #20472: [FLINK-28710][table-planner] Supports dynamic filtering execution

godfreyhe commented on PR #20472: URL: https://github.com/apache/flink/pull/20472#issuecomment-1207217111 @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] godfreyhe commented on a diff in pull request #20303: [FLINK-28599][table-planner] Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join

godfreyhe commented on code in PR #20303: URL: https://github.com/apache/flink/pull/20303#discussion_r939529014 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRuleTest.scala: ## @@ -50,19 +50,214 @@ class F

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

godfreyhe commented on code in PR #20303: URL: https://github.com/apache/flink/pull/20303#discussion_r939529014 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRuleTest.scala: ## @@ -50,19 +50,214 @@ class F

[GitHub] [flink] lincoln-lil commented on pull request #20324: [FLINK-28568][table-runtime] Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism

lincoln-lil commented on PR #20324: URL: https://github.com/apache/flink/pull/20324#issuecomment-1207212735 rebased latest master branch -- 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 specif

[jira] [Comment Edited] (FLINK-28570) Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result

[ https://issues.apache.org/jira/browse/FLINK-28570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576212#comment-17576212 ] godfrey he edited comment on FLINK-28570 at 8/6/22 1:03 PM:

[jira] [Closed] (FLINK-28570) Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or erro

[ https://issues.apache.org/jira/browse/FLINK-28570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28570. -- Resolution: Fixed Fixed in master: fd6c1cc96ce91bdeb0957b5dc26a663d0ba5b1d5: Introduces a StreamNonD

[jira] [Assigned] (FLINK-28570) Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or er

[ https://issues.apache.org/jira/browse/FLINK-28570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-28570: -- Assignee: lincoln lee > Introduces a StreamNonDeterministicPlanResolver to validate and try t

[GitHub] [flink] godfreyhe closed pull request #20393: [FLINK-28570][table-planner] Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-determinist

godfreyhe closed pull request #20393: [FLINK-28570][table-planner] Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or error URL: https://github.com/apache/flink/pull/20393 --

[jira] [Commented] (FLINK-28765) Create a doc for protobuf format

[ https://issues.apache.org/jira/browse/FLINK-28765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576210#comment-17576210 ] Suhan Mao commented on FLINK-28765: --- [~hui.yang] It probably can work, you could try.

[jira] [Assigned] (FLINK-27617) Add more analysis functions for Flink batch

[ https://issues.apache.org/jira/browse/FLINK-27617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27617: --- Assignee: luoyuxia > Add more analysis functions for Flink batch > ---

[jira] [Closed] (FLINK-27619) Support NTILE

[ https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27619. --- Resolution: Fixed Fixed in master: 3e1018e0cbc6d28d59f2d0658c6a94b044484f67 and 8ac7e9724a60d9f90ede81b8e1b

[jira] [Closed] (FLINK-27617) Add more analysis functions for Flink batch

[ https://issues.apache.org/jira/browse/FLINK-27617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27617. --- Resolution: Fixed > Add more analysis functions for Flink batch > -

[GitHub] [flink] wuchong merged pull request #20348: [FLINK-27619][sql] Flink SQL supports NTILE Function

wuchong merged PR #20348: URL: https://github.com/apache/flink/pull/20348 -- 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.apach

[GitHub] [flink] wuchong commented on pull request #20348: [FLINK-27619][sql] Flink SQL supports NTILE Function

wuchong commented on PR #20348: URL: https://github.com/apache/flink/pull/20348#issuecomment-1207208621 The failed case is caused by FLINK-28844. Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] godfreyhe commented on pull request #20062: [FLINK-28234][hive] fix Infinite or NaN exception in ExpressionReducer

godfreyhe commented on PR #20062: URL: https://github.com/apache/flink/pull/20062#issuecomment-1207208600 @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-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28844: Description: This is keep failing on master since the commit of https://github.com/flink-ci/flink-mirror/

[jira] [Commented] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576201#comment-17576201 ] Jark Wu commented on FLINK-28844: - [~chesnay], could you help to take a look? > YARNHig

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

godfreyhe commented on PR #20432: URL: https://github.com/apache/flink/pull/20432#issuecomment-1207208529 @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] [Created] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

Jark Wu created FLINK-28844: --- Summary: YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator Key: FLINK-28844 URL: https://issues.apache.org/jira/browse/FLINK-28844 Project: Flink

[GitHub] [flink] wuchong commented on a diff in pull request #20413: [FLINK-28772][hive] Hive dialect supports "ADD JAR"

wuchong commented on code in PR #20413: URL: https://github.com/apache/flink/pull/20413#discussion_r939524080 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java: ## @@ -1121,6 +1122,35 @@ public void testSetCommand() th

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

lsyldliu commented on PR #20442: URL: https://github.com/apache/flink/pull/20442#issuecomment-1207206536 @luoyuxia Thanks for review, I've addressed comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink] TanYuxin-tyx commented on pull request #20457: [FLINK-28373][network] Read a full buffer of data per file IO read request for sort-shuffle

TanYuxin-tyx commented on PR #20457: URL: https://github.com/apache/flink/pull/20457#issuecomment-1207206614 @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 comme

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

luoyuxia commented on code in PR #20442: URL: https://github.com/apache/flink/pull/20442#discussion_r939503994 ## flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ArrayColumnReader.java: ## @@ -0,0 +1,464 @@ +/* + * Licensed to the Apache

[GitHub] [flink] pltbkd commented on a diff in pull request #20415: [FLINK-28711] Hive connector implements SupportsDynamicFiltering interface

pltbkd commented on code in PR #20415: URL: https://github.com/apache/flink/pull/20415#discussion_r939520463 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java: ## @@ -247,6 +254,30 @@ public void applyPartitions(List> r

[GitHub] [flink] pltbkd commented on a diff in pull request #20415: [FLINK-28711] Hive connector implements SupportsDynamicFiltering interface

pltbkd commented on code in PR #20415: URL: https://github.com/apache/flink/pull/20415#discussion_r939520164 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java: ## @@ -247,6 +254,30 @@ public void applyPartitions(List> r

[GitHub] [flink-table-store] SteNicholas closed pull request #263: [FLINK-28840] Introduce roadmap document of Flink Table Store

SteNicholas closed pull request #263: [FLINK-28840] Introduce roadmap document of Flink Table Store URL: https://github.com/apache/flink-table-store/pull/263 -- 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 t

[GitHub] [flink] Myasuka commented on pull request #20421: [FLINK-28732][state] Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API

Myasuka commented on PR #20421: URL: https://github.com/apache/flink/pull/20421#issuecomment-1207198853 @pnowojski , @rkhachatryan could you please take a look at this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] pltbkd commented on a diff in pull request #20415: [FLINK-28711] Hive connector implements SupportsDynamicFiltering interface

pltbkd commented on code in PR #20415: URL: https://github.com/apache/flink/pull/20415#discussion_r939518523 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumerator.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

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

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

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

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

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

lsyldliu commented on code in PR #20442: URL: https://github.com/apache/flink/pull/20442#discussion_r939516574 ## flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ArrayColumnReader.java: ## @@ -0,0 +1,464 @@ +/* + * Licensed to the Apache

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

lsyldliu commented on code in PR #20442: URL: https://github.com/apache/flink/pull/20442#discussion_r939516574 ## flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ArrayColumnReader.java: ## @@ -0,0 +1,464 @@ +/* + * Licensed to the Apache

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

lsyldliu commented on code in PR #20442: URL: https://github.com/apache/flink/pull/20442#discussion_r939516535 ## flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ParquetDataColumnReaderFactory.java: ## @@ -0,0 +1,281 @@ +/* + * Licensed t

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

lsyldliu commented on code in PR #20442: URL: https://github.com/apache/flink/pull/20442#discussion_r939516203 ## flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetColumnarRowInputFormatTest.java: ## @@ -85,45 +91,43 @@ public class ParquetColumna

[jira] [Updated] (FLINK-28632) Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the HiveServer2 Endpoint

[ https://issues.apache.org/jira/browse/FLINK-28632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28632: --- Labels: pull-request-available (was: ) > Allow to GetColumns/GetTableTypes/GetPrimaryKeys i

[GitHub] [flink] flinkbot commented on pull request #20478: [FLINK-28632][sql-gateway][hive] Allow to GetColumns in the HiveServer2 Endpoint.

flinkbot commented on PR #20478: URL: https://github.com/apache/flink/pull/20478#issuecomment-1207192235 ## CI report: * 32a29095417941da444e8bfba7fe2914fa78e12f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wuchong commented on pull request #20348: [FLINK-27619][sql] Flink SQL supports NTILE Function

wuchong commented on PR #20348: URL: https://github.com/apache/flink/pull/20348#issuecomment-1207189864 @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] yuzelin opened a new pull request, #20478: Get columns

yuzelin opened a new pull request, #20478: URL: https://github.com/apache/flink/pull/20478 ## What is the purpose of the change Implement getSchemas in the HiveServer2 Endpoint. ## Brief change log - Implement getTable in the SqlGatewayService. - Implement

[GitHub] [flink] 1996fanrui commented on pull request #20137: Just for CI

1996fanrui commented on PR #20137: URL: https://github.com/apache/flink/pull/20137#issuecomment-1207188696 @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] godfreyhe commented on a diff in pull request #20432: [FLINK-28753][table-planner] Improve FilterIntoJoinRule which could push some predicates to another side

godfreyhe commented on code in PR #20432: URL: https://github.com/apache/flink/pull/20432#discussion_r939509904 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java: ## @@ -0,0 +1,510 @@ +/* + * Licensed to t

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

godfreyhe commented on code in PR #20432: URL: https://github.com/apache/flink/pull/20432#discussion_r939509875 ## 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: Sta

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

godfreyhe commented on code in PR #20432: URL: https://github.com/apache/flink/pull/20432#discussion_r939509694 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java: ## @@ -0,0 +1,510 @@ +/* + * Licensed to t

[GitHub] [flink] wsry commented on pull request #20350: [FLINK-28663][runtime] Allow multiple downstream consumer job vertices sharing the same intermediate dataset at scheduler side

wsry commented on PR #20350: URL: https://github.com/apache/flink/pull/20350#issuecomment-1207183205 @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. To

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

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

  1   2   >