[
https://issues.apache.org/jira/browse/FLINK-34562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825154#comment-17825154
]
Vincent Woo commented on FLINK-34562:
-
I'm willing to contribute, could someone assign this to me?
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
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825132#comment-17825132
]
Hongshun Wang commented on FLINK-34634:
---
[~ruanhang1993] , [~renqs] , [~Leonard] , CC
>
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
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
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:
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
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
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=17825131#comment-17825131
]
Jacky Lau commented on FLINK-31663:
---
hi [~snuyanzin] what is your opinion?
> Add ARRAY_EXCEPT
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
[
https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825123#comment-17825123
]
Hangxiang Yu commented on FLINK-29114:
--
master:
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
[
https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825121#comment-17825121
]
LvYanquan commented on FLINK-34585:
---
I am willing to take this.
> [JUnit5 Migration] Module: Flink
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=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=17825119#comment-17825119
]
Sergey Nuyanzin commented on FLINK-34156:
-
the more people the better for the community
may be
Sergey Nuyanzin created FLINK-34637:
---
Summary: Migrate JoinConditionEqualityTransferRule
Key: FLINK-34637
URL: https://issues.apache.org/jira/browse/FLINK-34637
Project: Flink
Issue Type:
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
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 @@
[
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
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
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
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
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=17825031#comment-17825031
]
Jeyhun Karimov commented on FLINK-32367:
Hi [~zhou_yb] when I tried to reproduce with the
[
https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825027#comment-17825027
]
Jeyhun Karimov commented on FLINK-33579:
Hi [~waywtdcc] when I tried to reproduce locally as of
[
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
[
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
[
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
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
61 matches
Mail list logo
