[
https://issues.apache.org/jira/browse/FLINK-28612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28612:
---
Assignee: Zhu Zhu
> Cancel pending slot allocation after canceling executions
> ---
Zhu Zhu created FLINK-28610:
---
Summary: Enable speculative execution of sources
Key: FLINK-28610
URL: https://issues.apache.org/jira/browse/FLINK-28610
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-28586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28586:
---
Assignee: Zhu Zhu
> Speculative execution for new sources
> -
>
Zhu Zhu created FLINK-28586:
---
Summary: Speculative execution for new sources
Key: FLINK-28586
URL: https://issues.apache.org/jira/browse/FLINK-28586
Project: Flink
Issue Type: Sub-task
Co
Zhu Zhu created FLINK-28585:
---
Summary: Speculative execution for InputFormat sources
Key: FLINK-28585
URL: https://issues.apache.org/jira/browse/FLINK-28585
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28547:
---
Assignee: Lijie Wang
> Add IT cases for SpeculativeScheduler
>
[
https://issues.apache.org/jira/browse/FLINK-28137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28137.
---
Resolution: Done
Done via
81c739ae462412e531216bb46bc567fce2355dd8
265612c2cf93a589d87d7fc8ca168bc19d838885
[
https://issues.apache.org/jira/browse/FLINK-28138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28138:
---
Assignee: Zhu Zhu
> Add metrics for speculative execution
> -
>
[
https://issues.apache.org/jira/browse/FLINK-28402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28402.
---
Resolution: Done
Done via edd10a1d8fd09f8a5e296ecdf0201945d77d5ff2
> Create FailureHandlingResultSnapshot w
[
https://issues.apache.org/jira/browse/FLINK-28144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28144.
---
Fix Version/s: 1.16.0
Resolution: Done
Done via:
f2f83e1956eccecaa2371b21bddaf7778bb4f819
04f2f0c2660
[
https://issues.apache.org/jira/browse/FLINK-28402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28402:
---
Assignee: Zhu Zhu
> Create FailureHandlingResultSnapshot with the truly failed execution
>
[
https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28392.
---
Resolution: Fixed
Fixed via e5c4e3f519f364b5951e7cac331eb8af48f0ed84
> RemoveCachedShuffleDescriptorTest#te
[
https://issues.apache.org/jira/browse/FLINK-28391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28391.
---
Resolution: Fixed
Fixed via 2bd8c209df72679684aeb493c6df03a167fbd2f6
> DefaultBlocklistHandlerTest.testRemo
[
https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563009#comment-17563009
]
Zhu Zhu edited comment on FLINK-28392 at 7/6/22 7:25 AM:
-
Thanks
[
https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563012#comment-17563012
]
Zhu Zhu commented on FLINK-28392:
-
#20178 is created to fix this problem as proposed abo
[
https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563009#comment-17563009
]
Zhu Zhu commented on FLINK-28392:
-
Thanks for reporting this issue and investigating it.
Zhu Zhu created FLINK-28402:
---
Summary: Create FailureHandlingResultSnapshot with the truly
failed execution
Key: FLINK-28402
URL: https://issues.apache.org/jira/browse/FLINK-28402
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-28137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28137:
---
Assignee: Zhu Zhu
> Introduce SpeculativeScheduler
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28143.
---
Fix Version/s: 1.16.0
Resolution: Done
Done via
57f1b6e508159cb40b60ef34d58f29044c88286c
b174deec0155
[
https://issues.apache.org/jira/browse/FLINK-28271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28271.
---
Resolution: Done
Done via 2aae49748350806a8523b3b0d95b6f795a9327f0
> Add configuration options for speculat
[
https://issues.apache.org/jira/browse/FLINK-28134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28134.
---
Resolution: Done
Done via
b96d476d4cd05de1e6c0b001f2477aaed98bd473
e73225e4071fb7ffe7c4d5cbfd89983129fe3312
[
https://issues.apache.org/jira/browse/FLINK-28142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28142.
---
Fix Version/s: 1.16.0
Resolution: Done
Done via:
51c139b601806cc4f4272fb678f4d1bed4cf06ab
eab0a1faf5e
[
https://issues.apache.org/jira/browse/FLINK-28136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28136.
---
Resolution: Done
Done via ef07590403ad7448a523ef5da78da0306cccdae7
> Implement ExecutionTimeBasedSlowTaskDe
[
https://issues.apache.org/jira/browse/FLINK-28135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28135.
---
Resolution: Done
Done via a0e8818d6967e5b0d14367d2095c91a05cadfe1f
> Introduce SlowTaskDetector
> -
[
https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561237#comment-17561237
]
Zhu Zhu commented on FLINK-28324:
-
Thanks for volunteering to take it. [~Leo Zhou]
I hav
[
https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28324:
---
Assignee: zl
> JUnit5 Migration] Module: flink-sql-client
> ---
[
https://issues.apache.org/jira/browse/FLINK-28213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28213.
---
Resolution: Done
Done via 065018dde64a10e8a4cf0ba296e2851a6867871c
> StreamExecutionEnvironment configure m
Title: Message Title
Zhu Zhu closed an iss
Title: Message Title
Zhu Zhu created an is
Title: Message Title
Zhu Zhu assigned an i
Title: Message Title
Zhu Zhu commented on
Title: Message Title
Zhu Zhu created an is
Zhu Zhu created FLINK-28258:
---
Summary: Introduce ExecutionHistory to host historical executions
for each execution vertex
Key: FLINK-28258
URL: https://issues.apache.org/jira/browse/FLINK-28258
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-28258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28258:
---
Assignee: Zhu Zhu
> Introduce ExecutionHistory to host historical executions for each execution
>
[
https://issues.apache.org/jira/browse/FLINK-28193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28193.
---
Resolution: Done
Done via cef491eab34f904cf67f8a0392d48c03def249ff
> Enable to identify whether a job verte
[
https://issues.apache.org/jira/browse/FLINK-28133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28133.
---
Resolution: Done
Done via c66101d518615ec2d6a36c829568583a6a5d93f9
> Rework DefaultScheduler to directly de
Zhu Zhu created FLINK-28193:
---
Summary: Enable to identify whether a job vertex contains
source/sink operators
Key: FLINK-28193
URL: https://issues.apache.org/jira/browse/FLINK-28193
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28193:
---
Assignee: Zhu Zhu
> Enable to identify whether a job vertex contains source/sink operators
> --
[
https://issues.apache.org/jira/browse/FLINK-28146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28146:
---
Assignee: Lijie Wang
> Sync blocklist information between JobMaster & ResourceManager
> ---
[
https://issues.apache.org/jira/browse/FLINK-28143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28143:
---
Assignee: Lijie Wang
> Introduce BlocklistHandler
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28145:
---
Assignee: Lijie Wang
> Let ResourceManager support blocklist mechanism
> --
[
https://issues.apache.org/jira/browse/FLINK-28144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28144:
---
Assignee: Lijie Wang
> Let JobMaster support blocklist mechanism
>
[
https://issues.apache.org/jira/browse/FLINK-28142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28142:
---
Assignee: Lijie Wang
> Enrich TaskManagerLocation with node information
> -
[
https://issues.apache.org/jira/browse/FLINK-28130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28130:
---
Assignee: Lijie Wang
> FLIP-224: Blocklist Mechanism
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557207#comment-17557207
]
Zhu Zhu commented on FLINK-27832:
-
https://dev.azure.com/apache-flink/98463496-1af2-4620
[
https://issues.apache.org/jira/browse/FLINK-28134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28134:
---
Assignee: Zhu Zhu
> Introduce SpeculativeExecutionVertex
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-28136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28136:
---
Assignee: wangwj
> Implement ExecutionTimeBasedSlowTaskDetector
> -
[
https://issues.apache.org/jira/browse/FLINK-28135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28135:
---
Assignee: wangwj
> Introduce SlowTaskDetector
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-28133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28133:
---
Assignee: Zhu Zhu
> Rework DefaultScheduler to directly deploy executions
> ---
Zhu Zhu created FLINK-28139:
---
Summary: Add documentation for speculative execution
Key: FLINK-28139
URL: https://issues.apache.org/jira/browse/FLINK-28139
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28138:
---
Summary: Add metrics for speculative execution
Key: FLINK-28138
URL: https://issues.apache.org/jira/browse/FLINK-28138
Project: Flink
Issue Type: Sub-task
Co
Zhu Zhu created FLINK-28137:
---
Summary: Introduce SpeculativeScheduler
Key: FLINK-28137
URL: https://issues.apache.org/jira/browse/FLINK-28137
Project: Flink
Issue Type: Sub-task
Component
Zhu Zhu created FLINK-28136:
---
Summary: Implement ExecutionTimeBasedSlowTaskDetector
Key: FLINK-28136
URL: https://issues.apache.org/jira/browse/FLINK-28136
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-28135:
---
Summary: Introduce SlowTaskDetector
Key: FLINK-28135
URL: https://issues.apache.org/jira/browse/FLINK-28135
Project: Flink
Issue Type: Sub-task
Reporter: Z
Zhu Zhu created FLINK-28134:
---
Summary: Introduce SpeculativeExecutionVertex
Key: FLINK-28134
URL: https://issues.apache.org/jira/browse/FLINK-28134
Project: Flink
Issue Type: Sub-task
Com
Zhu Zhu created FLINK-28133:
---
Summary: Rework DefaultScheduler to directly deploy executions
Key: FLINK-28133
URL: https://issues.apache.org/jira/browse/FLINK-28133
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556334#comment-17556334
]
Zhu Zhu commented on FLINK-10644:
-
The
[FLIP|https://cwiki.apache.org/confluence/displa
[
https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28131:
---
Assignee: Zhu Zhu
> FLIP-168: Speculative Execution for Batch Job
> ---
Zhu Zhu created FLINK-28131:
---
Summary: FLIP-168: Speculative Execution for Batch Job
Key: FLINK-28131
URL: https://issues.apache.org/jira/browse/FLINK-28131
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28105.
---
Resolution: Fixed
Fixed via 44b941557e131ea03486ba5324232fe7b421a6c4
> We should test the copied object in
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555467#comment-17555467
]
Zhu Zhu commented on FLINK-28105:
-
Thanks for reporting this problem! [~Leo Zhou]
The
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28105:
---
Assignee: zl
> We should test the copied object in
> GlobFilePathFilterTest#testGlobFilterSerializ
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28105:
Affects Version/s: 1.14.4
1.15.0
1.16.0
> We should test the
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28105:
Fix Version/s: 1.16.0
> We should test the copied object in
> GlobFilePathFilterTest#testGlobFilterSerial
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28105:
Component/s: Tests
(was: API / Core)
> We should test the copied object in
> GlobFil
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28018.
---
Fix Version/s: 1.15.1
(was: 1.15.2)
Resolution: Fixed
Fixed via:
master: 0cf8
[
https://issues.apache.org/jira/browse/FLINK-27658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-27658.
---
Assignee: dalongliu
Resolution: Fixed
Done via:
2e37a06368596ca9ed04366a879f2facfb7ef509
> FlinkUser
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27944:
Fix Version/s: 1.15.2
(was: 1.15.1)
> IO metrics collision happens if a task has un
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28018:
---
Assignee: zl
> the start index to create empty splits in BinaryInputFormat#createInputSplits
> is
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553484#comment-17553484
]
Zhu Zhu commented on FLINK-28018:
-
I have assigned you the ticket. Feel free to open a f
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28018:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
(was: API / Core)
> the
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28018:
Affects Version/s: 1.14.4
1.15.0
1.16.0
> the start index to
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28018:
Fix Version/s: 1.16.0
1.15.2
> the start index to create empty splits in BinaryInputFor
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553479#comment-17553479
]
Zhu Zhu commented on FLINK-28018:
-
Yes it is a bug. Thanks for reporting this! [~Leo Zho
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27944:
Fix Version/s: 1.15.1
> IO metrics collision happens if a task has union inputs
>
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551665#comment-17551665
]
Zhu Zhu commented on FLINK-27710:
-
Thanks for the comments. [~xtsong]
I think your con
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551657#comment-17551657
]
Zhu Zhu commented on FLINK-27791:
-
Good catch!
> KerberosDelegationTokenManagerTest sta
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27710:
Description:
Currently, an execution is usually represented as "{{{}job vertex name{}}}
({{{}subtaskIndex
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27710:
Description:
Currently, an execution is usually represented as "{{{}job vertex name{}}}
({{{}subtaskIndex
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27944:
Summary: IO metrics collision happens if a task has union inputs (was: IO
metric collision happens when a
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27710:
Description:
Currently, an execution is usually represented as "{{{}job vertex name{}}}
({{{}subtaskIndex
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-27791:
-
> SlotCountExceedingParallelismTest tests failed with
> NoResourceAvailableException
>
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27944:
Description:
When a task has union inputs, some IO metrics(numBytesIn* and numBuffersIn*) of
the differen
Zhu Zhu created FLINK-27944:
---
Summary: IO metric collision happens when a task has union inputs
Key: FLINK-27944
URL: https://issues.apache.org/jira/browse/FLINK-27944
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27710:
Description:
Currently, an execution is usually represented as "{{{}job vertex name{}}}
({{{}subtaskIndex
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27710:
Description:
Currently, an execution is usually represented as "{{{}job vertex name{}}}
({{{}subtaskIndex
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27710:
Description:
Currently, an execution is usually represented as "{{{}job vertex name{}}}
({{{}subtaskIndex
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550769#comment-17550769
]
Zhu Zhu commented on FLINK-27791:
-
[~wangyang0918] do you have any idea of this problem?
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545267#comment-17545267
]
Zhu Zhu commented on FLINK-27791:
-
The slot allocation timeout happened because the reso
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-27791.
---
Resolution: Not A Bug
> SlotCountExceedingParallelismTest tests failed with
> NoResourceAvailableException
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27791:
Attachment: error.log
> SlotCountExceedingParallelismTest tests failed with
> NoResourceAvailableExceptio
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544246#comment-17544246
]
Zhu Zhu commented on FLINK-27791:
-
I will take a look.
> SlotCountExceedingParallelismT
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17295.
---
Resolution: Done
Merged into master:
061df0ba8f2cd4b4e6436ebde1bc249bc629e940
1f101edd174c5f9b743bd3128a9f
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17295:
Fix Version/s: 1.16.0
> Refactor the ExecutionAttemptID to consist of ExecutionVertexID and
> attemptNumb
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914
]
Zhu Zhu edited comment on FLINK-17295 at 5/20/22 4:31 AM:
--
I wa
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-27710:
---
Assignee: Zhu Zhu
> Improve logs to better display Execution
>
Zhu Zhu created FLINK-27710:
---
Summary: Improve logs to better display Execution
Key: FLINK-27710
URL: https://issues.apache.org/jira/browse/FLINK-27710
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914
]
Zhu Zhu commented on FLINK-17295:
-
I was not concerning about it because PartitionReques
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17538581#comment-17538581
]
Zhu Zhu commented on FLINK-17295:
-
The benchmark value is the size of a serialized TDD.
[
https://issues.apache.org/jira/browse/FLINK-26909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26909.
---
Fix Version/s: 1.15.1
Resolution: Done
Done via:
master: 46c6d78ddd6b271cd434eff03ae65c0e74c0d53e
r
601 - 700 of 2478 matches
Mail list logo