[
https://issues.apache.org/jira/browse/FLINK-35902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Paryshev updated FLINK-35902:
Description: Displaying metrics with high parallelism causes a RangeError
(similar to Stac
yuanfenghu created FLINK-35903:
--
Summary: Add CentralizedSlotAssigner support to adaptive scheduler
Key: FLINK-35903
URL: https://issues.apache.org/jira/browse/FLINK-35903
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35903:
---
Affects Version/s: 2.0.0
> Add CentralizedSlotAssigner support to adaptive scheduler
> -
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868873#comment-17868873
]
Zhanghao Chen commented on FLINK-35903:
---
[~heigebupahei] Hi，[~RocMarshal] is alrea
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu closed FLINK-35903.
--
Resolution: Duplicate
> Add CentralizedSlotAssigner support to adaptive scheduler
> --
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868874#comment-17868874
]
yuanfenghu commented on FLINK-35903:
[~Zhanghao Chen] thansk, I closed this issue
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868874#comment-17868874
]
yuanfenghu edited comment on FLINK-35903 at 7/26/24 7:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868875#comment-17868875
]
Rui Fan commented on FLINK-35903:
-
I don't think extra SlotAssigner is needed.
Instead,
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868877#comment-17868877
]
yuanfenghu commented on FLINK-35903:
> Instead, all implementations of SlotAssigner
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1692695511
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -83,9 +83,15 @@ public Collection getJobManage
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1692695511
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -83,9 +83,15 @@ public Collection getJobManage
GoGoWen opened a new pull request, #25124:
URL: https://github.com/apache/flink/pull/25124
## 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
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1692705494
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -83,9 +83,15 @@ public Collection getJobManagerRunners() {
flinkbot commented on PR #25124:
URL: https://github.com/apache/flink/pull/25124#issuecomment-2252248628
## CI report:
* 5bff44c0b428581f9ebf78ecd6def65d9bd6f09b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
huyuanfeng2018 opened a new pull request, #856:
URL: https://github.com/apache/flink-kubernetes-operator/pull/856
## What is the purpose of the change
Throw exceptions that occur during the execution of
RescaleApiScalingRealizer so that eventHandler can handle it
##
[
https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35896:
---
Labels: pull-request-available (was: )
> eventHandler in RescaleApiScalingRealizer handle
jectpro7 opened a new pull request, #25125:
URL: https://github.com/apache/flink/pull/25125
## 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
flinkbot commented on PR #25125:
URL: https://github.com/apache/flink/pull/25125#issuecomment-2252280580
## CI report:
* 254d27984cb3258df9d630f6296e122b12a65448 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mateczagany commented on code in PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#discussion_r1692766135
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/snapshot/StateSnapshotReconciler.java:
##
@@ -0,0 +1,230
Zakelly Lan created FLINK-35904:
---
Summary: Test harness for async state processing operators
Key: FLINK-35904
URL: https://issues.apache.org/jira/browse/FLINK-35904
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Anokhovskiy updated FLINK-35899:
---
Description:
One of the sub-task out of 40 of the TumblingProcessingTimeWindows oper
[
https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868913#comment-17868913
]
Sergey Anokhovskiy commented on FLINK-35899:
[~pnowojski] Could you please
[
https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868932#comment-17868932
]
Piotr Nowojski commented on FLINK-35899:
Partially. FLIP-443/FLINK-20217 would h
[
https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868942#comment-17868942
]
Sergey Anokhovskiy commented on FLINK-35899:
[~pnowojski] [~zakelly] Thank
1996fanrui commented on code in PR #856:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/856#discussion_r1693165793
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/realizer/ScalingRealizer.java:
##
@@ -33,8 +33,13 @@
@Experimental
public interface
[
https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868956#comment-17868956
]
Piotr Nowojski commented on FLINK-35899:
{quote}
how flink decides what timers
huyuanfeng2018 commented on code in PR #856:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/856#discussion_r1693213476
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/realizer/ScalingRealizer.java:
##
@@ -33,8 +33,13 @@
@Experimental
public interf
[
https://issues.apache.org/jira/browse/FLINK-34440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868977#comment-17868977
]
David Mariassy commented on FLINK-34440:
Hi there,
I put up a PR for this fe
all-cloudz commented on PR #23563:
URL: https://github.com/apache/flink/pull/23563#issuecomment-2253728764
> Hello, could someone please clarify if this PR requires any further
modifications as the PR is open from quite some time now.
I resolved the conflict with another PR that was m
29 matches
Mail list logo
