@Override
    public void onFailure(ISink sink, Throwable t) {
      LOGGER.warn("Sink handle failed due to", t);
      if (onFailureCallback != null) {
        onFailureCallback.call(t);
      }
    }
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