Details

      Description

      The TaskExecutor has to track which partitions it has stored, grouped by JobID.

      This is necessary so that the TaskExecutor only disconnects from the JobManager if it no longer stores relevant (i.e., belonging to the corresponding job) partitions (similar to the taskSlotTable).

      Additionally this is needed so that the TaskExecutor can independently cleanup partitions for a given job if the connection to the corresponding JobManager is lost.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                chesnay Chesnay Schepler
                Reporter:
                chesnay Chesnay Schepler
              • Votes:
                0 Vote for this issue
                Watchers:
                3 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 - 20m
                  20m