We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0dbb896 commit a087c7bCopy full SHA for a087c7b
be/src/runtime/file_result_writer.h
@@ -66,8 +66,12 @@ struct ResultFileOptions {
66
hdfs_properties = t_opt.hdfs_properties;
67
is_local_file = false;
68
}
69
- if (t_opt.__isset.use_broker) {
70
- use_broker = t_opt.use_broker;
+ if (t_opt.__isset.use_broker && !t_opt.use_broker) {
+ // old FE only support use broker,
71
+ // so set use_broker to false only when use_broker in TResultFileSinkOptions is explicitly set false.
72
+ use_broker = false;
73
+ } else {
74
+ use_broker = true;
75
76
if (t_opt.__isset.broker_properties) {
77
broker_properties = t_opt.broker_properties;
0 commit comments