You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ca...@apache.org on 2022/03/17 11:25:10 UTC
[incubator-linkis] 02/04: update hive unique column default true
This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.1.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 2c0dae58002567fd98daa3d24f1e3a14620a8747
Author: peacewong <wp...@gmail.com>
AuthorDate: Thu Mar 17 17:53:53 2022 +0800
update hive unique column default true
---
.../engineconn/computation/executor/conf/ComputationExecutorConf.scala | 2 ++
.../computation/executor/execute/EngineExecutionContext.scala | 2 +-
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/conf/ComputationExecutorConf.scala b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/conf/ComputationExecutorConf.scala
index 0c9925c..1fdbe14 100644
--- a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/conf/ComputationExecutorConf.scala
+++ b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/conf/ComputationExecutorConf.scala
@@ -51,4 +51,6 @@ object ComputationExecutorConf {
val UPSTREAM_MONITOR_WRAPPER_ENTRIES_SURVIVE_THRESHOLD_SEC = CommonVars("linkis.upstream.monitor.wrapper.entries.survive.time.sec", 86400).getValue
val UPSTREAM_MONITOR_ECTASK_ENTRANCE_THRESHOLD_SEC = CommonVars("linkis.upstream.monitor.ectask.entrance.threshold.sec", 15).getValue
+
+ val HIVE_RESULTSET_USE_TABLE_NAME = CommonVars("hive.resultset.use.unique.column.names", true)
}
diff --git a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/EngineExecutionContext.scala b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/EngineExecutionContext.scala
index 76be9e3..776c1f2 100644
--- a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/EngineExecutionContext.scala
+++ b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/execute/EngineExecutionContext.scala
@@ -47,7 +47,7 @@ class EngineExecutionContext(executor: ComputationExecutor, executorUser: String
private var defaultResultSetWriter: ResultSetWriter[_ <: MetaData, _ <: Record] = _
private var resultSize = 0
- private var enableResultsetMetaWithTableName = false
+ private var enableResultsetMetaWithTableName = ComputationExecutorConf.HIVE_RESULTSET_USE_TABLE_NAME.getValue
private val properties: java.util.Map[String, Object] = new util.HashMap[String, Object]()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org