snuyanzin commented on code in PR #24235:
URL: https://github.com/apache/flink/pull/24235#discussion_r1475692973
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java:
##
@@ -158,16 +160,17 @@
* Default implementation of {@link
1996fanrui commented on code in PR #24246:
URL: https://github.com/apache/flink/pull/24246#discussion_r1475680928
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java:
##
@@ -328,7 +330,7 @@ public void
testCheckpointRescalingNonPartitionedS
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813215#comment-17813215
]
Matthias Pohl edited comment on FLINK-34333 at 2/2/24 7:46 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813537#comment-17813537
]
Matthias Pohl commented on FLINK-34202:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-34007:
---
I'm reopening the issue because we're seeing test instabilities now:
*
[https://dev.azure.com/
1996fanrui commented on code in PR #24246:
URL: https://github.com/apache/flink/pull/24246#discussion_r1475645896
##
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java:
##
@@ -367,9 +367,11 @@ public static void waitForCheckpoint(JobID jobID,
Mi
1996fanrui commented on code in PR #24246:
URL: https://github.com/apache/flink/pull/24246#discussion_r1475645896
##
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java:
##
@@ -367,9 +367,11 @@ public static void waitForCheckpoint(JobID jobID,
Mi
xuyangzhong commented on code in PR #24243:
URL: https://github.com/apache/flink/pull/24243#discussion_r1475601398
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala:
##
@@ -257,4 +257,48 @@ class Window
1996fanrui commented on PR #24248:
URL: https://github.com/apache/flink/pull/24248#issuecomment-1923016887
org.apache.flink.test.checkpointing.AutoRescalingITCase#testCheckpointRescalingNonPartitionedStateCausesException
hangs as well.
I checked, all test jobs of AutoRescalingITCase
hackergin commented on code in PR #24243:
URL: https://github.com/apache/flink/pull/24243#discussion_r1475597199
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala:
##
@@ -257,4 +257,48 @@ class WindowTa
xuyangzhong commented on code in PR #24243:
URL: https://github.com/apache/flink/pull/24243#discussion_r1475596548
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala:
##
@@ -257,4 +257,48 @@ class Window
xuyang created FLINK-34338:
--
Summary: An exception is thrown when some named params change
order when using window tvf
Key: FLINK-34338
URL: https://issues.apache.org/jira/browse/FLINK-34338
Project: Flink
Jiabao-Sun commented on code in PR #20340:
URL: https://github.com/apache/flink/pull/20340#discussion_r1475595276
##
docs/content.zh/docs/deployment/ha/overview.md:
##
@@ -74,18 +74,9 @@ Flink 提供了两种高可用服务实现：
{{< top >}}
-## JobResultStore
-
-The JobResultStore is used to arc
xuyangzhong commented on code in PR #24243:
URL: https://github.com/apache/flink/pull/24243#discussion_r1475591118
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala:
##
@@ -257,4 +257,48 @@ class Window
xuyangzhong commented on code in PR #24239:
URL: https://github.com/apache/flink/pull/24239#discussion_r1475586086
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/NestLoopJoinHintTest.xml:
##
@@ -679,8 +680,8 @@ HashJoin(join
flinkbot commented on PR #24249:
URL: https://github.com/apache/flink/pull/24249#issuecomment-1922891781
## CI report:
* a57b0e7e04a2f3f3b61a7a5c2ed5f3e8cbae9f47 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jiabao-Sun commented on PR #24249:
URL: https://github.com/apache/flink/pull/24249#issuecomment-1922891276
Hi @pvary, could you help review it when you have time?
--
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-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34192:
---
Labels: pull-request-available (was: )
> Update flink-connector-kafka to be compatible with
[
https://issues.apache.org/jira/browse/FLINK-34178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34178.
-
Fix Version/s: kubernetes-operator-1.8.0
Resolution: Fixed
> The ScalingTracking of autoscaler is
[
https://issues.apache.org/jira/browse/FLINK-34178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813488#comment-17813488
]
Rui Fan commented on FLINK-34178:
-
Merged to main(1.8.0) via:
* 2bd6b1b38171ce821509d46
[
https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813487#comment-17813487
]
Rui Fan edited comment on FLINK-34329 at 2/2/24 5:54 AM:
-
Merged
[
https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34329.
-
Resolution: Fixed
> ScalingReport format tests fail locally on decimal format
>
[
https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813487#comment-17813487
]
Rui Fan commented on FLINK-34329:
-
Merged to main(1.9.0) via : 398a87c9012ddc79bfe4b2378
1996fanrui merged PR #759:
URL: https://github.com/apache/flink-kubernetes-operator/pull/759
--
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-unsu
1996fanrui commented on PR #759:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/759#issuecomment-1922886105
Thanks for the review. I tested locally, it works fine, the tracking time is
correct now. Merging~
--
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-34337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34337:
---
Labels: pull-request-available (was: )
> Sink.InitContextWrapper should implement metadataC
Jiabao-Sun opened a new pull request, #24249:
URL: https://github.com/apache/flink/pull/24249
## What is the purpose of the change
[FLINK-34337][core] Sink.InitContextWrapper should implement
metadataConsumer method
## Brief change log
Sink.InitContextWrapper sho
Jiabao Sun created FLINK-34337:
--
Summary: Sink.InitContextWrapper should implement metadataConsumer
method
Key: FLINK-34337
URL: https://issues.apache.org/jira/browse/FLINK-34337
Project: Flink
1996fanrui merged PR #769:
URL: https://github.com/apache/flink-kubernetes-operator/pull/769
--
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-unsu
[
https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34336:
Description:
AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may
hang in
wait
flinkbot commented on PR #24248:
URL: https://github.com/apache/flink/pull/24248#issuecomment-1922845516
## CI report:
* 9732c01c33a38cb989d9fb73a5838329f35d8f7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34336:
---
Labels: pull-request-available (was: )
> AutoRescalingITCase#testCheckpointRescalingWithKey
1996fanrui opened a new pull request, #24248:
URL: https://github.com/apache/flink/pull/24248
## Purpose
AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState
may hang in waitForRunningTasks(restClusterClient, jobID, parallelism2);
## Reason:
The job
[
https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34336:
Description:
AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may
hang in
wait
Rui Fan created FLINK-34336:
---
Summary:
AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may
hang sometimes
Key: FLINK-34336
URL: https://issues.apache.org/jira/browse/FLINK-34336
fredia commented on code in PR #24181:
URL: https://github.com/apache/flink/pull/24181#discussion_r1475523078
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/WithinCheckpointFileMergingSnapshotManager.java:
##
@@ -50,6 +50,43 @@ public WithinCheckp
xuyang created FLINK-34335:
--
Summary: Query hints in RexSubQuery could not be printed
Key: FLINK-34335
URL: https://issues.apache.org/jira/browse/FLINK-34335
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-34335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813470#comment-17813470
]
xuyang commented on FLINK-34335:
I'll try to fix it.
> Query hints in RexSubQuery could
Jiabao-Sun commented on code in PR #23960:
URL: https://github.com/apache/flink/pull/23960#discussion_r1475422173
##
flink-core/src/test/java/org/apache/flink/api/common/io/FileInputFormatTest.java:
##
@@ -603,55 +587,52 @@ public void
testGetStatisticsMultipleOneFileWithCached
[
https://issues.apache.org/jira/browse/FLINK-34169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813469#comment-17813469
]
Yunfeng Zhou commented on FLINK-34169:
--
Fixed in 8dd28a2e8bf10ec278ff90c99563468e29
[
https://issues.apache.org/jira/browse/FLINK-34295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813465#comment-17813465
]
Junrui Li commented on FLINK-34295:
---
[~lincoln.86xy] This change doesn't need cross te
[
https://issues.apache.org/jira/browse/FLINK-34296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813466#comment-17813466
]
Junrui Li commented on FLINK-34296:
---
[~lincoln.86xy] This change doesn't need cross te
[
https://issues.apache.org/jira/browse/FLINK-32514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunfeng Zhou updated FLINK-32514:
-
Release Note: ProcessingBacklog is introduced to demonstrate whether a
record should be processe
[
https://issues.apache.org/jira/browse/FLINK-34299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813464#comment-17813464
]
Yangze Guo commented on FLINK-34299:
This change doesn't need crossteam testing.
>
[
https://issues.apache.org/jira/browse/FLINK-34299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-34299.
--
Resolution: Fixed
> Release Testing Instructions: Verify FLINK-33203 Adding a separate
> configuratio
[
https://issues.apache.org/jira/browse/FLINK-34258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-34258.
-
> Incorrect example of accumulator usage within emitUpdateWithRetract for
> TableAggregateFunction
> --
[
https://issues.apache.org/jira/browse/FLINK-34258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-34258.
---
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in master 0779c91e581dc16c4aef61d6cc27774f11495
[
https://issues.apache.org/jira/browse/FLINK-34258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34258:
-
Assignee: Jane Chan
> Incorrect example of accumulator usage within emitUpdateWithRetract for
LadyForest merged PR #24215:
URL: https://github.com/apache/flink/pull/24215
--
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
flinkbot commented on PR #24247:
URL: https://github.com/apache/flink/pull/24247#issuecomment-1922655270
## CI report:
* 5d0a461e79a4b6446e73c171bac69482f9d3251f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33734:
---
Labels: pull-request-available (was: )
> Merge unaligned checkpoint state handle
>
zoltar9264 opened a new pull request, #24247:
URL: https://github.com/apache/flink/pull/24247
## What is the purpose of the change
Merge and serialize the state handles of unaligned checkpoint on TaskManager
to potentially reduce checkpoint production time. Details in
[FLINK-33734](h
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813391#comment-17813391
]
Mingliang Liu commented on FLINK-27054:
---
Any updates on this?
My understanding is
JingGe commented on PR #24156:
URL: https://github.com/apache/flink/pull/24156#issuecomment-1922027269
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
T
XComp commented on code in PR #24246:
URL: https://github.com/apache/flink/pull/24246#discussion_r1474488421
##
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java:
##
@@ -367,9 +367,11 @@ public static void waitForCheckpoint(JobID jobID,
MiniClu
gyfora commented on PR #749:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/749#issuecomment-1921722522
@lajith2006 do you already have a Jira account?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813319#comment-17813319
]
Sergey Nuyanzin commented on FLINK-34148:
-
As it was decided in release meeting
[
https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813316#comment-17813316
]
Wencong Liu commented on FLINK-34132:
-
Thanks for the reminding. [~zhuzh] I will add
mxm merged PR #768:
URL: https://github.com/apache/flink-kubernetes-operator/pull/768
--
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...
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34333:
--
Description:
FLINK-34007 revealed a bug in the k8s client v6.6.2 which we're using since
Flin
[
https://issues.apache.org/jira/browse/FLINK-34319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34319.
--
Fix Version/s: kubernetes-operator-1.8.0
(was: 1.8.0)
Assignee: ConradJ
gyfora merged PR #766:
URL: https://github.com/apache/flink-kubernetes-operator/pull/766
--
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
ferenc-csaky commented on PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#issuecomment-1921525300
@pvary @gaborgsomogyi JAR included, CI run passed.
--
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-31220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31220:
---
Labels: pull-request-available (was: )
> Replace Pod with PodTemplateSpec for the pod templ
gyfora commented on PR #770:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/770#issuecomment-1921435716
cc @afedulov
--
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
gyfora opened a new pull request, #770:
URL: https://github.com/apache/flink-kubernetes-operator/pull/770
## What is the purpose of the change
The PodTemplate fields in the CRD currently incorrectly use the Pod time,
when they should be PodTemplateSpec type. This leads to unnecessary
gyfora closed pull request #767: [hotfix] Remove unnecessary fields from
podTemplate examples
URL: https://github.com/apache/flink-kubernetes-operator/pull/767
--
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
vahmed-hamdy commented on PR #24175:
URL: https://github.com/apache/flink/pull/24175#issuecomment-1921379510
@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
[
https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813238#comment-17813238
]
Alexis Sarda-Espinosa commented on FLINK-34325:
---
I will say that, while I
[
https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813238#comment-17813238
]
Alexis Sarda-Espinosa edited comment on FLINK-34325 at 2/1/24 1:49 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexis Sarda-Espinosa updated FLINK-34325:
--
Description:
I have a job that uses broadcast state to maintain a cache of req
[
https://issues.apache.org/jira/browse/FLINK-34328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813234#comment-17813234
]
lincoln lee commented on FLINK-34328:
-
[~Zhanghao Chen] Assigned to you :)
> Releas
[
https://issues.apache.org/jira/browse/FLINK-34328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-34328:
---
Assignee: Zhanghao Chen
> Release Testing Instructions: Verify FLINK-34037 Improve Serializ
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813215#comment-17813215
]
Matthias Pohl commented on FLINK-34333:
---
I think it's fine to do the upgrade from
flinkbot commented on PR #24246:
URL: https://github.com/apache/flink/pull/24246#issuecomment-1921304022
## CI report:
* 9eec91beb3f2ac2344454b9402ba2505201f0e49 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813205#comment-17813205
]
Rui Fan commented on FLINK-34200:
-
I have attached the detailed log in this JIRA.
> Aut
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34200:
---
Labels: pull-request-available test-stability (was: test-stability)
> AutoRescalingITCase#t
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34200:
---
Assignee: Rui Fan
> AutoRescalingITCase#testCheckpointRescalingInKeyedState fails
> ---
snuyanzin merged PR #24227:
URL: https://github.com/apache/flink/pull/24227
--
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.apa
snuyanzin commented on PR #24227:
URL: https://github.com/apache/flink/pull/24227#issuecomment-1921276645
thanks for taking a look
--
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
flinkbot commented on PR #24245:
URL: https://github.com/apache/flink/pull/24245#issuecomment-1921277811
## CI report:
* 087ef9d4311dcacaa6d7e7caf15d9abce0e8fb95 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813201#comment-17813201
]
Rui Fan edited comment on FLINK-34200 at 2/1/24 12:59 PM:
--
Afte
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813201#comment-17813201
]
Rui Fan commented on FLINK-34200:
-
After re-run hundreds of times and adding a series of
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813199#comment-17813199
]
Matthias Pohl edited comment on FLINK-34333 at 2/1/24 12:55 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34333:
---
Labels: pull-request-available (was: )
> Fix FLINK-34007 LeaderElector bug in 1.18
> --
XComp opened a new pull request, #24245:
URL: https://github.com/apache/flink/pull/24245
## What is the purpose of the change
This is the fix of FLINK-34007 applied to Flink 1.18. In the end, it's a
straight-forward backport including the upgrade to fabric8io:kubernetes-client
v6.9.0
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34200:
Attachment: debug-34200.log
> AutoRescalingITCase#testCheckpointRescalingInKeyedState fails
>
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813199#comment-17813199
]
Matthias Pohl edited comment on FLINK-34333 at 2/1/24 12:48 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813199#comment-17813199
]
Matthias Pohl commented on FLINK-34333:
---
Breaking changes between v6.6.2 and v6.9.
Jufang He created FLINK-34334:
-
Summary: Add sub-task level RocksDB file count metric
Key: FLINK-34334
URL: https://issues.apache.org/jira/browse/FLINK-34334
Project: Flink
Issue Type: Improvemen
zentol commented on code in PR #24012:
URL: https://github.com/apache/flink/pull/24012#discussion_r1474310073
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -301,27 +301,24 @@ public Collection
getContai
hackergin commented on code in PR #24235:
URL: https://github.com/apache/flink/pull/24235#discussion_r1474310557
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkSqlCallBinding.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache
hackergin commented on code in PR #24235:
URL: https://github.com/apache/flink/pull/24235#discussion_r1474303521
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkSqlCallBinding.java:
##
@@ -77,20 +76,15 @@ public List operands() {
hackergin commented on code in PR #24235:
URL: https://github.com/apache/flink/pull/24235#discussion_r1474302721
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/OperatorBindingCallContext.java:
##
@@ -59,7 +59,7 @@ public Opera
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34007:
--
Release Note: Fixes a bug where the leader election wasn't able to pick up
leadership again af
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34007:
--
Release Note: Fixes a bug where the leader election wasn't able to pick up
leadership again af
[
https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813169#comment-17813169
]
Dan Zou commented on FLINK-34229:
-
[~xiasun] Could you please check if this
[PR|https:/
zentol commented on code in PR #24244:
URL: https://github.com/apache/flink/pull/24244#discussion_r1474268805
##
flink-end-to-end-tests/test-scripts/test_file_sink.sh:
##
@@ -96,13 +51,54 @@ function get_complete_result {
# line number in part files
#
z3d1k commented on code in PR #127:
URL:
https://github.com/apache/flink-connector-aws/pull/127#discussion_r1474264702
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java:
##
@@ -284,7 +284,7 @
zentol commented on code in PR #24244:
URL: https://github.com/apache/flink/pull/24244#discussion_r1474261856
##
flink-end-to-end-tests/test-scripts/test_file_sink.sh:
##
@@ -96,13 +51,54 @@ function get_complete_result {
# line number in part files
#
1 - 100 of 153 matches
Mail list logo
