Merge branch 'master' into qubole_spark_fix_cluster_label

Fix Qubole cluster label for Hive components
2018-07-16 15:57:43 +02:00 · 2018-07-06 17:14:43 +03:00
3 changed files with 9 additions and 0 deletions
--- a/main/plugins/org.talend.designer.components.localprovider/components/tHiveIn/tHiveIn_main.javajet
+++ b/main/plugins/org.talend.designer.components.localprovider/components/tHiveIn/tHiveIn_main.javajet
@@ -54,6 +54,9 @@ imports="
 		if (ElementParameterParser.getBooleanValue(node, "__QUBOLE_ENDPOINT__")) {
 			quboleEndpoint = ElementParameterParser.getValue(node, "__QUBOLE_ENDPOINT_URL__");
 		}
+		if (ElementParameterParser.getBooleanValue(node, "__QUBOLE_CLUSTER__")) {
+			quboleClusterLabel = ElementParameterParser.getValue(node, "__QUBOLE_CLUSTER_LABEL__");
+		}
 	}

    org.talend.hadoop.distribution.component.HiveComponent hiveDistrib = null;
--- a/main/plugins/org.talend.designer.components.localprovider/components/tHiveRow/tHiveRow_begin.javajet
+++ b/main/plugins/org.talend.designer.components.localprovider/components/tHiveRow/tHiveRow_begin.javajet
@@ -54,6 +54,9 @@ imports="
 		if (ElementParameterParser.getBooleanValue(node, "__QUBOLE_ENDPOINT__")) {
 			quboleEndpoint = ElementParameterParser.getValue(node, "__QUBOLE_ENDPOINT_URL__");
 		}
+		if (ElementParameterParser.getBooleanValue(node, "__QUBOLE_CLUSTER__")) {
+			quboleClusterLabel = ElementParameterParser.getValue(node, "__QUBOLE_CLUSTER_LABEL__");
+		}
 	}

    org.talend.hadoop.distribution.component.HiveComponent hiveDistrib = null;
--- a/main/plugins/org.talend.designer.components.localprovider/components/tHiveRow/tHiveRow_main.javajet
+++ b/main/plugins/org.talend.designer.components.localprovider/components/tHiveRow/tHiveRow_main.javajet
@@ -53,6 +53,9 @@ if("true".equals(ElementParameterParser.getValue(node,"__USE_EXISTING_CONNECTION
 	if (ElementParameterParser.getBooleanValue(node, "__QUBOLE_ENDPOINT__")) {
 		quboleEndpoint = ElementParameterParser.getValue(node, "__QUBOLE_ENDPOINT_URL__");
 	}
+	if (ElementParameterParser.getBooleanValue(node, "__QUBOLE_CLUSTER__")) {
+		quboleClusterLabel = ElementParameterParser.getValue(node, "__QUBOLE_CLUSTER_LABEL__");
+	}
 }

 org.talend.hadoop.distribution.component.HiveComponent hiveDistrib = null;
Author	SHA1	Message	Date
Yu	acfd468e62	Merge branch 'master' into qubole_spark_fix_cluster_label	2018-07-16 15:57:43 +02:00
Oleh Stoliarov	7c68f281c4	Fix Qubole cluster label for Hive components	2018-07-06 17:14:43 +03:00