This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/master by this push:
new ad2ad57ca [Bug] Fix impala plugin dependencies and executor properties
parser (#4765)
ad2ad57ca is described below
commit ad2ad57ca6eef1072bbba3bdd9676990dc3ab505
Author: Knypys <[email protected]>
AuthorDate: Wed Jul 12 17:25:15 2023 +0800
[Bug] Fix impala plugin dependencies and executor properties parser (#4765)
* fix usage docs
* fix engine for linkis-storage type change
* fix impala executer bugs
---
linkis-engineconn-plugins/impala/pom.xml | 4 ++--
.../engineplugin/impala/executor/ImpalaEngineConnExecutor.scala | 8 +++++---
2 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/linkis-engineconn-plugins/impala/pom.xml
b/linkis-engineconn-plugins/impala/pom.xml
index d6aad856e..c4ec3082d 100644
--- a/linkis-engineconn-plugins/impala/pom.xml
+++ b/linkis-engineconn-plugins/impala/pom.xml
@@ -27,6 +27,7 @@
<artifactId>linkis-engineplugin-impala</artifactId>
<properties>
+ <libthrift.version>0.15.0</libthrift.version>
<package.impala.version>3.4.0</package.impala.version>
</properties>
<dependencies>
@@ -66,8 +67,7 @@
<dependency>
<groupId>org.apache.thrift</groupId>
<artifactId>libthrift</artifactId>
- <version>0.15.0</version>
- <scope>provided</scope>
+ <version>${libthrift.version}</version>
</dependency>
<!-- impala -->
diff --git
a/linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/executor/ImpalaEngineConnExecutor.scala
b/linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/executor/ImpalaEngineConnExecutor.scala
index 90dba93c0..d9cf13a3c 100644
---
a/linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/executor/ImpalaEngineConnExecutor.scala
+++
b/linkis-engineconn-plugins/impala/src/main/scala/org/apache/linkis/engineplugin/impala/executor/ImpalaEngineConnExecutor.scala
@@ -363,7 +363,7 @@ class ImpalaEngineConnExecutor(override val
outputPrintLimit: Int, val id: Int)
impalaSslTruststore,
impalaSslTruststoreType,
impalaSslTruststorePassword
- )
+ ).mkString("/")
impalaClients.synchronized {
var client = impalaClients.get(impalaClientKey)
@@ -427,8 +427,10 @@ class ImpalaEngineConnExecutor(override val
outputPrintLimit: Int, val id: Int)
.map(_.split(','))
.getOrElse(Array[String]())
.foreach { str =>
- val kv = StringUtils.split(str, "=", 2)
- impalaClient.setQueryOption(kv(0), if (kv.length > 1) kv(1) else
"")
+ if (StringUtils.contains(str, "=")) {
+ val kv = StringUtils.split(str, "=", 2)
+ impalaClient.setQueryOption(kv(0), if (kv.length > 1) kv(1) else
"")
+ }
}
client = impalaClient
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
