File tree Expand file tree Collapse file tree 1 file changed +12
-1
lines changed
Expand file tree Collapse file tree 1 file changed +12
-1
lines changed Original file line number Diff line number Diff line change @@ -26,7 +26,18 @@ namespace doris::pipeline {
2626
2727std::string MultiCastDataStreamSinkLocalState::name_suffix () {
2828 auto * parent = static_cast <MultiCastDataStreamSinkOperatorX*>(_parent);
29- return fmt::format (operator_name_suffix, parent->operator_id ());
29+ // return fmt::format(operator_name_suffix, parent->operator_id());
30+
31+ auto & dest_ids = parent->dests_id ();
32+ std::string result = " (" ;
33+ for (size_t i = 0 ; i < dest_ids.size (); ++i) {
34+ if (i > 0 ) {
35+ result += " , " ;
36+ }
37+ result += fmt::format (" dest_id={}" , dest_ids[i]);
38+ }
39+ result += " )" ;
40+ return fmt::format (result + operator_name_suffix, parent->operator_id ());
3041}
3142
3243std::shared_ptr<BasicSharedState> MultiCastDataStreamSinkOperatorX::create_shared_state () const {
You can’t perform that action at this time.
0 commit comments