Java KuduClient не может подключиться куду-мастер - PullRequest
Новая
       24

Java KuduClient не может подключиться куду-мастер

0 голосов
/ 20 марта 2019

Я установил Quickstart CDH 5.13 и настроил службу kudu (все роли работают правильно) на одном узле.Есть только один мастер куду, и это лидер.Я хочу подключить мастер kudu через Java Kudu API, используя этот код: 

package com.codebind;
import java.util.ArrayList;
import java.util.List;

import org.kududb.ColumnSchema;
import org.kududb.Schema;
import org.kududb.Type;
import org.kududb.ColumnSchema.*;
import org.kududb.client.KuduClient;
import org.kududb.client.KuduClient.KuduClientBuilder;


public class main {

public static void main(String[] args) {
    // TODO Auto-generated method stub

    KuduClient kuduClient =
               new KuduClientBuilder("127.0.0.1:7051").build(); 

    ColumnSchema usernameCol =
            new ColumnSchemaBuilder("username", Type.STRING)
            .key(true).build();
        ColumnSchema ageCol =
            new ColumnSchemaBuilder("age", Type.INT8)
            .build();

        List<ColumnSchema> columns = new ArrayList<ColumnSchema>();
        columns.add(usernameCol);
        columns.add(ageCol);

        Schema schema = new Schema(columns);
        String tableName = "table1";

        try {
            if ( ! kuduClient.tableExists(tableName) ) {
                kuduClient.createTable(tableName, schema);
            }
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 }

При создании кода я получил следующие ошибки:

421 [New I / O worker #1] ОШИБКА org.kududb.client.TabletClient - [Peer Kudu Master - quickstart.cloudera: 7051] Неожиданное исключение из нисходящего потока в [id: 0x93e81f9b, /10.0.2.15:37191 => /10.0.2.15:7051] org.kududb.client.InvalidResponseException: Не удалось десериализовать ответ, несовместимый RPC?Ошибка: auths [0] .method at org.kududb.client.KuduRpc.readProtobuf (KuduRpc.java:243)

432 [Новый работник ввода-вывода # 1] WARN org.kududb.client.GetMasterRegistrationReceived- Ошибка получения ответа от: quickstart.cloudera: 7051 org.kududb.client.ConnectionResetException: [Peer Kudu Master - quickstart.cloudera: 7051] Сброс подключения при [id: 0x93e81f9b, /10.0.2.15:37191:> / 10.0.2.15: 7051] at org.kududb.client.TabletClient.cleanup (TabletClient.java:622)

442 [Новый работник ввода-вывода # 1] WARN org.kududb.client.GetMasterRegistrationReceived - невозможно найтиведущий мастер (quickstart.cloudera: 7051), попытается повторить

Однако, когда я использую команду «kudu master list 127.0.0.1:7051», она выдает

uuid |rpc-адреса ---------------------------------- + -------------------------- af5a8a14e1ec4603ad5fa7d6c7398b21 |quickstart.cloudera: 7051

, а также я вижу планшетный сервер таким же образом.

Я не понимаю, почему мой код не работает и говорит, что «лидер не найден», как вы можете видеть выше.У тебя есть идеи?

...