From b65a48d46f918bae659e8301454264a51a0dcb5b Mon Sep 17 00:00:00 2001 From: Eriri Kito Date: Fri, 3 Dec 2021 16:22:17 +0800 Subject: [PATCH] Fixed an issue where kettle could not connect to Impala in authentication mode --- .../big/data/kettle/plugins/hive/ImpalaDatabaseDialect.java | 2 +- .../big/data/kettle/plugins/hive/ImpalaDatabaseMeta.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseDialect.java b/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseDialect.java index 7b75185ad15..95e77df245b 100644 --- a/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseDialect.java +++ b/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseDialect.java @@ -80,7 +80,7 @@ public String getURL( IDatabaseConnection connection ) throws DatabaseDialectExc return urlBuffer.toString(); } - urlBuffer.append( ";auth=noSasl" ); + // urlBuffer.append( ";auth=noSasl" ); return urlBuffer.toString(); } diff --git a/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseMeta.java b/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseMeta.java index 7785db16b7a..b34829f8373 100644 --- a/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseMeta.java +++ b/kettle-plugins/hive/src/main/java/org/pentaho/big/data/kettle/plugins/hive/ImpalaDatabaseMeta.java @@ -144,9 +144,9 @@ public String getURL( String hostname, String port, String databaseName ) { getAttributes().getProperty( ATTRIBUTE_PREFIX_EXTRA_OPTION + getPluginId() + ".principal" ); urlBuffer.append( "jdbc:hive2://" ).append( hostname ).append( ":" ).append( port ).append( "/" ) .append( databaseName ); - if ( principal == null && extraPrincipal == null ) { - urlBuffer.append( AUTH_NO_SASL ); - } + // if ( principal == null && extraPrincipal == null ) { + // urlBuffer.append( AUTH_NO_SASL ); + // } urlBuffer.append( ";impala_db=true" ); return urlBuffer.toString(); }