XComp commented on a change in pull request #13111:
URL: https://github.com/apache/flink/pull/13111#discussion_r469874590
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
##########
@@ -134,120 +134,190 @@
*/
public class Task implements Runnable, TaskSlotPayload, TaskActions,
PartitionProducerStateProvider, CheckpointListener, BackPressureSampleableTask {
- /** The class logger. */
+ /**
+ * The class logger.
+ */
Review comment:
It was accidentally added. But there is actually a change that is
relevant:
```
@@ -755,7 +836,7 @@ public class Task implements Runnable, TaskSlotPayload,
TaskActions, PartitionPr
// an exception was thrown as a side effect of
cancelling
//
----------------------------------------------------------------
- t =
TaskManagerExceptionUtils.tryEnrichTaskManagerError(t);
+
TaskManagerExceptionUtils.tryEnrichTaskManagerError(t);
```
I reverted everything except for the change above.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
