udpate

be/src/pipeline/exec/operator.h

@@ -356,7 +356,7 @@ class PipelineXSinkLocalStateBase {
  // Set to true after close() has been called. subclasses should check and set this in
  // close().
  bool _closed = false;
- bool _eos = false;
+ std::atomic<bool> _eos = false;
  //NOTICE: now add a faker profile, because sometimes the profile record is useless
  //so we want remove some counters and timers, eg: in join node, if it's broadcast_join
  //and shared hash table, some counter/timer about build hash table is useless,