jiaoqingbo commented on PR #22694:
URL: https://github.com/apache/flink/pull/22694#issuecomment-1645088574
[FAIL] 'Run Kubernetes test' failed after 5 minutes and 31 seconds! Test
exited with exit code 1
CI errors do not seem to be related to this PR
--
This is an automated messa
WencongLiu commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1270307421
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java:
##
@@ -122,6 +155,9 @@ public ResultPartitionFactory(
WencongLiu commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1270307675
##
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##
@@ -28,6 +28,12 @@
@PublicEvolving
public class NettyShuffleEnvi
WencongLiu commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1270307929
##
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##
@@ -381,6 +393,38 @@ public class NettyShuffleEnvironmentOptions {
[
https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc updated FLINK-32587:
-
Description:
I created a CDC table(the sqlserver source table has more than 100 columns) as
bel
WencongLiu commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1270309221
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageConfiguration.java:
##
@@ -18,58 +18,435 @@
package
Tartarus0zm commented on code in PR #22862:
URL: https://github.com/apache/flink/pull/22862#discussion_r1270206798
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/utils/HiveCatalogUtils.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apach
wanglijie95 commented on PR #23004:
URL: https://github.com/apache/flink/pull/23004#issuecomment-1645107962
The CI failure is caused by FLINK-32632. It is inrelevant of this PR. This
PR only add 5 new class to Flink, does not affect any original logic of Flink.
Merged.
--
This is an auto
wanglijie95 closed pull request #23004: [FLINK-32493][table-runtime] Introduce
RuntimeFilterBuilderOperator to build a BloomFilter from build side data of
shuffle join
URL: https://github.com/apache/flink/pull/23004
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/FLINK-32493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745467#comment-17745467
]
Lijie Wang commented on FLINK-32493:
Done via master(1.18) 47596ea9250415bc333fa612c
[
https://issues.apache.org/jira/browse/FLINK-32493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-32493.
--
Resolution: Done
> Introduce RuntimeFilterBuilderOperator to build a BloomFilter from build side
> da
huwh commented on PR #22913:
URL: https://github.com/apache/flink/pull/22913#issuecomment-1645117387
@KarmaGYZ Thanks for review, I have updated this pr, PTAL
Because the class name has changed, it's hard to create fixup commits
without conflict, so I change the origin commit and forc
reswqa commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1270333895
##
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##
@@ -28,6 +28,12 @@
@PublicEvolving
public class NettyShuffleEnvironm
WencongLiu commented on PR #22975:
URL: https://github.com/apache/flink/pull/22975#issuecomment-1645155920
Thanks for the review 😄 @TanYuxin-tyx @reswqa . Please take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-32638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745473#comment-17745473
]
Yunhong Zheng commented on FLINK-32638:
---
https://dev.azure.com/apache-flink/apache
lsyldliu commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270276722
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/runtimefilter/util/RuntimeFilterUtils.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licen
lincoln-lil commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r1270274880
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/abilities/source/SourceAbilitySpec.java:
##
@@ -58,6 +58,14 @@ public interface
huwh commented on PR #22861:
URL: https://github.com/apache/flink/pull/22861#issuecomment-1645183189
@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
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745490#comment-17745490
]
Alexander Fedulov edited comment on FLINK-28046 at 7/21/23 8:31 AM:
--
TanYuxin-tyx commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1270396604
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/GateBuffersSpecTest.java:
##
@@ -143,17 +144,25 @@ void
testCalculationWithC
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745490#comment-17745490
]
Alexander Fedulov commented on FLINK-28046:
---
This is how the subject of the or
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745490#comment-17745490
]
Alexander Fedulov edited comment on FLINK-28046 at 7/21/23 8:32 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745490#comment-17745490
]
Alexander Fedulov edited comment on FLINK-28046 at 7/21/23 8:32 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745490#comment-17745490
]
Alexander Fedulov edited comment on FLINK-28046 at 7/21/23 8:33 AM:
--
wanglijie95 commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270404663
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/runtimefilter/LocalRuntimeFilterBuilderOperator.java:
##
@@ -0,0 +1,96 @@
wanglijie95 commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270407081
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/runtimefilter/util/RuntimeFilterUtils.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Li
luoyuxia commented on PR #22939:
URL: https://github.com/apache/flink/pull/22939#issuecomment-1645227430
But I think it may well fail since
[FLINK-32632](https://issues.apache.org/jira/browse/FLINK-32632), anyway, ping
me after test complelte
--
This is an automated message from the Apac
lincoln-lil commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r1270410338
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkCalcMergeRule.scala:
##
@@ -65,6 +66,23 @@ class FlinkCalcM
lincoln-lil commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r1270412921
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuser.java:
##
@@ -0,0 +1,296 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745496#comment-17745496
]
Maximilian Michels commented on FLINK-28046:
Are there really any major feat
wanglijie95 opened a new pull request, #23040:
URL: https://github.com/apache/flink/pull/23040
## What is the purpose of the change
try to fix [FLINK-32632](https://issues.apache.org/jira/browse/FLINK-32632).
I guess it fails because the kubectl version is not compatible with the
minikub
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745519#comment-17745519
]
Matthias Pohl commented on FLINK-32632:
---
[~Sergey Nuyanzin] where did you find the
flinkbot commented on PR #23040:
URL: https://github.com/apache/flink/pull/23040#issuecomment-1645320754
## CI report:
* 4bc6f51a0e495e24879ca6966cb3cbeb5de7f0bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745520#comment-17745520
]
Sergey Nuyanzin commented on FLINK-32632:
-
[~mapohl] that's a bit strange behavi
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745522#comment-17745522
]
Matthias Pohl commented on FLINK-32632:
---
Thanks for the hint. I assumed the watchd
[
https://issues.apache.org/jira/browse/FLINK-32287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745524#comment-17745524
]
Hang Ruan commented on FLINK-32287:
---
I would like to help. Please assign this to me. T
hackergin commented on PR #22939:
URL: https://github.com/apache/flink/pull/22939#issuecomment-1645359943
@luoyuxia Thanks for your review. The test completed, and failed since
[FLINK-32632](https://issues.apache.org/jira/browse/FLINK-32632)
--
This is an automated message from the Apach
luoyuxia merged PR #22939:
URL: https://github.com/apache/flink/pull/22939
--
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
[
https://issues.apache.org/jira/browse/FLINK-32287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-32287:
Assignee: Hang Ruan
> Add doc for truncate table statement
>
[
https://issues.apache.org/jira/browse/FLINK-32474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32474.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master:
410b52a35a1941a6f80c9158bd3ecd439524c3f1
> Su
wanglijie95 closed pull request #23040: try fix e2e_1
URL: https://github.com/apache/flink/pull/23040
--
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: is
Jacky Lau created FLINK-32641:
-
Summary: json format supports pojo type
Key: FLINK-32641
URL: https://issues.apache.org/jira/browse/FLINK-32641
Project: Flink
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745560#comment-17745560
]
Matthias Pohl commented on FLINK-32632:
---
Ok, the issue is also appearing in 1.17:
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745565#comment-17745565
]
Matthias Pohl commented on FLINK-32632:
---
There is an issue raised in the minikube
FangYongs opened a new pull request, #23041:
URL: https://github.com/apache/flink/pull/23041
## What is the purpose of the change
This PR aims to create event for table ddl and notify catalog modification
listener in CatalogManager
## Brief change log
- Create event for ta
[
https://issues.apache.org/jira/browse/FLINK-32407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32407:
---
Labels: pull-request-available (was: )
> Notify catalog listener for table events
> ---
flinkbot commented on PR #23041:
URL: https://github.com/apache/flink/pull/23041#issuecomment-1645494845
## CI report:
* a1806d05012b40d65d0b2deb3ee836ce614ae7da UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745572#comment-17745572
]
Martijn Visser commented on FLINK-32641:
[~jackylau] Can you be a little more de
XComp opened a new pull request, #23042:
URL: https://github.com/apache/flink/pull/23042
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on e
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32632:
---
Labels: pull-request-available test-stability (was: test-stability)
> Run Kubernetes test i
flinkbot commented on PR #23042:
URL: https://github.com/apache/flink/pull/23042#issuecomment-1645517942
## CI report:
* 4db2f3a771d63866314928fe5cc9da8635e4b5eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745574#comment-17745574
]
Matthias Pohl commented on FLINK-32632:
---
It might be that it's caused by a Go-Lang
[
https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745579#comment-17745579
]
Martijn Visser commented on FLINK-29459:
[~gaoyunhaii] Should we restart the dis
JingGe commented on code in PR #23033:
URL: https://github.com/apache/flink/pull/23033#discussion_r1270643521
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java:
##
@@ -42,7 +42,12 @@
/**
* Converts an existing {@l
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32632:
-
Assignee: Matthias Pohl
> Run Kubernetes test is unstable on AZP
>
wanglijie95 commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270663166
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/runtimefilter/GlobalRuntimeFilterBuilderOperator.java:
##
@@ -0,0 +1,93 @@
wanglijie95 commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270663166
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/runtimefilter/GlobalRuntimeFilterBuilderOperator.java:
##
@@ -0,0 +1,93 @@
wanglijie95 commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270665499
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/runtimefilter/GlobalRuntimeFilterBuilderOperator.java:
##
@@ -0,0 +1,93 @@
wanglijie95 commented on code in PR #23007:
URL: https://github.com/apache/flink/pull/23007#discussion_r1270678144
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/runtimefilter/RuntimeFilterCodeGenerator.scala:
##
@@ -0,0 +1,126 @@
+/*
+
ruanhang1993 commented on code in PR #23036:
URL: https://github.com/apache/flink/pull/23036#discussion_r1270736940
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/CatalogStoreFactory.java:
##
@@ -108,7 +108,7 @@
public interface CatalogStoreFac
hackergin commented on code in PR #23036:
URL: https://github.com/apache/flink/pull/23036#discussion_r1270754419
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/CatalogStoreFactory.java:
##
@@ -108,7 +108,7 @@
public interface CatalogStoreFactor
FangYongs commented on PR #23041:
URL: https://github.com/apache/flink/pull/23041#issuecomment-1645711363
Hi @PatrickRen @leonardBang Please help to review this PR when you're free,
thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
RyanSkraba commented on code in PR #23006:
URL: https://github.com/apache/flink/pull/23006#discussion_r1270790972
##
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaOptionSerializerSnapshot.java:
##
@@ -24,7 +24,17 @@
import scala.Option;
-/** A {@link T
wanglijie95 commented on PR #23007:
URL: https://github.com/apache/flink/pull/23007#issuecomment-1645742390
Thanks for review @lsyldliu . I 've addressed or reply all comments, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
leonardBang commented on PR #23039:
URL: https://github.com/apache/flink/pull/23039#issuecomment-1645752251
@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
[
https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745645#comment-17745645
]
Matthias Pohl commented on FLINK-32632:
---
Looks like relying on binaries for {{cri-
[
https://issues.apache.org/jira/browse/FLINK-32592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32592.
Fix Version/s: 1.18.0
1.16.3
1.17.2
Resolution
[
https://issues.apache.org/jira/browse/FLINK-32592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744529#comment-17744529
]
Chesnay Schepler edited comment on FLINK-32592 at 7/21/23 4:05 PM:
---
wuchong commented on code in PR #22990:
URL: https://github.com/apache/flink/pull/22990#discussion_r1267669642
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/AggCodeGenHelper.scala:
##
@@ -45,11 +45,16 @@ import scala.annotatio
jasonliangyc created FLINK-32642:
Summary: The upsert mode doesn't work for the compound keys
Key: FLINK-32642
URL: https://issues.apache.org/jira/browse/FLINK-32642
Project: Flink
Issue Type
PatrickRen commented on PR #23039:
URL: https://github.com/apache/flink/pull/23039#issuecomment-1645977239
The CI failed because of a known issue FLINK-32632. All table test cases
passed so I'll give a green light
--
This is an automated message from the Apache Git Service.
To respond to
PatrickRen merged PR #23039:
URL: https://github.com/apache/flink/pull/23039
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-32406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745666#comment-17745666
]
Qingsheng Ren commented on FLINK-32406:
---
Merged to master: 151566d21e7051820182c13
[
https://issues.apache.org/jira/browse/FLINK-32406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-32406.
---
Resolution: Fixed
> Notify catalog listener for database events
> --
[
https://issues.apache.org/jira/browse/FLINK-32592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745668#comment-17745668
]
Fabio Wanner commented on FLINK-32592:
--
We did a few hundred deployments and did no
PatrickRen commented on code in PR #23041:
URL: https://github.com/apache/flink/pull/23041#discussion_r1270896040
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -806,6 +810,19 @@ public void createTable(
XComp commented on PR #23042:
URL: https://github.com/apache/flink/pull/23042#issuecomment-1646006632
Initially, I tried to download the debian package. But there, I ran into
problems with the corresponding dependencies (I installed the required
`containerd` dependency. But this one require
deepyaman opened a new pull request, #23043:
URL: https://github.com/apache/flink/pull/23043
## What is the purpose of the change
The existing code results in an error:
```
Traceback (most recent call last):
File "/tmp/ibis-testing-data/example.py", line 16, in
flinkbot commented on PR #23043:
URL: https://github.com/apache/flink/pull/23043#issuecomment-1646093828
## CI report:
* 8c0660c70ccd22ccde0eb0934cddb45328b456f3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin opened a new pull request, #23044:
URL: https://github.com/apache/flink/pull/23044
## 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
[
https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32628:
---
Labels: pull-request-available (was: )
> build_wheels_on_macos fails on AZP
> -
flinkbot commented on PR #23044:
URL: https://github.com/apache/flink/pull/23044#issuecomment-1646162400
## CI report:
* 99976d7392fb41da7d74fa41bdbb18fe2c057429 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin closed pull request #23044: [FLINK-32628] Fix build_wheels_on_macos
fails on AZP
URL: https://github.com/apache/flink/pull/23044
--
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 specifi
snuyanzin opened a new pull request, #23045:
URL: https://github.com/apache/flink/pull/23045
## 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
flinkbot commented on PR #23045:
URL: https://github.com/apache/flink/pull/23045#issuecomment-1646217924
## CI report:
* ea7622199e09500984ab8d9721501c08cb8433c6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Fang Yong created FLINK-32643:
-
Summary: Introduce off-heap shared state cache across stateful
operators in TM
Key: FLINK-32643
URL: https://issues.apache.org/jira/browse/FLINK-32643
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-31843:
--
Assignee: Weihua Hu
> Select slots from SlotPool#freeSlots in bulk
>
weitianpei created FLINK-32644:
--
Summary: ts
Key: FLINK-32644
URL: https://issues.apache.org/jira/browse/FLINK-32644
Project: Flink
Issue Type: Bug
Reporter: weitianpei
--
This
[
https://issues.apache.org/jira/browse/FLINK-32644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
weitianpei closed FLINK-32644.
--
Resolution: Fixed
> ts
> --
>
> Key: FLINK-32644
> URL: https://issues
lsyldliu commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r1271221828
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuser.java:
##
@@ -0,0 +1,296 @@
+/*
+ * Licensed to the Apache Softwar
lsyldliu commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r1271222052
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuser.java:
##
@@ -0,0 +1,296 @@
+/*
+ * Licensed to the Apache Softwar
lsyldliu commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r127178
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/DynamicTableSourceSpec.java:
##
@@ -71,12 +72,25 @@ public Dynamic
lsyldliu commented on code in PR #23035:
URL: https://github.com/apache/flink/pull/23035#discussion_r1271222506
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkCalcMergeRule.scala:
##
@@ -65,6 +66,23 @@ class FlinkCalcMerg
lsyldliu commented on PR #23035:
URL: https://github.com/apache/flink/pull/23035#issuecomment-1646387239
@lincoln-lil Thanks for your review, I've updated it.
--
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
luoyuxia commented on code in PR #22862:
URL: https://github.com/apache/flink/pull/22862#discussion_r1271239371
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/utils/HiveCatalogUtils.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache S
luoyuxia commented on code in PR #22862:
URL: https://github.com/apache/flink/pull/22862#discussion_r1271239389
##
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java:
##
@@ -150,4 +160,30 @@ public PlannerFactory loadPla
wanglijie95 commented on PR #23007:
URL: https://github.com/apache/flink/pull/23007#issuecomment-1646454817
The CI failed because of a known issue
[FLINK-32632](https://issues.apache.org/jira/browse/FLINK-32632). All table
test cases passed, merged.
--
This is an automated message from t
wanglijie95 closed pull request #23007: [FLINK-32491][table-runtime] Introduce
RuntimeFilterOperator to support runtime filter which can reduce the shuffle
data size before shuffle join
URL: https://github.com/apache/flink/pull/23007
--
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/FLINK-32491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745872#comment-17745872
]
Lijie Wang commented on FLINK-32491:
Done via master(1.18): 59850a91f96ddb5c58d8554b
[
https://issues.apache.org/jira/browse/FLINK-32491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-32491.
--
Resolution: Done
> Introduce RuntimeFilterOperator to support runtime filter which can reduce
> the s
1 - 100 of 113 matches
Mail list logo
