weizuo93 commented on code in PR #10298:
URL: https://github.com/apache/doris/pull/10298#discussion_r923424425
##########
fe/fe-core/src/main/java/org/apache/doris/common/Config.java:
##########
@@ -722,6 +722,24 @@ public class Config extends ConfigBase {
@ConfField(mutable = true, masterOnly = true)
public static boolean disable_show_stream_load = false;
+ /**
+ * Whether to enable to write single replica for stream load.
+ */
+ @ConfField(mutable = true, masterOnly = true)
+ public static boolean enable_single_replica_stream_load = false;
+
+ /**
+ * Whether to enable to write single replica for broker load.
+ */
+ @ConfField(mutable = true, masterOnly = true)
+ public static boolean enable_single_replica_broker_load = false;
+
+ /**
+ * Whether to enable to write single replica for insert.
+ */
+ @ConfField(mutable = true, masterOnly = true)
+ public static boolean enable_single_replica_insert = false;
Review Comment:
> better to use a load property for stream and broker load. and use session
variable to control the insert operation.
done
##########
be/src/exec/tablet_sink.h:
##########
@@ -287,6 +291,7 @@ class NodeChannel {
RefCountClosure<PTabletWriterOpenResult>* _open_closure = nullptr;
std::vector<TTabletWithPartition> _all_tablets;
+ std::unordered_map<int64_t, std::vector<int64_t>> _slave_tablet_nodes;
Review Comment:
> Add comment to explain these `int64_t`
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
