NEED (#27531)
This commit is contained in:
@ -243,7 +243,6 @@ public class Coordinator implements CoordInterface {
|
||||
|
||||
private boolean enablePipelineEngine = false;
|
||||
private boolean enablePipelineXEngine = false;
|
||||
private boolean fasterFloatConvert = false;
|
||||
|
||||
// Runtime filter merge instance address and ID
|
||||
public TNetworkAddress runtimeFilterMergeAddr;
|
||||
@ -299,7 +298,6 @@ public class Coordinator implements CoordInterface {
|
||||
&& (fragments.size() > 0);
|
||||
this.enablePipelineXEngine = context.getSessionVariable().getEnablePipelineXEngine()
|
||||
&& (fragments.size() > 0);
|
||||
this.fasterFloatConvert = context.getSessionVariable().fasterFloatConvert();
|
||||
|
||||
initQueryOptions(context);
|
||||
|
||||
|
||||
@ -2941,10 +2941,6 @@ public class SessionVariable implements Serializable, Writable {
|
||||
return this.profileLevel;
|
||||
}
|
||||
|
||||
public boolean fasterFloatConvert() {
|
||||
return this.fasterFloatConvert;
|
||||
}
|
||||
|
||||
public void checkSqlDialect(String sqlDialect) {
|
||||
if (StringUtils.isEmpty(sqlDialect)) {
|
||||
LOG.warn("sqlDialect value is empty");
|
||||
|
||||
Reference in New Issue
Block a user