Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15076

Source thread should be interrupted during the Task cancellation

    XMLWordPrintableJSON

    Details

      Description

      Source thread should be interrupted more or less the same way how task thread is being interrupted.

      +/- The `StreamTaskTest#testCancellationNotBlockedOnLock` should also work in case if the mailbox (task) thread is blocked on trying to acquire a `checkpointLock` by some other currently being executed mail (processing time timer/perform checkpoint).

      https://github.com/apache/flink/pull/10345#discussion_r353615760

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                pnowojski Piotr Nowojski
                Reporter:
                pnowojski Piotr Nowojski
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 40m
                  40m