Revision 39157
Added by Marek Horst over 8 years ago
| ExternalHbaseConnectionTestProcess.java | ||
|---|---|---|
| 1 | 1 |
package eu.dnetlib.iis.export.actionmanager; |
| 2 | 2 |
|
| 3 |
import static eu.dnetlib.iis.export.actionmanager.ExportWorkflowRuntimeParameters.EXPORT_ACTION_HBASE_REMOTE_ZOOKEEPER_CLIENTPORT; |
|
| 4 |
import static eu.dnetlib.iis.export.actionmanager.ExportWorkflowRuntimeParameters.EXPORT_ACTION_HBASE_REMOTE_ZOOKEEPER_QUORUM; |
|
| 5 |
|
|
| 3 | 6 |
import java.io.InputStream; |
| 4 | 7 |
import java.util.Collections; |
| 5 | 8 |
import java.util.Iterator; |
| ... | ... | |
| 51 | 54 |
|
| 52 | 55 |
// setting remote zookeeper address for hbase if any set |
| 53 | 56 |
String zookeeperQuorum = ProcessUtils.getParameterValue( |
| 54 |
WorkflowRuntimeParameters.EXPORT_ACTION_HBASE_REMOTE_ZOOKEEPER_QUORUM,
|
|
| 57 |
EXPORT_ACTION_HBASE_REMOTE_ZOOKEEPER_QUORUM, |
|
| 55 | 58 |
conf, parameters); |
| 56 | 59 |
if (zookeeperQuorum!=null && !zookeeperQuorum.trim().isEmpty() && |
| 57 | 60 |
!zookeeperQuorum.trim().equals( |
| ... | ... | |
| 60 | 63 |
// hbaseConfiguration.set("ha.zookeeper.quorum", zookeeperQuorum.trim());
|
| 61 | 64 |
System.out.println("zookeeper quorum set to: " + zookeeperQuorum.trim());
|
| 62 | 65 |
String zookeeperClientPort = ProcessUtils.getParameterValue( |
| 63 |
WorkflowRuntimeParameters.EXPORT_ACTION_HBASE_REMOTE_ZOOKEEPER_CLIENTPORT,
|
|
| 66 |
EXPORT_ACTION_HBASE_REMOTE_ZOOKEEPER_CLIENTPORT, |
|
| 64 | 67 |
conf, parameters); |
| 65 | 68 |
if (zookeeperClientPort!=null && !zookeeperClientPort.trim().isEmpty() && |
| 66 | 69 |
!zookeeperClientPort.trim().equals( |
Also available in: Unified diff
merging trunk changes with IIS-CDH-5.3.0 branch