WencongLiu opened a new pull request, #21645:
URL: https://github.com/apache/flink/pull/21645
## What is the purpose of the change
Improve the logic for enumerating splits for Hive source to avoid potential
OOM
## Brief change log
- *Introduce the HiveSourc
tisonkun merged PR #16:
URL: https://github.com/apache/flink-connector-pulsar/pull/16
--
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...
xintongsong commented on code in PR #21603:
URL: https://github.com/apache/flink/pull/21603#discussion_r1065378796
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexSpilledRegionManagerImpl.java:
##
@@ -0,0 +1,288 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-14023:
---
Assignee: Dian Fu
> Support accessing job parameters in Python user-defined functions
> ---
flinkbot commented on PR #21644:
URL: https://github.com/apache/flink/pull/21644#issuecomment-1378346642
## CI report:
* ece5fc636eff04178c8b0f13c43799eefb08189b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guoxin updated FLINK-30612:
---
Component/s: Table SQL / API
Table SQL / Runtime
> ObjectArrayConverter is not thread-safe，
[
https://issues.apache.org/jira/browse/FLINK-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14023:
---
Labels: pull-request-available (was: )
> Support accessing job parameters in Python user-de
dianfu opened a new pull request, #21644:
URL: https://github.com/apache/flink/pull/21644
## What is the purpose of the change
*This pull request allows to access the job parameters defined in Python
user-defined functions*
## Verifying this change
Please make su
ruanhang1993 commented on PR #21589:
URL: https://github.com/apache/flink/pull/21589#issuecomment-1378316766
@lindong28 @PatrickRen Could you help to review this PR? Thanks ~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066577618
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/OnlineStandardScalerTest.java:
##
@@ -0,0 +1,396 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
zhipeng93 commented on PR #196:
URL: https://github.com/apache/flink-ml/pull/196#issuecomment-1378314881
> @zhipeng93 Thanks for the PR, left some comments.
Thanks @jiangxin369 for the review. I have addressed your comments in the
latest commit. Please take a look.
--
This is an au
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066632174
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/OnlineStandardScalerParams.java:
##
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-30615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30615:
---
Labels: pull-request-available (was: )
> Refactor ReadWriteTableITCase to get rid of Manage
yuzelin opened a new pull request, #478:
URL: https://github.com/apache/flink-table-store/pull/478
1. Split Kafka log related cases into a new test class.
2. `testQueryContainsDefaultFieldName` & `testSuccessiveWriteAndRead` in
`ReadWriteTableITCase` seems trivial so I remove them.
3.
tsreaper commented on code in PR #475:
URL: https://github.com/apache/flink-table-store/pull/475#discussion_r1066610241
##
flink-table-store-hive/flink-table-store-hive-catalog/src/main/java/org/apache/flink/table/store/hive/HiveCatalogOptions.java:
##
@@ -0,0 +1,34 @@
+/*
+ * L
swuferhong commented on code in PR #20822:
URL: https://github.com/apache/flink/pull/20822#discussion_r1066609115
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/SubplanReuseTest.scala:
##
@@ -248,6 +248,44 @@ class SubplanReuseTe
swuferhong commented on code in PR #20822:
URL: https://github.com/apache/flink/pull/20822#discussion_r1066608228
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/SubplanReuseTest.scala:
##
@@ -334,6 +334,44 @@ class SubplanReuseTes
fsk119 commented on code in PR #21581:
URL: https://github.com/apache/flink/pull/21581#discussion_r1066602543
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -487,23 +487,22 @@ public ResultFetcher cal
zhangjun0x01 commented on code in PR #471:
URL: https://github.com/apache/flink-table-store/pull/471#discussion_r1066603066
##
flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java:
##
@@ -276,6 +279,36 @@ pu
fsk119 commented on code in PR #21582:
URL: https://github.com/apache/flink/pull/21582#discussion_r1066565533
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -524,6 +533,47 @@ private ResultFetcher bui
JingsongLi commented on code in PR #471:
URL: https://github.com/apache/flink-table-store/pull/471#discussion_r1066593633
##
flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java:
##
@@ -276,6 +279,36 @@ publ
JingsongLi commented on code in PR #475:
URL: https://github.com/apache/flink-table-store/pull/475#discussion_r1066589722
##
docs/layouts/shortcodes/generated/hive_catalog_configuration.html:
##
@@ -0,0 +1,18 @@
+
+
+
+Key
+Default
+
[
https://issues.apache.org/jira/browse/FLINK-30168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17657083#comment-17657083
]
Dian Fu commented on FLINK-30168:
-
[~yunfengzhou] Could you share some code snippets whi
lindong28 commented on code in PR #21621:
URL: https://github.com/apache/flink/pull/21621#discussion_r1066582414
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BootstrapStreamTask.java:
##
@@ -82,16 +86,14 @@ protected void init() t
gyfora commented on code in PR #502:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/502#discussion_r1066577710
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScaler.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed t
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066577618
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/OnlineStandardScalerTest.java:
##
@@ -0,0 +1,396 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066575361
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/OnlineStandardScaler.java:
##
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the Apache Software Founda
gyfora commented on code in PR #502:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/502#discussion_r1066574644
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScaler.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed t
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066574806
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/OnlineStandardScaler.java:
##
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the Apache Software Founda
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066574806
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/OnlineStandardScaler.java:
##
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the Apache Software Founda
gyfora commented on code in PR #502:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/502#discussion_r1066574644
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScaler.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed t
gyfora commented on code in PR #502:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/502#discussion_r1066572069
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScaler.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed t
gyfora commented on code in PR #502:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/502#discussion_r1066571479
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScaler.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed t
zhangjun0x01 commented on code in PR #471:
URL: https://github.com/apache/flink-table-store/pull/471#discussion_r1066569592
##
flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java:
##
@@ -276,6 +279,36 @@ pu
[
https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17657076#comment-17657076
]
Gyula Fora commented on FLINK-30609:
+1 from my part, this indeed seems to be a comm
[
https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17657075#comment-17657075
]
Gyula Fora commented on FLINK-30609:
Are you suggesting simply adding:
```
ephemeral
JingsongLi commented on PR #471:
URL:
https://github.com/apache/flink-table-store/pull/471#issuecomment-1378230909
>
The point is: there is only one implementation for
`Catalog.getTableLocation`, that is `AbstractCatalog.getTableLocation`
--
This is an automated message from the
JingsongLi commented on code in PR #471:
URL: https://github.com/apache/flink-table-store/pull/471#discussion_r1066564740
##
flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java:
##
@@ -276,6 +279,36 @@ publ
JingsongLi opened a new pull request, #477:
URL: https://github.com/apache/flink-table-store/pull/477
We should read kerberos keytab from catalog options and doAs for hive
metastore client.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-30628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30628:
---
Labels: pull-request-available (was: )
> Kerberos in HiveCatalog is not work
>
Jingsong Lee created FLINK-30628:
Summary: Kerberos in HiveCatalog is not work
Key: FLINK-30628
URL: https://issues.apache.org/jira/browse/FLINK-30628
Project: Flink
Issue Type: Bug
JingsongLi opened a new pull request, #476:
URL: https://github.com/apache/flink-table-store/pull/476
We should read kerberos keytab from catalog options and doAs for hive
metastore client.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066558831
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/common/JoinReorderTestBase.scala:
##
@@ -121,6 +121,8 @@ abstract class JoinReo
fsk119 commented on code in PR #20822:
URL: https://github.com/apache/flink/pull/20822#discussion_r1066546132
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdDistribution.scala:
##
@@ -87,6 +87,10 @@ class FlinkRelMdDistri
zhuzhurk commented on code in PR #21621:
URL: https://github.com/apache/flink/pull/21621#discussion_r106677
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BootstrapStreamTask.java:
##
@@ -82,16 +86,14 @@ protected void init() th
zhipeng93 commented on code in PR #196:
URL: https://github.com/apache/flink-ml/pull/196#discussion_r1066549248
##
flink-ml-python/pyflink/ml/lib/param.py:
##
@@ -581,3 +581,48 @@ def get_flatten(self) -> bool:
@property
def flatten(self):
return self.get(self
[
https://issues.apache.org/jira/browse/FLINK-30401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang resolved FLINK-30401.
---
Resolution: Fixed
> Add Estimator and Transformer for MinHashLSH
> -
flinkbot commented on PR #21643:
URL: https://github.com/apache/flink/pull/21643#issuecomment-1378194575
## CI report:
* e1edb1263219a587b5eb67c9ee1c7aa8642b8037 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhangjun0x01 commented on PR #471:
URL:
https://github.com/apache/flink-table-store/pull/471#issuecomment-1378191610
> Thanks @zhangjun0x01 for the contribution.
>
> Maybe there is a problem here. You didn't rename the entire table file
directory. Our current design has determined th
LadyForest opened a new pull request, #21643:
URL: https://github.com/apache/flink/pull/21643
## What is the purpose of the change
This is a trivial change to fix the broken link in page
[determinism/#3-determinism-in-streaming-processing](https://nightlies.apache.org/flink/flink-docs
lindong28 commented on code in PR #21621:
URL: https://github.com/apache/flink/pull/21621#discussion_r1066536879
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BootstrapStreamTask.java:
##
@@ -82,16 +86,14 @@ protected void init() t
zhipeng93 merged PR #191:
URL: https://github.com/apache/flink-ml/pull/191
--
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
zhipeng93 commented on PR #191:
URL: https://github.com/apache/flink-ml/pull/191#issuecomment-1378185006
Thanks for the update. 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
yuchuanchen commented on code in PR #21563:
URL: https://github.com/apache/flink/pull/21563#discussion_r1066533653
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemConnectorOptions.java:
##
@@ -68,6 +70,22 @@ public class Fi
fsk119 commented on code in PR #21502:
URL: https://github.com/apache/flink/pull/21502#discussion_r1066514320
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -506,24 +521,16 @@ public ResultFetcher cal
libenchao commented on PR #21613:
URL: https://github.com/apache/flink/pull/21613#issuecomment-1378176914
@maosuhan I will, but I've been a little busy lately. To manage your
expectation, it won't be quick.
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/FLINK-30607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-30607.
---
Fix Version/s: 1.17.0
Assignee: Dian Fu
Resolution: Fixed
Merged to master via b781a13dd615e
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066524471
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/JoinReorderITCase.java:
##
@@ -0,0 +1,465 @@
+/*
+ * Licensed
dianfu closed pull request #21639: [FLINK-30607][python] Support MapType for
Pandas UDF
URL: https://github.com/apache/flink/pull/21639
--
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 c
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066523167
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/JoinReorderITCase.java:
##
@@ -0,0 +1,465 @@
+/*
+ * Licensed
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066523057
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/JoinReorderITCase.java:
##
@@ -0,0 +1,465 @@
+/*
+ * Licensed
flinkbot commented on PR #21642:
URL: https://github.com/apache/flink/pull/21642#issuecomment-1378160576
## CI report:
* 663a5d85ff5189fbea1470eee8b333245cf30315 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30617:
---
Labels: pull-request-available (was: )
> Wrong data type for null literal with cast in Hive
luoyuxia opened a new pull request, #21642:
URL: https://github.com/apache/flink/pull/21642
## 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 o
[
https://issues.apache.org/jira/browse/FLINK-30592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655878#comment-17655878
]
Jark Wu edited comment on FLINK-30592 at 1/11/23 2:09 AM:
--
Fixe
[
https://issues.apache.org/jira/browse/FLINK-30592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-30592:
Fix Version/s: 1.16.1
> The unsupported hive version is not deleted on the hive overview document
> --
wuchong merged PR #21625:
URL: https://github.com/apache/flink/pull/21625
--
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
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066506235
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066506352
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066506235
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
lindong28 commented on PR #21621:
URL: https://github.com/apache/flink/pull/21621#issuecomment-1378140166
Thanks for the PR! 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 com
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066501816
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
flinkbot commented on PR #21641:
URL: https://github.com/apache/flink/pull/21641#issuecomment-1378137900
## CI report:
* debc2e12062d3ec0924438eb18cdd1a08f80cf53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuchuanchen commented on code in PR #21563:
URL: https://github.com/apache/flink/pull/21563#discussion_r1066500768
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/DataTypeUtils.java:
##
@@ -94,6 +99,217 @@ public static DataType projectRow(Data
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066499832
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
lsyldliu commented on PR #21596:
URL: https://github.com/apache/flink/pull/21596#issuecomment-1378134535
cc @beyond1920
--
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
[
https://issues.apache.org/jira/browse/FLINK-30006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30006:
---
Labels: pull-request-available (was: )
> Cannot remove columns that are incorrectly conside
lincoln-lil opened a new pull request, #21641:
URL: https://github.com/apache/flink/pull/21641
## What is the purpose of the change
Make all pure dynamic functions non-deterministic in streaming mode to avoid
wrong plans
## Brief change log
* change all pure dynamic functions no
lsyldliu commented on PR #21601:
URL: https://github.com/apache/flink/pull/21601#issuecomment-1378134200
cc @beyond1920
--
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
lsyldliu commented on PR #21605:
URL: https://github.com/apache/flink/pull/21605#issuecomment-1378133936
cc @beyond1920
--
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
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066499085
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-30006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-30006:
Description:
In Streaming, columns generated by dynamic functions are incorrectly considered
cons
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066494317
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066493761
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066492728
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066492364
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066491418
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066490734
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066490161
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,634 @@
+/*
+ * Licen
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1066489338
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/join/JoinReorderITCase.java:
##
@@ -0,0 +1,276 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-30601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-30601:
Assignee: Lijie Wang
> Omit "setKeyContextElement" call for non-keyed stream/operators to improve
VinodAnandan commented on code in PR #503:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/503#discussion_r1066466074
##
pom.xml:
##
@@ -402,6 +402,20 @@ under the License.
+
+
+org.
MartijnVisser closed pull request #15140: [FLINK-20628][connectors/rabbitmq2]
RabbitMQ connector using new connector API
URL: https://github.com/apache/flink/pull/15140
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
MartijnVisser commented on PR #15140:
URL: https://github.com/apache/flink/pull/15140#issuecomment-1378032498
Closing this PR since the connector has been moved to
https://github.com/apache/flink-connector-rabbitmq and this PR is now available
at https://github.com/apache/flink-connector-ra
MartijnVisser closed pull request #17524: Update rabbitmq.md
URL: https://github.com/apache/flink/pull/17524
--
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-m
MartijnVisser commented on PR #17524:
URL: https://github.com/apache/flink/pull/17524#issuecomment-1378031895
Closed since the connector code has been moved to
https://github.com/apache/flink-connector-rabbitmq
--
This is an automated message from the Apache Git Service.
To respond to the
MartijnVisser commented on PR #21630:
URL: https://github.com/apache/flink/pull/21630#issuecomment-1377897663
> Why don't we remove everything at once?
That was the original idea, but I chatted offline with @JingsongLi and there
is work to be done on `FileSystemTableSink` in order to
Martijn Visser created FLINK-30627:
--
Summary: Refactor FileSystemTableSink to use FileSink instead of
StreamingFileSink
Key: FLINK-30627
URL: https://issues.apache.org/jira/browse/FLINK-30627
Project
MartijnVisser commented on PR #21542:
URL: https://github.com/apache/flink/pull/21542#issuecomment-1377887404
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-30626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30626:
---
Description:
https://github.com/apache/flink-connector-rabbitmq/actions/runs/3773487890/jobs
1 - 100 of 243 matches
Mail list logo
