@Override
    public Optional<Throwable> onAborted(ISink sink) {
      if (LOGGER.isDebugEnabled()) {
        LOGGER.debug("[SkHListenerOnAbort]");
      }
      return context.getFailureCause();
    }
Listen to the state changes of a sink handle of pipeline. And since the finish of pipeline sink
handle doesn't equal the finish of the whole fragment, therefore we don't need to notify
fragment context. But if it's aborted or failed, it can lead to the total fail.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManager.java