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
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
[
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
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:
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
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
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
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.
[
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
[
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
>
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
[
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
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
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
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
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 @@
+/*
+
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-28816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576306#comment-17576306
]
Aitozi commented on FLINK-28816:
[~wangyang0918] Thanks for your valuable insight, will check the
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
[
https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576303#comment-17576303
]
Aitozi commented on FLINK-26721:
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
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
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
[
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
[
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
[
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
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:
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
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.
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
[
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
[
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
[
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
> ---
>
>
[
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
> ---
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:
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
[
https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576255#comment-17576255
]
lincoln lee commented on FLINK-28844:
-
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
[
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-28789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576251#comment-17576251
]
Jark Wu commented on FLINK-28789:
-
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`
[
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
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576243#comment-17576243
]
Yun Gao commented on FLINK-27524:
-
Merged on master via cf1a29d47a5bb4fb92e98a36934e525d74bae17b
>
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-28845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576225#comment-17576225
]
Gyula Fora commented on FLINK-28845:
cc [~jeesmon]
> InitialSavepointPath might be ignored if
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
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-28570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576212#comment-17576212
]
godfrey he edited comment on FLINK-28570 at 8/6/22 1:03 PM:
Fixed in master:
[
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
[
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
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
--
[
https://issues.apache.org/jira/browse/FLINK-28765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576210#comment-17576210
]
Suhan Mao commented on FLINK-28765:
---
[~hui.yang] It probably can work, you could try.
> Create a doc
[
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
>
[
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
[
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
>
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:
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
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
[
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://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576201#comment-17576201
]
Jark Wu commented on FLINK-28844:
-
[~chesnay], could you help to take a look?
>
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
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
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()
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
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
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
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>
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>
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
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
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
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
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
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
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
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
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
[
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
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`
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.
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
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
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
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:
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
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
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
godfreyhe commented on PR #20374:
URL: https://github.com/apache/flink/pull/20374#issuecomment-1207181809
@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
godfreyhe commented on code in PR #20359:
URL: https://github.com/apache/flink/pull/20359#discussion_r939500620
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/JoinHintResolver.java:
##
@@ -0,0 +1,267 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-28164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576159#comment-17576159
]
Wencong Liu commented on FLINK-28164:
-
According to the discussion in
1 - 100 of 122 matches
Mail list logo