[jira] [Created] (FLINK-19189) Enable pipelined scheduling by default

Zhu Zhu created FLINK-19189: --- Summary: Enable pipelined scheduling by default Key: FLINK-19189 URL: https://issues.apache.org/jira/browse/FLINK-19189 Project: Flink Issue Type: Sub-task C

[jira] [Updated] (FLINK-17016) Integrate pipelined region scheduling

[ https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17016: Description: This task is to integrate PipelinedRegionSchedulingStrategy with DefaultScheduler. A config o

[jira] [Commented] (FLINK-14870) Remove nullable assumption of task slot sharing group

[ https://issues.apache.org/jira/browse/FLINK-14870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193478#comment-17193478 ] Zhu Zhu commented on FLINK-14870: - Merged via 455ab3d0fea08295447ad690b39ff0d743230bea 8

[jira] [Closed] (FLINK-14870) Remove nullable assumption of task slot sharing group

[ https://issues.apache.org/jira/browse/FLINK-14870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-14870. --- Resolution: Fixed > Remove nullable assumption of task slot sharing group >

[jira] [Closed] (FLINK-17016) Integrate pipelined region scheduling

[ https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17016. --- Resolution: Fixed Done via: d918cc3e660d9cdbb84a175c8bb93ce6a14e38dc 4df2295f54709f4292888a3b4fcbb019dd4d790

[jira] [Updated] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15467: Fix Version/s: (was: 1.11.2) 1.11.3 > Should wait for the end of the source thread

[jira] [Commented] (FLINK-19264) Identical jobs cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197360#comment-17197360 ] Zhu Zhu commented on FLINK-19264: - Thanks for reporting and investigating this issue! I

[jira] [Commented] (FLINK-19264) Jobs with identical graph shapes cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198094#comment-17198094 ] Zhu Zhu commented on FLINK-19264: - [~aljoscha] yes the {{StreamNode}} hash is, if not sp

[jira] [Closed] (FLINK-18114) Expose more details in logs for debugging bulk slot allocation failures

[ https://issues.apache.org/jira/browse/FLINK-18114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-18114. --- Resolution: Won't Do > Expose more details in logs for debugging bulk slot allocation failures > ---

[jira] [Created] (FLINK-19286) Improve pipelined region scheduling performance

Zhu Zhu created FLINK-19286: --- Summary: Improve pipelined region scheduling performance Key: FLINK-19286 URL: https://issues.apache.org/jira/browse/FLINK-19286 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19287) Fix minor version in flink docs

Zhu Zhu created FLINK-19287: --- Summary: Fix minor version in flink docs Key: FLINK-19287 URL: https://issues.apache.org/jira/browse/FLINK-19287 Project: Flink Issue Type: Bug Components: D

[jira] [Assigned] (FLINK-19189) Enable pipelined scheduling by default

[ https://issues.apache.org/jira/browse/FLINK-19189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19189: --- Assignee: Zhu Zhu > Enable pipelined scheduling by default > --

[jira] [Closed] (FLINK-19287) Fix minor version in flink docs

[ https://issues.apache.org/jira/browse/FLINK-19287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19287. --- Resolution: Fixed Fixed via release-1.11: a2ab22e771ddd5feedb873d901a047e0bcb9e297 release-1.10: 6c49a8e54be

[jira] [Assigned] (FLINK-19264) Jobs with identical graph shapes cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19264: --- Assignee: Yangze Guo > Jobs with identical graph shapes cannot be run concurrently > --

[jira] [Commented] (FLINK-19264) Jobs with identical graph shapes cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200020#comment-17200020 ] Zhu Zhu commented on FLINK-19264: - Thanks for doing the experiment [~karmagyz] I checke

[jira] [Closed] (FLINK-19286) Improve pipelined region scheduling performance

[ https://issues.apache.org/jira/browse/FLINK-19286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19286. --- Resolution: Fixed Done via: 6045da062d30fcaea1b2eaf5fb879fd89b7e920e f89c137eabb5b61826dac143eca8d804aa99d9f

[jira] [Closed] (FLINK-19189) Enable pipelined scheduling by default

[ https://issues.apache.org/jira/browse/FLINK-19189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19189. --- Resolution: Fixed Done via: 773dc111782db70bef07473755e95b10b32ef8e2 030fa2148594f1ba006fc472a0c02f802ebbdbf

[jira] [Updated] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15467: Fix Version/s: (was: 1.11.3) 1.11.2 > Should wait for the end of the source thread

[jira] [Commented] (FLINK-16430) FLIP-119 Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203129#comment-17203129 ] Zhu Zhu commented on FLINK-16430: - Yes, I will prepare a release not and close it [~troh

[jira] [Comment Edited] (FLINK-16430) FLIP-119 Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203129#comment-17203129 ] Zhu Zhu edited comment on FLINK-16430 at 9/28/20, 9:46 AM: --- Ye

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119326#comment-17119326 ] Zhu Zhu commented on FLINK-17726: - Thanks for the updates [~nicholasjiang]. Please ping

[jira] [Created] (FLINK-18034) Introduce PreferredLocationsRetriever

Zhu Zhu created FLINK-18034: --- Summary: Introduce PreferredLocationsRetriever Key: FLINK-18034 URL: https://issues.apache.org/jira/browse/FLINK-18034 Project: Flink Issue Type: Sub-task Co

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120725#comment-17120725 ] Zhu Zhu commented on FLINK-17726: - [~nicholasjiang] what's the current state? is there a

[jira] [Assigned] (FLINK-18048) "--host" option could not take effect for standalone application cluster

[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-18048: --- Assignee: Yang Wang > "--host" option could not take effect for standalone application cluster > --

[jira] [Commented] (FLINK-18048) "--host" option could not take effect for standalone application cluster

[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120901#comment-17120901 ] Zhu Zhu commented on FLINK-18048: - Yes you are right that host option should be added to

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120997#comment-17120997 ] Zhu Zhu commented on FLINK-17726: - I just thought of a case that might be problematic wi

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121514#comment-17121514 ] Zhu Zhu commented on FLINK-17726: - [~nicholasjiang] What I mean is that not all kinds of

[jira] [Created] (FLINK-18114) Expose more details in logs for debugging bulk slot allocation failures

Zhu Zhu created FLINK-18114: --- Summary: Expose more details in logs for debugging bulk slot allocation failures Key: FLINK-18114 URL: https://issues.apache.org/jira/browse/FLINK-18114 Project: Flink

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125588#comment-17125588 ] Zhu Zhu commented on FLINK-17726: - I think it should be that in TM we do not allow `tran

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125653#comment-17125653 ] Zhu Zhu commented on FLINK-17726: - Thanks for the updates. [~nicholasjiang] Looking for

[jira] [Closed] (FLINK-18034) Introduce PreferredLocationsRetriever

[ https://issues.apache.org/jira/browse/FLINK-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-18034. --- Resolution: Fixed Done via e850760019b81b132f9d8d98ab8ff7fb1eb62ea3 31282fe6ded14dd1229b8978532aec250ae5b8c

[jira] [Assigned] (FLINK-17760) Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

[ https://issues.apache.org/jira/browse/FLINK-17760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17760: --- Assignee: Zhu Zhu > Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133005#comment-17133005 ] Zhu Zhu commented on FLINK-17260: - another instance: https://dev.azure.com/apache-flink/

[jira] [Closed] (FLINK-17017) Implements bulk allocation for physical slots

[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17017. --- Resolution: Fixed Done via 7054f97350efec83e3bf8b10b9b2c44f1a149cf1 636e36cbd5bc2f45e0e502e0fec9d7723b06dd7a

[jira] [Commented] (FLINK-18454) Add a code contribution section about how to look for what to contribute

[ https://issues.apache.org/jira/browse/FLINK-18454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161678#comment-17161678 ] Zhu Zhu commented on FLINK-18454: - Ok. I will take the Chinsese translation. > Add a co

[jira] [Assigned] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-18496: --- Assignee: Zhilong Hong > Anchors are not generated based on ZH characters > ---

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162811#comment-17162811 ] Zhu Zhu commented on FLINK-18496: - [~Thesharing] Thanks for offering to take this ticket

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165668#comment-17165668 ] Zhu Zhu commented on FLINK-18496: - Thanks for the updates [~Thesharing]. Really good inv

[jira] [Updated] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18690: Component/s: Runtime / Coordination > Implement LocalInputPreferredSlotSharingStrategy > -

[jira] [Commented] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168531#comment-17168531 ] Zhu Zhu commented on FLINK-18690: - There are known limitations of LocalInputPreferredSlo

[jira] [Comment Edited] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168531#comment-17168531 ] Zhu Zhu edited comment on FLINK-18690 at 7/31/20, 8:47 AM: --- Th

[jira] [Commented] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168535#comment-17168535 ] Zhu Zhu commented on FLINK-18690: - Suboptimal case 1: The grouping of execution vertices

[jira] [Comment Edited] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168535#comment-17168535 ] Zhu Zhu edited comment on FLINK-18690 at 7/31/20, 8:49 AM: --- Su

[jira] [Updated] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18690: Attachment: case1.png > Implement LocalInputPreferredSlotSharingStrategy > ---

[jira] [Comment Edited] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168535#comment-17168535 ] Zhu Zhu edited comment on FLINK-18690 at 7/31/20, 8:49 AM: --- Su

[jira] [Comment Edited] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168535#comment-17168535 ] Zhu Zhu edited comment on FLINK-18690 at 7/31/20, 8:50 AM: --- Su

[jira] [Commented] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168543#comment-17168543 ] Zhu Zhu commented on FLINK-18690: - Suboptimal case 2: (it is just a potential case to be

[jira] [Comment Edited] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168535#comment-17168535 ] Zhu Zhu edited comment on FLINK-18690 at 7/31/20, 9:11 AM: --- Su

[jira] [Commented] (FLINK-17714) Support custom RestartBackoffTimeStrategy

[ https://issues.apache.org/jira/browse/FLINK-17714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169695#comment-17169695 ] Zhu Zhu commented on FLINK-17714: - One way in my mind is allow users to configure the fa

[jira] [Comment Edited] (FLINK-17714) Support custom RestartBackoffTimeStrategy

[ https://issues.apache.org/jira/browse/FLINK-17714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169695#comment-17169695 ] Zhu Zhu edited comment on FLINK-17714 at 8/3/20, 3:46 AM: -- One

[jira] [Comment Edited] (FLINK-17714) Support custom RestartBackoffTimeStrategy

[ https://issues.apache.org/jira/browse/FLINK-17714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169695#comment-17169695 ] Zhu Zhu edited comment on FLINK-17714 at 8/3/20, 3:46 AM: -- One

[jira] [Commented] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169755#comment-17169755 ] Zhu Zhu commented on FLINK-18799: - If your jobs are DataStream jobs, you can assign job

[jira] [Commented] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169874#comment-17169874 ] Zhu Zhu commented on FLINK-18799: - Thanks for the explanation [~nobleyd] In your case th

[jira] [Comment Edited] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169874#comment-17169874 ] Zhu Zhu edited comment on FLINK-18799 at 8/3/20, 10:04 AM: --- Th

[jira] [Comment Edited] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169874#comment-17169874 ] Zhu Zhu edited comment on FLINK-18799 at 8/3/20, 10:04 AM: --- Th

[jira] [Commented] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169877#comment-17169877 ] Zhu Zhu commented on FLINK-18799: - > The key point is one vertex's all parallel subtask

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170531#comment-17170531 ] Zhu Zhu commented on FLINK-17726: - Hi [~nicholasjiang], is there any updates for the des

[jira] [Updated] (FLINK-18426) Incompatible deprecated key type for registration cluster options

[ https://issues.apache.org/jira/browse/FLINK-18426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18426: Fix Version/s: (was: 1.11.0) 1.11.1 > Incompatible deprecated key type for registra

[jira] [Updated] (FLINK-18426) Incompatible deprecated key type for registration cluster options

[ https://issues.apache.org/jira/browse/FLINK-18426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18426: Fix Version/s: (was: 1.11.1) 1.11.0 > Incompatible deprecated key type for registra

[jira] [Updated] (FLINK-18689) Deterministic Slot Sharing

[ https://issues.apache.org/jira/browse/FLINK-18689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18689: Fix Version/s: 1.12.0 > Deterministic Slot Sharing > -- > > Key: F

[jira] [Closed] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-18690. --- Fix Version/s: 1.12.0 Resolution: Fixed Done via: 2542d86861cd5dd94feb9fcc92ef8e06398c8241 cfda0e0bb7

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171449#comment-17171449 ] Zhu Zhu commented on FLINK-17075: - Hi [~chesnay], I can see the PR is merged but the tic

[jira] [Commented] (FLINK-9667) Scala docs are only generated for flink-scala

[ https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171451#comment-17171451 ] Zhu Zhu commented on FLINK-9667: [~chesnay] do you think we can have it fixed in 1.10.2?

[jira] [Updated] (FLINK-18045) Fix Kerberos credentials checking to unblock Flink on secured MapR

[ https://issues.apache.org/jira/browse/FLINK-18045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18045: Summary: Fix Kerberos credentials checking to unblock Flink on secured MapR (was: Newest version reintrod

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171485#comment-17171485 ] Zhu Zhu commented on FLINK-16441: - Hi [~jark][~gyfora], I'd like to understand whether t

[jira] [Commented] (FLINK-9667) Scala docs are only generated for flink-scala

[ https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171486#comment-17171486 ] Zhu Zhu commented on FLINK-9667: Thanks for the updates! [~chesnay] > Scala docs are onl

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171881#comment-17171881 ] Zhu Zhu commented on FLINK-17075: - Thanks for the explanation [~trohrmann] I will move i

[jira] [Assigned] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17330: --- Assignee: Zhu Zhu > Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172759#comment-17172759 ] Zhu Zhu commented on FLINK-16441: - Thanks for the updates [~jark] > Allow users to over

[jira] [Updated] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17075: Fix Version/s: (was: 1.10.2) 1.10.3 > Add task status reconciliation between TM and

[jira] [Commented] (FLINK-16069) Creation of TaskDeploymentDescriptor can block main thread for long time

[ https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173885#comment-17173885 ] Zhu Zhu commented on FLINK-16069: - Hi Yumeng, I think we have not reached a consensus. I

[jira] [Comment Edited] (FLINK-16069) Creation of TaskDeploymentDescriptor can block main thread for long time

[ https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173885#comment-17173885 ] Zhu Zhu edited comment on FLINK-16069 at 8/10/20, 1:44 AM: --- Hi

[jira] [Commented] (FLINK-18859) ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnoughResources failed with "Condition was not met in given timeout."

[ https://issues.apache.org/jira/browse/FLINK-18859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174061#comment-17174061 ] Zhu Zhu commented on FLINK-18859: - I tried running the case 1000 times and failed to rep

[jira] [Comment Edited] (FLINK-18859) ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnoughResources failed with "Condition was not met in given timeout."

[ https://issues.apache.org/jira/browse/FLINK-18859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174061#comment-17174061 ] Zhu Zhu edited comment on FLINK-18859 at 8/10/20, 5:56 AM: --- I

[jira] [Updated] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16324: Affects Version/s: 1.12.0 1.10.1 1.11.1 > Checkpoint tasks p

[jira] [Updated] (FLINK-15788) Various Kubernetes integration improvements

[ https://issues.apache.org/jira/browse/FLINK-15788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15788: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Various Kubernetes

[jira] [Updated] (FLINK-15524) Some links in Chinese documents points to English documents by mistake

[ https://issues.apache.org/jira/browse/FLINK-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15524: Affects Version/s: 1.12.0 1.10.1 1.11.1 > Some links in Chin

[jira] [Updated] (FLINK-15524) Some links in Chinese documents points to English documents by mistake

[ https://issues.apache.org/jira/browse/FLINK-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15524: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Some links in Chine

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15471: Fix Version/s: (was: 1.9.4) (was: 1.10.2) 1.10.3

[jira] [Closed] (FLINK-19264) Jobs with identical graph shapes cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19264. --- Resolution: Fixed Fixed via 6e5240f8ac24974826a07b5370908a85bd874ce1 > Jobs with identical graph shapes can

[jira] [Closed] (FLINK-16430) FLIP-119 Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-16430. --- Release Note: Beginning from Flink 1.12, jobs will be scheduled in the unit of pipelined regions. A pipeline

[jira] [Commented] (FLINK-19552) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

[ https://issues.apache.org/jira/browse/FLINK-19552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17210701#comment-17210701 ] Zhu Zhu commented on FLINK-19552: - Thanks for reporting this issue! [~rmetzger] We will

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17210780#comment-17210780 ] Zhu Zhu commented on FLINK-17726: - Hi [~nicholasjiang], is there any updates? Or do you

[jira] [Created] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

Zhu Zhu created FLINK-19570: --- Summary: Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID Key: FLINK-19570 URL: https://issues.apache.org/jira/browse/FLINK-19570

[jira] [Updated] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19570: Description: Since FLINK-17295, many tests encounters unexpected global failure due to registering duplic

[jira] [Commented] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212219#comment-17212219 ] Zhu Zhu commented on FLINK-19570: - cc [~karmagyz] [~trohrmann] [~mapohl] > Execution gr

[jira] [Updated] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19570: Description: Since FLINK-17295, many tests encounters unexpected global failure due to registering duplic

[jira] [Created] (FLINK-19598) E2E test Kerberized YARN application on Docker test (default input) fails on CI

Zhu Zhu created FLINK-19598: --- Summary: E2E test Kerberized YARN application on Docker test (default input) fails on CI Key: FLINK-19598 URL: https://issues.apache.org/jira/browse/FLINK-19598 Project: Flink

[jira] [Assigned] (FLINK-19552) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

[ https://issues.apache.org/jira/browse/FLINK-19552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19552: --- Assignee: Zhu Zhu (was: Andrey Zagrebin) > JobManager dies with IllegalStateException SharedSlot (

[jira] [Closed] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19570. --- Resolution: Fixed Fixed via f2d70c85b659074342db93bd903b2c9e91cfb749 0c373822e31562c6f0d65505c0b95ea1b166c09

[jira] [Commented] (FLINK-19552) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

[ https://issues.apache.org/jira/browse/FLINK-19552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213685#comment-17213685 ] Zhu Zhu commented on FLINK-19552: - The root cause is that `MergingSharedSlotProfileRetri

[jira] [Assigned] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19669: --- Assignee: Xuannan Su > PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check >

[jira] [Commented] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215134#comment-17215134 ] Zhu Zhu commented on FLINK-19669: - Thanks for reporting this issue [~xuannan]. You are r

[jira] [Updated] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19669: Component/s: Runtime / Coordination > PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking

[jira] [Updated] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19669: Fix Version/s: 1.11.3 1.12.0 > PipelinedRegionSchedulingStrategy#init ResultPartitionTy

[jira] [Updated] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19669: Affects Version/s: 1.11.0 > PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check > s

[jira] [Updated] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19669: Fix Version/s: (was: 1.11.3) > PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking che

[jira] [Updated] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19669: Affects Version/s: (was: 1.11.0) 1.12.0 > PipelinedRegionSchedulingStrategy#ini

[jira] [Closed] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

[ https://issues.apache.org/jira/browse/FLINK-19669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19669. --- Resolution: Fixed Fixed via 8133c0662c94d1d7dc225166130e4838b9361e04 > PipelinedRegionSchedulingStrategy#in

[jira] [Created] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager

Zhu Zhu created FLINK-19703: --- Summary: A result partition is not untracked after its producer task failed in TaskManager Key: FLINK-19703 URL: https://issues.apache.org/jira/browse/FLINK-19703 Project: Flin

<    9   10   11   12   13   14   15   16   17   18   >