[
https://issues.apache.org/jira/browse/FLINK-35230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840623#comment-17840623
]
Shuai Xu commented on FLINK-35230:
--
[~lsy] I'd like to take this, would you assign it to me?
> Sp
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839947#comment-17839947
]
Shuai Xu commented on FLINK-35184:
--
Absolutely, please feel free to start the implementation.
> H
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839947#comment-17839947
]
Shuai Xu edited comment on FLINK-35184 at 4/23/24 5:46 AM:
---
[~rovboyko
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839920#comment-17839920
]
Shuai Xu commented on FLINK-35184:
--
Hi [~rovboyko] , actually it can't be avoid hash collision even
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839464#comment-17839464
]
Shuai Xu commented on FLINK-35184:
--
Hi [~rovboyko] , thx for reporting this bug which is caused
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835668#comment-17835668
]
Shuai Xu edited comment on FLINK-34694 at 4/10/24 9:43 AM:
---
Hi [~rovboyko
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835668#comment-17835668
]
Shuai Xu commented on FLINK-34694:
--
Hi [~rovboyko],
The method
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835648#comment-17835648
]
Shuai Xu commented on FLINK-34694:
--
Hi [~rovboyko] , your idea looks interesting. Actually I found
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822433#comment-17822433
]
Shuai Xu commented on FLINK-34380:
--
Let me take a look.
> Strange RowKind and records ab
[ https://issues.apache.org/jira/browse/FLINK-34500 ]
Shuai Xu deleted comment on FLINK-34500:
--
was (Author: JIRAUSER300096):
Hi, Could I take this verification?
> Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/
[
https://issues.apache.org/jira/browse/FLINK-34500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819964#comment-17819964
]
Shuai Xu commented on FLINK-34500:
--
Hi, Could I take this verification?
> Release Testing: Ver
[
https://issues.apache.org/jira/browse/FLINK-34219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-34219:
-
Release Note: Support minibatch regular join to reduce intermediate result
and resolve record
[
https://issues.apache.org/jira/browse/FLINK-34346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818612#comment-17818612
]
Shuai Xu commented on FLINK-34346:
--
Hi, I have finished this testing. The exception I think could
[
https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818611#comment-17818611
]
Shuai Xu commented on FLINK-34355:
--
Hi, I have finished this verification.
> Release Testing: Ver
Shuai Xu created FLINK-34462:
Summary: Session window with negative parameter throws unclear
exception
Key: FLINK-34462
URL: https://issues.apache.org/jira/browse/FLINK-34462
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818384#comment-17818384
]
Shuai Xu commented on FLINK-34378:
--
Hi [~xuyangzhong] . This is an expected behavior. To maintain order
[
https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814193#comment-17814193
]
Shuai Xu edited comment on FLINK-34355 at 2/5/24 7:19 AM:
--
Hi, I'd like to take
[
https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814193#comment-17814193
]
Shuai Xu commented on FLINK-34355:
--
Hi, I'd like to take this verification.
> Release Testing: Ver
[
https://issues.apache.org/jira/browse/FLINK-34304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814192#comment-17814192
]
Shuai Xu commented on FLINK-34304:
--
This test is opened in another issue FLINK-34349 and this issue
[ https://issues.apache.org/jira/browse/FLINK-34304 ]
Shuai Xu deleted comment on FLINK-34304:
--
was (Author: JIRAUSER300096):
Minibatch join is ready. Users could improve performance in regular stream join
scenarios.
Someone can verify
[
https://issues.apache.org/jira/browse/FLINK-34349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-34349:
-
Description:
Minibatch join is ready. Users could improve performance in regular stream join
scenarios
Shuai Xu created FLINK-34349:
Summary: Release Testing: Verify FLINK-34219 Introduce a new join
operator to support minibatch
Key: FLINK-34349
URL: https://issues.apache.org/jira/browse/FLINK-34349
[
https://issues.apache.org/jira/browse/FLINK-34300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814016#comment-17814016
]
Shuai Xu commented on FLINK-34300:
--
Hi, [~xuyangzhong]. I'd like to take this verification.
> Rele
[
https://issues.apache.org/jira/browse/FLINK-34304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814015#comment-17814015
]
Shuai Xu commented on FLINK-34304:
--
Minibatch join is ready. Users could improve performance in regular
[
https://issues.apache.org/jira/browse/FLINK-34222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-34222:
-
Summary: Supports mini-batch for streaming regular join (was: End to end
implementation of minibatch
[
https://issues.apache.org/jira/browse/FLINK-34222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-34222:
-
Description: Implement minibatch join in E2E which includes both plan and
runtime parts. (was: Get
Shuai Xu created FLINK-34256:
Summary: Add a documentation section for minibatch join
Key: FLINK-34256
URL: https://issues.apache.org/jira/browse/FLINK-34256
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-34222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-34222:
-
Description: Get minibatch join operator involved in which includes both
plan and operator. Implement
Shuai Xu created FLINK-34222:
Summary: Get minibatch join operator involved
Key: FLINK-34222
URL: https://issues.apache.org/jira/browse/FLINK-34222
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-34221:
Summary: Introduce operator for minibatch join
Key: FLINK-34221
URL: https://issues.apache.org/jira/browse/FLINK-34221
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-34220:
Summary: introduce buffer bundle for minibatch join
Key: FLINK-34220
URL: https://issues.apache.org/jira/browse/FLINK-34220
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-34219:
Summary: Introduce a new join operator to support minibatch
Key: FLINK-34219
URL: https://issues.apache.org/jira/browse/FLINK-34219
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-33689:
-
Summary: JsonObjectAggFunction can't retract previous data which is invalid
when enabling local global
[
https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-33689:
-
Summary: JsonObjectAggFunction can't retract previous data which is invalid
when enable local global
[
https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-33689:
-
Description:
Run the test as following and enable LocalGlobal and minibatch in
sql/AggregateITCase
[
https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-33689:
-
Description:
Run the test as following and enable LocalGlobal in sql/AggregateITCase .
{code:java}
def
Shuai Xu created FLINK-33689:
Summary: jsonObjectAggFunction can't retract previous data which
is invalid when enable local global agg
Key: FLINK-33689
URL: https://issues.apache.org/jira/browse/FLINK-33689
[
https://issues.apache.org/jira/browse/FLINK-33549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788967#comment-17788967
]
Shuai Xu edited comment on FLINK-33549 at 11/23/23 3:39 AM:
Hi [~luoyuxia
[
https://issues.apache.org/jira/browse/FLINK-33549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788967#comment-17788967
]
Shuai Xu commented on FLINK-33549:
--
I'd like to fix this. Could you assign it to me? [~luoyuxia
[
https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775580#comment-17775580
]
Shuai Xu commented on FLINK-28650:
--
The bug in partial insert with writable metadata is fixed in FLINK
[
https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775580#comment-17775580
]
Shuai Xu edited comment on FLINK-28650 at 10/16/23 7:58 AM:
This bug
[
https://issues.apache.org/jira/browse/FLINK-28866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757169#comment-17757169
]
Shuai Xu commented on FLINK-28866:
--
Hi, I would like to fix this issue. Could it be assigned to me
[
https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756785#comment-17756785
]
Shuai Xu edited comment on FLINK-27741 at 8/21/23 9:58 AM:
---
Hi [~chenzihao
[
https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756785#comment-17756785
]
Shuai Xu commented on FLINK-27741:
--
Hi, I would like to fix this issue. Could it be assigned to me
[
https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756784#comment-17756784
]
Shuai Xu commented on FLINK-25054:
--
Hi, I would like to fix this issue. Could it be assigned to me
[
https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752618#comment-17752618
]
Shuai Xu commented on FLINK-32824:
--
Hi, lincoln. I‘d like to fix this issue, could you assign it to me
[
https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-32219:
-
Description:
I compiled a plan for an INSERT statement and executed the plan, but the SQL
client
[
https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-32219:
-
Description:
I compiled a plan for an insert statement and then executed the plan. However,
the SQL
[
https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-32219:
-
Affects Version/s: 1.17.1
> sql client would be pending after executing plan of insert
Shuai Xu created FLINK-32219:
Summary: sql client would be pending after executing plan of
inserting
Key: FLINK-32219
URL: https://issues.apache.org/jira/browse/FLINK-32219
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717082#comment-17717082
]
Shuai Xu commented on FLINK-31956:
--
Hi Jane, I have taken the FLINK-31952 which is similar to the task
[
https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717031#comment-17717031
]
Shuai Xu edited comment on FLINK-31952 at 4/27/23 7:31 AM:
---
Hi Jane, I have
[
https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717031#comment-17717031
]
Shuai Xu commented on FLINK-31952:
--
Hi Jane, I have some ideas for the task and this is how I consider
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/6360
[FLINK-9884] [runtime] fix slot request may not be removed when it has
already be assigned in slot manager
## What is the purpose of the change
*(The pull request fix the bug
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5931
@StephanEwen, Good idea, I prefer the first one. As for the second one, the
pending request may have been fulfilled when task executor is killed. so job
master can not cancel the pending request
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5931
@GJL In blink, we solve this problem like this.
When a container complete, we will first whether the container has
registered yet, if it has registered before, RM will not request a new
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5951
[FLINK-9293] [runtime] SlotPool should check slot id when accepting a slot
offer with existing allocation id
## What is the purpose of the change
*This pull request fix that job
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5693
[FLINK-8938] [runtime] not remove job graph during job master failover
## What is the purpose of the change
*This pull request fix a bug that when job master failover, it may delete
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/5190
---
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5190
@tillrohrmann , In fact, the original problem I'm concerned with has been
fix by your commit "[FLINK-8119] [flip6] Wire correct Flip6 components in
Flip6YarnClusterDescriptor",
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5297
[FLINK-8434] Take over the running task manager after yarn app master
failvoer
## What is the purpose of the change
*This pull request makes the yarn resource manager could take over
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2675
---
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2674
---
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5271
@tillrohrmann thank you for reviewing, I have modified it.
---
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5190
@tillrohrmann @EronWright , this make it more clear, but seems not solve
the problem completely. Since we need to set RestOptions#ADDRESS to the address
of a rest server so the client can access
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5170
@tillrohrmann sorry, the conflict is resolved now
---
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/5186
@NicoK , thank you for reviewing, I have adjusted the indent.
---
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5271
[FLINK-8399] [runtime] use independent configurations for the different
timeouts in slot manager
## What is the purpose of the change
*This pull request separate the timeouts
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5190#discussion_r158627004
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java
---
@@ -155,6 +156,7 @@ protected void runCluster
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5190
[FLINK-8289] [runtime] set the rest.address to the host of the rest server
machine
## What is the purpose of the change
This pull request set the rest.address to the host
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5186
[FLINK-8288] [runtime] register job master rest endpoint url to yarn
## What is the purpose of the change
This pull request pass the endpoint url of job master rest server
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5170
[FLINK-8266] [runtime] add network memory to ResourceProfile for the input
and output memory of a task
## What is the purpose of the change
This pull request adds a network memory
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4991#discussion_r156848154
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -52,6 +63,15 @@
/** How many
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5139
[FLINK-8224] [runtime] shutdown application when job terminated in job mode
## What is the purpose of the change
This current job cluster entrypoint doesn't call resource manage
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4991#discussion_r155708446
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -61,16 +80,26 @@
* @param
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
@tillrohrmann , I agree with you that adding a build looks better, I
changed it according to your comments. Do you think it works now?
---
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4988
This pr is very helpful for us. Thank you. I have tried it on our cluster
with yarn job modeï¼and it works well. My only suggestion is to change the
default value of rest.address to 0.0.0.0
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4985#discussion_r153708910
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGateway.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/4991
[FLINK-7928] [runtime] extend the resources in ResourceProfile for
precisely calculating the resource of task manager
Notes: this pull request contains the #4911 since it depends
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
@tillrohrmann, I make the Resource abstract and add GPUResource and
FPGAResource, so user can only add such defined resources, how about it?
---
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4911#discussion_r149610252
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java
---
@@ -61,18 +79,17 @@
/** How many state size in mb
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
@tillrohrmann, There is not a generic way for both Yarn and Mesos, as their
resource allocation interface are different. I think the YARN/MESOS resource
manager should handle it in their own way
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
@tillrohrmann, Yes, the Resource is a little too generic and prone to
typos. However, the resource are various and closely related to the
platform(YARN/MESOS), only a GPUResource and FPGAResource
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4937#discussion_r148718854
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotPool.java ---
@@ -262,23 +263,36 @@ public void disconnectResourceManager
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4887#discussion_r148716173
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -874,6 +894,13 @@ public void handleError(final
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4887#discussion_r148715689
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceActions.java
---
@@ -52,4 +52,6 @@
* @param
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4887#discussion_r148715651
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -302,7 +302,12 @@ public boolean
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/4937
[FLINK-6434] [runtime] cancel slot allocation if request timed out in
ProviderAndOwner
## What is the purpose of the change
This pr adds a cancel slot allocation protocol between
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/3398
---
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
I run the failed test on my machine and it pass, and it seems my changes
will not influence it.
---
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/4911
[FLINK-7878] [api] make resource type extendible in ResourceSpec
Summary:
Now, flink only support user define CPU and MEM,
but some user need to specify the GPU, FPGA and so on resources
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4887
@tillrohrmann could you help to review this pr? Thank you.
---
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/4887
[FLINK-7870] [runtime] Cancel slot allocation to RM when requestSlot timed
out in SlotPool
## What is the purpose of the change
This pull request add a cancelSlotRequest rpc protocol
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/3580
@tillrohrmann Could you please help to review this pr? And there is a
question, the pending requests in slot managers are not in order. So requests
arrived later may be fulfilled earlier, does
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/3398
@tillrohrmann , sorry to reply late. I will modify it according to your
comments in one week.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/3539
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/3755
There will soon be a YarnFlinkAppMaster extends
AbstractYarnFlinkApplicationMasterRunner for flink yarn cluster mode, so need
not combine them to one class.
---
If your project is set up
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/3773#discussion_r113361061
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/FailoverRegion.java
---
@@ -0,0 +1,251 @@
+/*
+ * Licensed
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/3580
[FLINK-5791] Support an optimal matching based slot manager for flip6 yarn
mode
This pr is for
jira-#[5791](https://issues.apache.org/jira/browse/FLINK-5791)
Main changes:
1. Add
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/3304
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
1 - 100 of 148 matches
Mail list logo
