[
https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34522.
-
Resolution: Fixed
> StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time
> class
[
https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825162#comment-17825162
]
Rui Fan commented on FLINK-34522:
-
merged in master(1.20):
* eb9bcfa5893374093d3add272c
1996fanrui merged PR #24387:
URL: https://github.com/apache/flink/pull/24387
--
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-34562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825154#comment-17825154
]
Vincent Woo commented on FLINK-34562:
-
I'm willing to contribute, could someone assi
LvYanquan created FLINK-34638:
-
Summary: Support default value of table column.
Key: FLINK-34638
URL: https://issues.apache.org/jira/browse/FLINK-34638
Project: Flink
Issue Type: Improvement
ljz2051 commented on code in PR #24402:
URL: https://github.com/apache/flink/pull/24402#discussion_r1519145995
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java:
##
@@ -219,6 +219,18 @@ public TaskStateSnapshot retrieveLocalState(long
ch
ljz2051 commented on code in PR #24402:
URL: https://github.com/apache/flink/pull/24402#discussion_r1519145206
##
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java:
##
@@ -35,7 +35,7 @@
import java.util.Collection;
minchowang commented on PR #84:
URL:
https://github.com/apache/flink-connector-pulsar/pull/84#issuecomment-1987561329
> @minchowang I submitted a fix in #85 along with a unit test that
reproduces the issue. Replacing `%` with `floorMod` is simpler and keeps the
function deterministic.
flinkbot commented on PR #24478:
URL: https://github.com/apache/flink/pull/24478#issuecomment-1987525147
## CI report:
* 0301a286157fc86105ca53cd0007c458bbc75d4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519078269
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/PartitionReduceOperator.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Softw
wslkxup opened a new pull request, #24478:
URL: https://github.com/apache/flink/pull/24478
Function name LOCA_LTIME does not exist and should be LOCALTIME
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above t
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519076085
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/PartitionReduceOperator.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Softw
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519075588
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalAsyncIteratorImpl.java:
##
@@ -0,0 +1,196 @@
+/*
+ * Licensed to the Apache So
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519075382
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MapPartitionOperator.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825132#comment-17825132
]
Hongshun Wang commented on FLINK-34634:
---
[~ruanhang1993] , [~renqs] , [~Leonard] ,
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519074254
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MapPartitionOperator.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Apache Software
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519073380
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalAsyncIteratorImpl.java:
##
@@ -0,0 +1,196 @@
+/*
+ * Licensed to the Apache So
1996fanrui closed pull request #24393: Draft PR
URL: https://github.com/apache/flink/pull/24393
--
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-u
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519071934
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalAsyncIteratorImpl.java:
##
@@ -0,0 +1,196 @@
+/*
+ * Licensed to the Apache So
1996fanrui commented on PR #786:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/786#issuecomment-1987512556
> @1996fanrui I'm merging but I'll take any comments from your side that you
might have reviewing this later on.
Thanks @mxm for the improvement and ping! Sorry
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519071465
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java:
##
@@ -0,0 +1,219 @@
+/*
+ * Licensed to the Apache Sof
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1519070714
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825131#comment-17825131
]
Jacky Lau commented on FLINK-31663:
---
hi [~snuyanzin] what is your opinion?
> Add ARRA
liuyongvs commented on PR #24421:
URL: https://github.com/apache/flink/pull/24421#issuecomment-1987508497
hi @snuyanzin will you also help review this pr ?
--
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
liuyongvs commented on PR #24373:
URL: https://github.com/apache/flink/pull/24373#issuecomment-1987508136
hi @snuyanzin will you also help review this pr ?
--
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
liuyongvs commented on code in PR #24423:
URL: https://github.com/apache/flink/pull/24423#discussion_r1519069215
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ReplaceIntersectWithSemiJoinRule.java:
##
@@ -0,0 +1,96 @@
+/*
+ *
liuyongvs commented on code in PR #24423:
URL: https://github.com/apache/flink/pull/24423#discussion_r1519068996
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ReplaceIntersectWithSemiJoinRule.java:
##
@@ -0,0 +1,96 @@
+/*
+ *
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510732371
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510727272
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java:
##
@@ -1071,6 +1077,110 @@ protected SingleOutputStreamOperator
ag
[
https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825123#comment-17825123
]
Hangxiang Yu commented on FLINK-29114:
--
master:
https://dev.azure.com/apache-flink
masteryhx commented on PR #24418:
URL: https://github.com/apache/flink/pull/24418#issuecomment-1987489513
The failed case is not related to this pr:
[FLINK-29114](https://issues.apache.org/jira/browse/FLINK-29114)
--
This is an automated message from the Apache Git Service.
To respond to
masteryhx commented on code in PR #24474:
URL: https://github.com/apache/flink/pull/24474#discussion_r1519055013
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java:
##
@@ -870,7 +870,8 @@ private static void
logC
[
https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825121#comment-17825121
]
LvYanquan commented on FLINK-34585:
---
I am willing to take this.
> [JUnit5 Migration]
flinkbot commented on PR #24477:
URL: https://github.com/apache/flink/pull/24477#issuecomment-1987441888
## CI report:
* 8d7fa41547e16d601446501f8634f39784c85cea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34637:
---
Labels: pull-request-available (was: )
> Migrate JoinConditionEqualityTransferRule
> --
snuyanzin opened a new pull request, #24477:
URL: https://github.com/apache/flink/pull/24477
## 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-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825119#comment-17825119
]
Sergey Nuyanzin edited comment on FLINK-34156 at 3/11/24 12:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825119#comment-17825119
]
Sergey Nuyanzin commented on FLINK-34156:
-
the more people the better for the co
Sergey Nuyanzin created FLINK-34637:
---
Summary: Migrate JoinConditionEqualityTransferRule
Key: FLINK-34637
URL: https://issues.apache.org/jira/browse/FLINK-34637
Project: Flink
Issue Type: S
snuyanzin commented on code in PR #24423:
URL: https://github.com/apache/flink/pull/24423#discussion_r1519025405
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ReplaceIntersectWithSemiJoinRule.java:
##
@@ -0,0 +1,96 @@
+/*
+ *
snuyanzin commented on code in PR #24140:
URL: https://github.com/apache/flink/pull/24140#discussion_r1519024028
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowAggregateReduceFunctionsRule.java:
##
@@ -0,0 +1,90 @@
+/*
+
snuyanzin commented on code in PR #24443:
URL: https://github.com/apache/flink/pull/24443#discussion_r1519010699
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/aggfunctions/ModeAggFunctionTest.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed
dchristle commented on PR #84:
URL:
https://github.com/apache/flink-connector-pulsar/pull/84#issuecomment-1987392406
@minchowang I submitted a fix in
https://github.com/apache/flink-connector-pulsar/pull/85 along with a unit test
that reproduces the issue. Replacing `%` with `floorMod` is
dchristle opened a new pull request, #85:
URL: https://github.com/apache/flink-connector-pulsar/pull/85
## Purpose of the change
This PR fixes a bug in partition owner logic returning `-1` for the
partition owner. The subtask ID to which we try to assign a split should always
be
snuyanzin commented on code in PR #24423:
URL: https://github.com/apache/flink/pull/24423#discussion_r1518998032
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ReplaceIntersectWithSemiJoinRule.java:
##
@@ -0,0 +1,96 @@
+/*
+ *
jeyhunkarimov commented on PR #24475:
URL: https://github.com/apache/flink/pull/24475#issuecomment-1987359390
Hi @zhuzhurk could you please review the PR in you available time? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
snuyanzin commented on PR #24449:
URL: https://github.com/apache/flink/pull/24449#issuecomment-1987334698
@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.
dchristle commented on code in PR #84:
URL:
https://github.com/apache/flink-connector-pulsar/pull/84#discussion_r1518922858
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssignerBase.java:
##
@@ -125,11 +127,12 @@ prot
[
https://issues.apache.org/jira/browse/FLINK-34629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34629:
---
Labels: pull-request-available (was: )
> Pulsar source lost topic subscribe
> -
flinkbot commented on PR #24476:
URL: https://github.com/apache/flink/pull/24476#issuecomment-1987316215
## CI report:
* 4c7831ad03b847349fba69fe1d45a35852b5fa6c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
HCTommy commented on PR #24476:
URL: https://github.com/apache/flink/pull/24476#issuecomment-1987315148
Corrected a comment of the [BarrierAlignmentUtilTest.java] file
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
HCTommy opened a new pull request, #24476:
URL: https://github.com/apache/flink/pull/24476
## 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
gyfora commented on PR #791:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/791#issuecomment-1987310999
The new and improved / consistent logging after the rework @mateczagany @mxm
:
```
[INFO ][default/basic-checkpoint-ha-example] >>> Event | Info| CLEANUP
flinkbot commented on PR #24475:
URL: https://github.com/apache/flink/pull/24475#issuecomment-1987262990
## CI report:
* 89fdb18a4980e46c30683675025736b9ce5fd05d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32513:
---
Labels: pull-request-available (was: )
> Job in BATCH mode with a significant number of tra
jeyhunkarimov opened a new pull request, #24475:
URL: https://github.com/apache/flink/pull/24475
## 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 t
gyfora commented on code in PR #791:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/791#discussion_r1518872217
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/NativeFlinkService.java:
##
@@ -356,4 +353,32 @@ public boolean
hejufang commented on code in PR #24322:
URL: https://github.com/apache/flink/pull/24322#discussion_r1518860909
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java:
##
@@ -31,55 +31,86 @@
*/
@Internal
[
https://issues.apache.org/jira/browse/FLINK-32367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825031#comment-17825031
]
Jeyhun Karimov commented on FLINK-32367:
Hi [~zhou_yb] when I tried to reproduce
[
https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825027#comment-17825027
]
Jeyhun Karimov commented on FLINK-33579:
Hi [~waywtdcc] when I tried to reproduc
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Woo updated FLINK-34636:
Description:
Based on the observation of logs and metrics, it was found that a subtask
deployed o
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Woo updated FLINK-34636:
Description:
Based on the observation of logs and metrics, it was found that a subtask
deployed o
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Woo updated FLINK-34636:
Description:
Based on the observation of logs and metrics, it was found that a subtask
deployed o
Vincent Woo created FLINK-34636:
---
Summary: Requesting exclusive buffers timeout causes repeated
restarts and cannot be automatically recovered
Key: FLINK-34636
URL: https://issues.apache.org/jira/browse/FLINK-34636
64 matches
Mail list logo
