@Override
    public Optional<Throwable> onAborted(ISink sink) {
      if (LOGGER.isDebugEnabled()) {
        LOGGER.debug("[ShuffleSinkHandleListenerOnAbort]");
      }
      shuffleSinkHandles.remove(sink.getLocalFragmentInstanceId());
      return context.getFailureCause();
    }
Listen to the state changes of a sink handle.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManager.java