Hi Madheswaran, Is this the java-sample script application from Clouera's kudu-example repository? If it is, it's using Kudu client version 1.1.0 which doesn't support TLS yet.
You should update it to a more recent version (the latest one is 1.8.0) and it should work. Also, these examples have been merged into the apache/kudu repository under the examples directory and they also have been updated since then, you can review them here: https://github.com/apache/kudu/tree/master/examples Attila On Thu, Feb 14, 2019 at 11:01:00AM +0400, Madheswaran Thangavel wrote: > Hi, > > I try to run the below sample java program to connect Kudu server, but it > got failed to connect the Kudu server ( SSL enabled). > > Attached error log screenshot. > > Program : > > package org.kududb.examples.sample; > import org.apache.kudu.ColumnSchema; > import org.apache.kudu.Schema; > import org.apache.kudu.Type; > import org.apache.kudu.client.*; > import java.util.ArrayList; > import java.util.List; > public class Sample { > private static final String KUDU_MASTER = System.getProperty( > "kuduMaster", "quickstart.cloudera"); > public static void main(String[] args) { > System.out.println("-----------------------------------------------"); > System.out.println("Will try to connect to Kudu master at " + KUDU_MASTER); > System.out.println("Run with -DkuduMaster=myHost:port to override."); > System.out.println("-----------------------------------------------"); > String tableName = "java_sample-" + System.currentTimeMillis(); > KuduClient client = new KuduClient.KuduClientBuilder(KUDU_MASTER).build(); > try { > List<ColumnSchema> columns = new ArrayList(2); > columns.add(new ColumnSchema.ColumnSchemaBuilder("key", Type.INT32) > .key(true) > .build()); > columns.add(new ColumnSchema.ColumnSchemaBuilder("value", Type.STRING) > .build()); > List<String> rangeKeys = new ArrayList<>(); > rangeKeys.add("key"); > Schema schema = new Schema(columns); > client.createTable(tableName, schema, > new CreateTableOptions().setRangePartitionColumns(rangeKeys)); > KuduTable table = client.openTable(tableName); > KuduSession session = client.newSession(); > for (int i = 0; i < 3; i++) { > Insert insert = table.newInsert(); > PartialRow row = insert.getRow(); > row.addInt(0, i); > row.addString(1, "value " + i); > session.apply(insert); > } > List<String> projectColumns = new ArrayList<>(1); > projectColumns.add("value"); > KuduScanner scanner = client.newScannerBuilder(table) > .setProjectedColumnNames(projectColumns) > .build(); > while (scanner.hasMoreRows()) { > RowResultIterator results = scanner.nextRows(); > while (results.hasNext()) { > RowResult result = results.next(); > System.out.println(result.getString(0)); > } > } > } catch (Exception e) { > e.printStackTrace(); > } finally { > try { > client.deleteTable(tableName); > } catch (Exception e) { > e.printStackTrace(); > } finally { > try { > client.shutdown(); > } catch (Exception e) { > e.printStackTrace(); > } > } > } > } > } > *Execution *: > java -DkuduMaster=hadoop1.kudu.com -jar kudu-java-sample-1.0-SNAPSHOT.ja > r > > > Regards, > Madheswaran
