Matthias Pohl created FLINK-34225:
-
Summary: HybridShuffleITCase.testHybridSelectiveExchangesRestart
failed due to RPC issue
Key: FLINK-34225
URL: https://issues.apache.org/jira/browse/FLINK-34225
Pro
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34225:
--
Attachment: FLINK-34225.log
> HybridShuffleITCase.testHybridSelectiveExchangesRestart failed d
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34225:
--
Summary: HybridShuffleITCase.testHybridSelectiveExchangesRestart failed due
to NullPointerExce
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810252#comment-17810252
]
Matthias Pohl commented on FLINK-34225:
---
I attached the logs of the test failure t
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34225:
--
Component/s: Runtime / Network
(was: Runtime / Coordination)
> HybridShuf
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34225:
--
Priority: Blocker (was: Critical)
> HybridShuffleITCase.testHybridSelectiveExchangesRestart f
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810254#comment-17810254
]
Matthias Pohl commented on FLINK-34225:
---
I'm raising this as a blocker because it'
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810254#comment-17810254
]
Matthias Pohl edited comment on FLINK-34225 at 1/24/24 8:15 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34225:
--
Description:
This test failed in a master nightly workflow run in GitHub Actions
([FLIP-396|h
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34225:
--
Description:
This test failed in a master nightly workflow run in GitHub Actions
([FLIP-396|h
JunRuiLee commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907622959
@mayuehappy I noticed that the creation of the CheckpointCoordinator
currently depends on the isCheckpointingEnabled condition. This implies that if
we disable checkpointing, the entire
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-34007:
-
Assignee: Matthias Pohl
> Flink Job stuck in suspend state after losing leadership in H
xiangforever2014 commented on code in PR #24058:
URL: https://github.com/apache/flink/pull/24058#discussion_r1464515517
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java:
##
@@ -163,14 +163,16 @@ public static SavepointRestoreSettings
xiangforever2014 commented on PR #24058:
URL: https://github.com/apache/flink/pull/24058#issuecomment-1907643393
> Thanks for the pr. PTAL my comments. BTW, Could we also provide a UT to
verify this ?
Sorry to reply so late, I have refactor the code according to your comments,
and ad
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810038#comment-17810038
]
Matthias Pohl edited comment on FLINK-34007 at 1/24/24 8:37 AM:
--
1996fanrui commented on code in PR #757:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/757#discussion_r1464522145
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoscalerEventUtils.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache So
mayuehappy commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907651213
@JunRuiLee Thanks for joining the disscussion .
> the PR skips the creation of the checkpoint coordinator when disabling the
checkpoint scheduling
Yes, actually I think that's
xuyangzhong commented on PR #23505:
URL: https://github.com/apache/flink/pull/23505#issuecomment-1907653922
@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-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810280#comment-17810280
]
Yunfeng Zhou commented on FLINK-34225:
--
Hi [~mapohl] thanks for raising this bug. I
[
https://issues.apache.org/jira/browse/FLINK-33683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810282#comment-17810282
]
xiangyu feng commented on FLINK-33683:
--
[~guoyangze] Hi, this
Flip(https://cwiki.
[
https://issues.apache.org/jira/browse/FLINK-33683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-33683:
--
Assignee: xiangyu feng
> FLIP-407 Improve Flink Client performance in interactive scenarios
>
leonardBang merged PR #24120:
URL: https://github.com/apache/flink/pull/24120
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34117:
---
Affects Version/s: 1.18.1
> CompactCoordinator for table file sink loses data upon job termination
>
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34117:
---
Component/s: Connectors / FileSystem
> CompactCoordinator for table file sink loses data upon job te
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34117:
---
Fix Version/s: 1.19.0
> CompactCoordinator for table file sink loses data upon job termination
> ---
xiangyu feng created FLINK-34226:
Summary: Add the backoff-multiplier configuration in
ExponentialBackoffRetryStrategy
Key: FLINK-34226
URL: https://issues.apache.org/jira/browse/FLINK-34226
Project:
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810283#comment-17810283
]
Leonard Xu commented on FLINK-34117:
master: 1d0f34e5a4a9127724bd09ecd0d9c0c0dba431f
JunRuiLee commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1464545618
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -408,4 +431,104 @@ private T loadClass(
throw new Ill
xjmdoo commented on code in PR #24156:
URL: https://github.com/apache/flink/pull/24156#discussion_r1464565498
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java:
##
@@ -1174,6 +1174,107 @@ public static String toBase64
WencongLiu commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907709816
@mayuehappy The key point is that if the users set the job with streaming
execution mode and set the checkpoint-interval with Long.MAX_VALUE, the
savepoint will be not supported at all
JunRuiLee commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907724157
> @JunRuiLee Thanks for joining the disscussion .
>
> > the PR skips the creation of the checkpoint coordinator when disabling
the checkpoint scheduling
>
> Yes, actually I
reswqa commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1464593996
##
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java:
##
@@ -255,6 +256,51 @@ public class PipelineOptions {
pvary commented on code in PR #24180:
URL: https://github.com/apache/flink/pull/24180#discussion_r1464617858
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java:
##
@@ -307,6 +313,14 @@ public AsyncSinkWriter(
pvary commented on PR #24180:
URL: https://github.com/apache/flink/pull/24180#issuecomment-1907753610
The `AsyncFlinkWriter` changes are not covered by the FLIP-372, but they are
need to follow the same deprecation patterns for the writer interface so the
API is consistent.
--
This i
gyfora merged PR #24174:
URL: https://github.com/apache/flink/pull/24174
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-34208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34208.
--
Fix Version/s: 1.19.0
Assignee: Peter Vary
Resolution: Fixed
merged to master 2cf213ec
LB-Yu commented on code in PR #24104:
URL: https://github.com/apache/flink/pull/24104#discussion_r1464624954
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchPhysicalLookupJoinRule.scala:
##
@@ -73,7 +75,19 @@ object
LB-Yu commented on code in PR #24104:
URL: https://github.com/apache/flink/pull/24104#discussion_r1464627984
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,6 +326,17 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data from the
Cu
LB-Yu commented on code in PR #24104:
URL: https://github.com/apache/flink/pull/24104#discussion_r1464628624
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,6 +326,17 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data from the
Cu
xuyangzhong commented on PR #23505:
URL: https://github.com/apache/flink/pull/23505#issuecomment-1907771837
@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
BIOINSu commented on code in PR #24128:
URL: https://github.com/apache/flink/pull/24128#discussion_r1464639516
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformationWrapper.java:
##
@@ -0,0 +1,72 @@
+/*
+Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810300#comment-17810300
]
Yunhong Zheng commented on FLINK-34147:
---
Hi, [~lirui] . I also think it ambiguous.
BIOINSu commented on code in PR #24128:
URL: https://github.com/apache/flink/pull/24128#discussion_r1464649772
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.xml:
##
@@ -727,4 +727,60 @@ Calc(select=[ts, a, b],
ferenc-csaky commented on code in PR #24065:
URL: https://github.com/apache/flink/pull/24065#discussion_r1464653979
##
docs/layouts/shortcodes/generated/artifact_fetch_configuration.html:
##
@@ -0,0 +1,36 @@
+
+
+
+Key
+Default
+Ty
X-czh commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1464658457
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -352,6 +361,20 @@ public void configure(ReadableConfig configuration,
[
https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810313#comment-17810313
]
Stefan Richter commented on FLINK-34218:
Hi, I also cannot reproduce the problem
reswqa opened a new pull request, #24187:
URL: https://github.com/apache/flink/pull/24187
## 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
[
https://issues.apache.org/jira/browse/FLINK-34204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34204:
---
Labels: pull-request-available (was: )
> Dispatch legacy serializer related methods in Exec
XComp opened a new pull request, #24188:
URL: https://github.com/apache/flink/pull/24188
## What is the purpose of the change
The name {{AkkaOptions}} is wrong after replacing Akka with Apache Pekko in
FLINK-32468. The new options should be named more generically to avoid running
int
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32684:
---
Labels: 2.0-related pull-request-available (was: 2.0-related)
> Renaming AkkaOptions into P
flinkbot commented on PR #24187:
URL: https://github.com/apache/flink/pull/24187#issuecomment-1907857611
## CI report:
* f2e9c8652fa9b9f71867d913ebc61843b1de03a7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Summary: Renaming AkkaOptions into RpcOptions (was: Renaming AkkaOptions
into PekkoOptions)
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32684:
-
Assignee: Matthias Pohl
> Renaming AkkaOptions into PekkoOptions
>
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810319#comment-17810319
]
Matthias Pohl commented on FLINK-32684:
---
I'm working on that one now. I decided ag
JunRuiLee commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1464718228
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -352,6 +361,20 @@ public void configure(ReadableConfig configuratio
flinkbot commented on PR #24188:
URL: https://github.com/apache/flink/pull/24188#issuecomment-1907874885
## CI report:
* 7e95ca97cb6a0b2d8f04c08dee403927efe77c8e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mayuehappy commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907878203
@JunRuiLee @WencongLiu Thanks for replying
> In my opinion, disabling checkpoints does not necessarily equate to
disabling savepoints or other functionalities of the Checkpoint
1996fanrui commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1464567468
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache Soft
1996fanrui merged PR #761:
URL: https://github.com/apache/flink-kubernetes-operator/pull/761
--
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
KarmaGYZ opened a new pull request, #24189:
URL: https://github.com/apache/flink/pull/24189
## 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-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810330#comment-17810330
]
Rui Fan commented on FLINK-33287:
-
Merged to main(1.9.0) via : ca5587445e1cde945e26bd6aa
[
https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33287.
-
Fix Version/s: kubernetes-operator-1.8.0
Resolution: Fixed
> Using the flink shaded jackson for f
jiangxin369 commented on code in PR #23851:
URL: https://github.com/apache/flink/pull/23851#discussion_r1464734165
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/CreditBasedInputBuffersUsageGauge.java:
##
@@ -28,27 +31,35 @@
*/
public class CreditB
[
https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810330#comment-17810330
]
Rui Fan edited comment on FLINK-33287 at 1/24/24 10:55 AM:
---
Me
flinkbot commented on PR #24189:
URL: https://github.com/apache/flink/pull/24189#issuecomment-1907898418
## CI report:
* 0faeb94bea8f83cf2aa8c533ccf936edd66a6249 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464755151
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/UnalignedWindowTableFunctionOperator.java:
##
@@ -0,0
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464763918
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/UnalignedWindowTableFunctionOperator.java:
##
@@ -0,0
X-czh commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1464765997
##
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java:
##
@@ -255,6 +256,51 @@ public class PipelineOptions {
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464766029
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/WindowTableFunctionITCase.scala:
##
@@ -1327,4 +1328,146 @@ class
xishuaidelin commented on code in PR #24159:
URL: https://github.com/apache/flink/pull/24159#discussion_r1464767224
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/bundle/InputSideHasNoUniqueKeyBundle.java:
##
@@ -0,0 +1,145
xishuaidelin commented on code in PR #24159:
URL: https://github.com/apache/flink/pull/24159#discussion_r1464767765
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/bundle/BufferBundle.java:
##
@@ -0,0 +1,86 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-34220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34220:
---
Labels: pull-request-available (was: )
> introduce buffer bundle for minibatch join
> -
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464769669
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/agg/WindowAggregateTest.xml:
##
@@ -2170,6 +2360,386 @@ Sink(ta
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464774215
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/agg/WindowAggregateTest.xml:
##
@@ -1186,6 +1186,196 @@ Calc(se
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464774651
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/agg/WindowAggregateTest.xml:
##
@@ -1186,6 +1186,196 @@ Calc(se
echauchot commented on code in PR #24021:
URL: https://github.com/apache/flink/pull/24021#discussion_r1464780022
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -310,22 +312,25 @@ static class Factory implements StateFactory {
X-czh commented on code in PR #24129:
URL: https://github.com/apache/flink/pull/24129#discussion_r1464784119
##
docs/layouts/shortcodes/generated/pipeline_configuration.html:
##
@@ -56,6 +56,12 @@
Boolean
If enabled, forces TypeExtractor to use Kryo ser
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810338#comment-17810338
]
Ferenc Csaky commented on FLINK-32315:
--
Hi! I wrapped up the work on FLINK-28915 an
X-czh commented on code in PR #24129:
URL: https://github.com/apache/flink/pull/24129#discussion_r1464796642
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/DataTypeFactoryImpl.java:
##
@@ -141,6 +141,16 @@ private static Supplier
createSerializ
echauchot commented on code in PR #24021:
URL: https://github.com/apache/flink/pull/24021#discussion_r1464780022
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -310,22 +312,25 @@ static class Factory implements StateFactory {
[
https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810339#comment-17810339
]
Yunhong Zheng commented on FLINK-34016:
---
Hi, [~wczhu] , I cann't reproduce this er
[
https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810347#comment-17810347
]
Rui Li commented on FLINK-34147:
I think having two separate classes is fine, but it mig
xishuaidelin commented on code in PR #24160:
URL: https://github.com/apache/flink/pull/24160#discussion_r1464818953
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/StreamingMiniBatchJoinOperatorTest.java:
##
@@ -0,0 +1,1667 @
Matthias Pohl created FLINK-34227:
-
Summary: ResourceRequirements couldn't be matched in
WindowDistinctAggregateITCase with AdaptiveScheduler causing a timeout
Key: FLINK-34227
URL: https://issues.apache.org/jira/
BIOINSu commented on code in PR #24128:
URL: https://github.com/apache/flink/pull/24128#discussion_r1464827047
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java:
##
@@ -105,54 +117,131 @@ protect
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34227:
--
Summary: WindowDistinctAggregateITCase with AdaptiveScheduler times out
(was: ResourceRequire
zhuzhurk commented on code in PR #24186:
URL: https://github.com/apache/flink/pull/24186#discussion_r1464840583
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/FileSourceTextLinesITCase.java:
##
@@ -126,8 +127,9 @@ private void testBou
WencongLiu commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1908029486
Thanks @mayuehappy . In adaptive batch scenarios, the creation of a
CheckpointCoordinator is definitely not necessary. In other scenarios, we may
need to further sort out whether we ne
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810357#comment-17810357
]
Matthias Pohl commented on FLINK-34227:
---
There are several test failures in {{Wind
xiangforever2014 commented on PR #24058:
URL: https://github.com/apache/flink/pull/24058#issuecomment-1908037053
@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 c
zhuzhurk commented on code in PR #24184:
URL: https://github.com/apache/flink/pull/24184#discussion_r1464845836
##
docs/content/docs/deployment/elastic_scaling.md:
##
@@ -230,6 +230,22 @@ In addition, there are several related configuration
options that may need adjus
- Set
Peter Vary created FLINK-34228:
--
Summary: Add long UTF serializer/deserializer
Key: FLINK-34228
URL: https://issues.apache.org/jira/browse/FLINK-34228
Project: Flink
Issue Type: Improvement
XComp commented on PR #23970:
URL: https://github.com/apache/flink/pull/23970#issuecomment-1908054230
* [This force
push](https://github.com/apache/flink/compare/2d8452c5abe034a48df6b08eabd1e7088f54c1d4..1557192d0ed323a1265d11512384f720ae3bc268)
updates the workflow name to include `(beta)`
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810366#comment-17810366
]
Matthias Pohl commented on FLINK-34227:
---
:facepalm: The test run was cancelled bec
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34227:
--
Summary: table stage timed out (was: WindowDistinctAggregateITCase with
AdaptiveScheduler tim
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34227:
--
Summary: Github Actions: table stage timed out in AdaptiveScheduler profile
(was: table stage
lsyldliu commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464871853
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/WindowTableFunctionITCase.scala:
##
@@ -1327,4 +1328,146 @@ class Wi
lsyldliu commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464873767
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/UnalignedWindowTableFunctionOperator.java:
##
@@ -0,0 +1,
lsyldliu commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1464873767
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/UnalignedWindowTableFunctionOperator.java:
##
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810373#comment-17810373
]
Matthias Pohl commented on FLINK-34227:
---
Ok, {{WindowDistinctAggregateITCase}} see
1 - 100 of 266 matches
Mail list logo
