[
https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007720#comment-18007720
]
Shuai Xu edited comment on FLINK-38029 at 7/17/25 6:14 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007720#comment-18007720
]
Shuai Xu commented on FLINK-38029:
--
I have conducted cross testing on FLIP-486,
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description:
Follow up the test for https://issues.apache.org/jira/browse/FLINK-37874
We now support a
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description:
Follow up the test for https://issues.apache.org/jira/browse/FLINK-37874
We now support a
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description:
Follow up the test for https://issues.apache.org/jira/browse/FLINK-37874
We now support a
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description:
Follow up the test for https://issues.apache.org/jira/browse/FLINK-37874
We now support a
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description:
Follow up the test for https://issues.apache.org/jira/browse/FLINK-37874
We now support a
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description: Follow up the test for
https://issues.apache.org/jira/browse/FLINK-37874 (was: Follow up
[
https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-38032:
-
Description: Follow up the test for
https://issues.apache.org/jira/browse/FLINK-37994
> Rele
Shuai Xu created FLINK-38032:
Summary: Release Testing: Verify FLIP-519: Introduce async lookup
key ordered mode
Key: FLINK-38032
URL: https://issues.apache.org/jira/browse/FLINK-38032
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985209#comment-17985209
]
Shuai Xu commented on FLINK-37981:
--
[~xuyangzhong] Sure, I would hava a look at
Shuai Xu created FLINK-37947:
Summary: Add sql hint to enable this optimization
Key: FLINK-37947
URL: https://issues.apache.org/jira/browse/FLINK-37947
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-37921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37921:
-
Description: Current implementation borrows most concepts of FLIP-425 like
Epoch
[
https://issues.apache.org/jira/browse/FLINK-37931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17958633#comment-17958633
]
Shuai Xu commented on FLINK-37931:
--
[~zakelly] FLINK-37901 has f
[
https://issues.apache.org/jira/browse/FLINK-37921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37921:
-
Description: Current implementation borrows most concepts of FLIP-425 like
Epoch
[
https://issues.apache.org/jira/browse/FLINK-37921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37921:
-
Summary: Refactor current implementation to reduce code duplication (was:
Refactor current
Shuai Xu created FLINK-37921:
Summary: Refactor current implementation with implementation in
FLIP-425
Key: FLINK-37921
URL: https://issues.apache.org/jira/browse/FLINK-37921
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37876:
-
Component/s: Table SQL / Runtime
> Introduce key ordered component in runt
Shuai Xu created FLINK-37877:
Summary: Add the key ordered operator in table runtime
Key: FLINK-37877
URL: https://issues.apache.org/jira/browse/FLINK-37877
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-37877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37877:
-
Component/s: Table SQL / Runtime
> Add the key ordered operator in table runt
Shuai Xu created FLINK-37876:
Summary: Introduce key ordered component in runtime
Key: FLINK-37876
URL: https://issues.apache.org/jira/browse/FLINK-37876
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-37875:
Summary: Introduce the option and the support of planner
Key: FLINK-37875
URL: https://issues.apache.org/jira/browse/FLINK-37875
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-37874:
Summary: FLIP-519: Introduce async lookup key ordered mode
Key: FLINK-37874
URL: https://issues.apache.org/jira/browse/FLINK-37874
Project: Flink
Issue Type: New
Shuai Xu created FLINK-37640:
Summary: Type timestamp_ltz is converted timestamp wrongly when
scanreuse
Key: FLINK-37640
URL: https://issues.apache.org/jira/browse/FLINK-37640
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930508#comment-17930508
]
Shuai Xu commented on FLINK-37068:
--
Hi, [~xuyangzhong]. I have tested this accor
[
https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927955#comment-17927955
]
Shuai Xu commented on FLINK-37068:
--
Hi [~xtsong][~xuyangzhong], I would like to as
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913945#comment-17913945
]
Shuai Xu commented on FLINK-36167:
--
I would like try to fix it. Could you assign i
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913945#comment-17913945
]
Shuai Xu edited comment on FLINK-36167 at 1/17/25 3:57 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-36504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912327#comment-17912327
]
Shuai Xu commented on FLINK-36504:
--
Since the code freeze date for flink 2.0.
[
https://issues.apache.org/jira/browse/FLINK-36962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-36962:
-
Description:
Non-deterministic filter after stream join is push down to source by mistake.
Modify the
Shuai Xu created FLINK-36962:
Summary: push down non-deterministic filter after stream join to
source by mistake
Key: FLINK-36962
URL: https://issues.apache.org/jira/browse/FLINK-36962
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-36654:
-
Description:
paste the test code in SqlExpressionTest.
{code:java}
// code placeholder
// Decimal
Shuai Xu created FLINK-36654:
Summary: Decimal divide Integer reports Null pointer exception
Key: FLINK-36654
URL: https://issues.apache.org/jira/browse/FLINK-36654
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846626#comment-17846626
]
Shuai Xu edited comment on FLINK-34380 at 5/16/24 1:5
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846626#comment-17846626
]
Shuai Xu commented on FLINK-34380:
--
Hi [~rovboyko] , sorry for late reply.
For
[
https://issues.apache.org/jira/browse/FLINK-35230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840623#comment-17840623
]
Shuai Xu commented on FLINK-35230:
--
[~lsy] I'd like to take this, would you
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839947#comment-17839947
]
Shuai Xu commented on FLINK-35184:
--
Absolutely, please feel free to start
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839947#comment-17839947
]
Shuai Xu edited comment on FLINK-35184 at 4/23/24 5:4
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839920#comment-17839920
]
Shuai Xu commented on FLINK-35184:
--
Hi [~rovboyko] , actually it can't be a
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839464#comment-17839464
]
Shuai Xu commented on FLINK-35184:
--
Hi [~rovboyko] , thx for reporting this bug w
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835668#comment-17835668
]
Shuai Xu edited comment on FLINK-34694 at 4/10/24 9:4
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835668#comment-17835668
]
Shuai Xu commented on FLINK-34694:
--
Hi [~rovboyko],
The me
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835648#comment-17835648
]
Shuai Xu commented on FLINK-34694:
--
Hi [~rovboyko] , your idea looks interes
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822433#comment-17822433
]
Shuai Xu commented on FLINK-34380:
--
Let me take a look.
> Strange RowKind and
[ 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&focusedCommentId=17819964#comment-17819964
]
Shuai Xu commented on FLINK-34500:
--
Hi, Could I take this verification?
>
[
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&focusedCommentId=17818612#comment-17818612
]
Shuai Xu commented on FLINK-34346:
--
Hi, I have finished this testing. The excepti
[
https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818611#comment-17818611
]
Shuai Xu commented on FLINK-34355:
--
Hi, I have finished this verification.
>
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&focusedCommentId=17818384#comment-17818384
]
Shuai Xu commented on FLINK-34378:
--
Hi [~xuyangzhong] . This is an expected beha
[
https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814193#comment-17814193
]
Shuai Xu edited comment on FLINK-34355 at 2/5/24 7:19 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814193#comment-17814193
]
Shuai Xu commented on FLINK-34355:
--
Hi, I'd like to take this verification.
[
https://issues.apache.org/jira/browse/FLINK-34304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814192#comment-17814192
]
Shuai Xu commented on FLINK-34304:
--
This test is opened in another issue FLINK-3
[ 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 this
[
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&focusedCommentId=17814016#comment-17814016
]
Shuai Xu commented on FLINK-34300:
--
Hi, [~xuyangzhong]. I'd like to
[
https://issues.apache.org/jira/browse/FLINK-34304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814015#comment-17814015
]
Shuai Xu commented on FLINK-34304:
--
Minibatch join is ready. Users could imp
[
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 g
[
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 g
[
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-
[
https://issues.apache.org/jira/browse/FLINK-33549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788967#comment-17788967
]
Shuai Xu edited comment on FLINK-33549 at 11/23/23 3:3
[
https://issues.apache.org/jira/browse/FLINK-33549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788967#comment-17788967
]
Shuai Xu commented on FLINK-33549:
--
I'd like to fix this. Could you assign
[
https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775580#comment-17775580
]
Shuai Xu commented on FLINK-28650:
--
The bug in partial insert with writable meta
[
https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775580#comment-17775580
]
Shuai Xu edited comment on FLINK-28650 at 10/16/23 7:5
[
https://issues.apache.org/jira/browse/FLINK-28866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757169#comment-17757169
]
Shuai Xu commented on FLINK-28866:
--
Hi, I would like to fix this issue. Could i
[
https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756785#comment-17756785
]
Shuai Xu edited comment on FLINK-27741 at 8/21/23 9:5
[
https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756785#comment-17756785
]
Shuai Xu commented on FLINK-27741:
--
Hi, I would like to fix this issue. Could i
[
https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756784#comment-17756784
]
Shuai Xu commented on FLINK-25054:
--
Hi, I would like to fix this issue. Could i
[
https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752618#comment-17752618
]
Shuai Xu commented on FLINK-32824:
--
Hi, lincoln. I‘d like to fix this issue, could
[
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&focusedCommentId=17717082#comment-17717082
]
Shuai Xu commented on FLINK-31956:
--
Hi Jane, I have taken the FLINK-31952 whic
[
https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717031#comment-17717031
]
Shuai Xu edited comment on FLINK-31952 at 4/27/23 7:3
[
https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717031#comment-17717031
]
Shuai Xu commented on FLINK-31952:
--
Hi Jane, I have some ideas for the task and
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 that
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
1 - 100 of 183 matches
Mail list logo
