Support Questions

Find answers, ask questions, and share your expertise
cancel
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for 
Show  only  | Search instead for 
Did you mean: 
Advanced Search
Announcements
Check out our newest addition to the community, the Cloudera Data Analytics (CDA) group hub.

Java API Operate Hbase API Error connecting to cluster: "Exception making rpc to masters"

Labels:
csdcsd
New Contributor

Created ‎02-07-2022 09:39 PM

I have placed hbase-site.xml and core-site.xml in the src/main/resources folder in the Maven project file, and also imported the hbase dependency:

 

        <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client -->
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-client</artifactId>
            <version>3.0.0-alpha-2</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase -->
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase</artifactId>
            <version>3.0.0-alpha-2</version>
            <type>pom</type>
        </dependency>

```

 

According to the introduction of the official API documentation, HbaseConfiguration will automatically help you find the information in the core-site.xml&hbase-site.xml configuration file and connect through the Connection interface

 

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
 
import java.io.IOException;
 
 
public class helloHbase {
    public static void main (String[] args) throws IOException {
 
        // Auto-detect hbase-site.xml and core-site.xml configuration
        Configuration config = HBaseConfiguration.create();
            config.addResource("core-site.xml");
            config.addResource("hbase-site.xml");
            config.addResource("hdfs-site.xml");
            config.set("zookeeper.znode.parent","/resources");
            config.set("hbase.zookeeper.property.clientPort","2181");
            config.set("hbase.zookeeper.quorum","192.168.115.10,192.168.115.11,192.168.115.12,192.168.115.13,192.168.115.14");
 
        // Create a link to connect to the cluster, then close it
        Connection connection = ConnectionFactory.createConnection(config);
        try {
 
            // materialize the Table object
            Table table = connection.getTable(TableName.valueOf("test"));
            try {
                // Add a line via the Put constructor
                Put p = new Put(Bytes.toBytes("row2"));
 
                // insert a message into the row
                p.addColumn(Bytes.toBytes("myLittleFamily"), Bytes.toBytes("someQualifier"),
                        Bytes.toBytes("Some Value"));
                table.put(p);
 
                // retrieve data
                Get g = new Get(Bytes.toBytes("row2"));
                Result r = table.get(g);
                byte [] value = r.getValue(Bytes.toBytes("myLittleFamily"),
                        Bytes.toBytes("someQualifier"));
 
                // returns "Some Value"
                String valueStr = Bytes.toString(value);
                System.out.println("Get:" + valueStr);
 
                // Scan with Scan
                Scan s = new Scan();
                s.addColumn(Bytes.toBytes("myLittleFamily"),Bytes.toBytes("someQualifier"));
                ResultScanner scanner = table.getScanner(s);
 
                try {
                    // Scan returns a Result instance
                    // For iteration use while loop to print
                    for (Result rr = scanner.next(); rr != null; rr = scanner.next()) {
                        System.out.println("Found row: " + rr);
                    }
                } finally {
                    // Close the Scan process when finished
                    scanner.close();
                }
            } finally {
                // Close the connection between the table and the cluster
                if (table != null) table.close();
            }
        } finally {
             connection.close();
        }
    }
}

 

I used and operated the Hbase Client API according to the requirements of the official documentation https://hbase.apache.org/1.4/devapidocs/index.html, but unfortunately he still failed to connect to the cluster successfully.

From the error message "Exception making rpc to masters [192.168.0.104,16000,-1]" he tried to connect to 192.168.0.104 but actually my master address is 192.168.115.10.

It should be noted that I have added the hostname and corresponding IP address of the cluster to the local host file, and changed the original hostname to an IP address in the hbase-site.xml&core-site.xml file.

It is still normal for me to operate CURD under the hbase shell, but the following error will appear when executing it through the Java API.

 

"D:\Program Files\Java\jdk1.8.0_201\bin\java.exe" "-javaagent:D:\Program Files\JetBrains\IntelliJ IDEA 2021.1\lib\idea_rt.jar=54216:D:\Program Files\JetBrains\IntelliJ IDEA 2021.1\bin" -Dfile.encoding=UTF-8 -classpath "D:\Program Files\Java\jdk1.8.0_201\jre\lib\charsets.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\deploy.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\access-bridge-64.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\cldrdata.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\dnsns.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\jaccess.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\jfxrt.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\localedata.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\nashorn.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\sunec.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\sunjce_provider.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\sunmscapi.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\sunpkcs11.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\ext\zipfs.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\javaws.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\jce.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\jfr.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\jfxswt.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\jsse.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\management-agent.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\plugin.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\resources.jar;D:\Program Files\Java\jdk1.8.0_201\jre\lib\rt.jar;E:\learning_project\hbase-api\target\classes;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-client\3.0.0-alpha-1\hbase-client-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\thirdparty\hbase-shaded-protobuf\3.5.1\hbase-shaded-protobuf-3.5.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-common\3.0.0-alpha-1\hbase-common-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-logging\3.0.0-alpha-1\hbase-logging-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\thirdparty\hbase-shaded-gson\3.5.1\hbase-shaded-gson-3.5.1.jar;C:\Users\lk.sun\.m2\repository\commons-validator\commons-validator\1.6\commons-validator-1.6.jar;C:\Users\lk.sun\.m2\repository\commons-digester\commons-digester\1.8.1\commons-digester-1.8.1.jar;C:\Users\lk.sun\.m2\repository\io\opentelemetry\opentelemetry-semconv\1.0.1-alpha\opentelemetry-semconv-1.0.1-alpha.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-hadoop-compat\3.0.0-alpha-1\hbase-hadoop-compat-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-metrics\3.0.0-alpha-1\hbase-metrics-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-metrics-api\3.0.0-alpha-1\hbase-metrics-api-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\javax\activation\javax.activation-api\1.2.0\javax.activation-api-1.2.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\hbase-protocol-shaded\3.0.0-alpha-1\hbase-protocol-shaded-3.0.0-alpha-1.jar;C:\Users\lk.sun\.m2\repository\javax\annotation\javax.annotation-api\1.2\javax.annotation-api-1.2.jar;C:\Users\lk.sun\.m2\repository\commons-codec\commons-codec\1.13\commons-codec-1.13.jar;C:\Users\lk.sun\.m2\repository\commons-io\commons-io\2.8.0\commons-io-2.8.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\commons\commons-lang3\3.9\commons-lang3-3.9.jar;C:\Users\lk.sun\.m2\repository\org\slf4j\slf4j-api\1.7.30\slf4j-api-1.7.30.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\thirdparty\hbase-shaded-miscellaneous\3.5.1\hbase-shaded-miscellaneous-3.5.1.jar;C:\Users\lk.sun\.m2\repository\com\google\errorprone\error_prone_annotations\2.7.1\error_prone_annotations-2.7.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hbase\thirdparty\hbase-shaded-netty\3.5.1\hbase-shaded-netty-3.5.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\zookeeper\zookeeper\3.5.7\zookeeper-3.5.7.jar;C:\Users\lk.sun\.m2\repository\org\apache\zookeeper\zookeeper-jute\3.5.7\zookeeper-jute-3.5.7.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-handler\4.1.45.Final\netty-handler-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-common\4.1.45.Final\netty-common-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-buffer\4.1.45.Final\netty-buffer-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-transport\4.1.45.Final\netty-transport-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-resolver\4.1.45.Final\netty-resolver-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-codec\4.1.45.Final\netty-codec-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-transport-native-epoll\4.1.45.Final\netty-transport-native-epoll-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\netty\netty-transport-native-unix-common\4.1.45.Final\netty-transport-native-unix-common-4.1.45.Final.jar;C:\Users\lk.sun\.m2\repository\io\opentelemetry\opentelemetry-api\1.0.1\opentelemetry-api-1.0.1.jar;C:\Users\lk.sun\.m2\repository\io\opentelemetry\opentelemetry-context\1.0.1\opentelemetry-context-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\jruby\jcodings\jcodings\1.0.55\jcodings-1.0.55.jar;C:\Users\lk.sun\.m2\repository\org\jruby\joni\joni\2.1.31\joni-2.1.31.jar;C:\Users\lk.sun\.m2\repository\io\dropwizard\metrics\metrics-core\3.2.6\metrics-core-3.2.6.jar;C:\Users\lk.sun\.m2\repository\org\apache\commons\commons-crypto\1.0.0\commons-crypto-1.0.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\hadoop\hadoop-auth\3.2.0\hadoop-auth-3.2.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\httpcomponents\httpclient\4.5.2\httpclient-4.5.2.jar;C:\Users\lk.sun\.m2\repository\org\apache\httpcomponents\httpcore\4.4.4\httpcore-4.4.4.jar;C:\Users\lk.sun\.m2\repository\com\nimbusds\nimbus-jose-jwt\4.41.1\nimbus-jose-jwt-4.41.1.jar;C:\Users\lk.sun\.m2\repository\com\github\stephenc\jcip\jcip-annotations\1.0-1\jcip-annotations-1.0-1.jar;C:\Users\lk.sun\.m2\repository\org\apache\curator\curator-framework\2.12.0\curator-framework-2.12.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-simplekdc\1.0.1\kerb-simplekdc-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-client\1.0.1\kerb-client-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerby-config\1.0.1\kerby-config-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-core\1.0.1\kerb-core-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerby-pkix\1.0.1\kerby-pkix-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerby-asn1\1.0.1\kerby-asn1-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerby-util\1.0.1\kerby-util-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-common\1.0.1\kerb-common-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-crypto\1.0.1\kerb-crypto-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-util\1.0.1\kerb-util-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\token-provider\1.0.1\token-provider-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-admin\1.0.1\kerb-admin-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-server\1.0.1\kerb-server-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerb-identity\1.0.1\kerb-identity-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\kerby\kerby-xdr\1.0.1\kerby-xdr-1.0.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\hadoop\hadoop-common\3.2.0\hadoop-common-3.2.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\hadoop\hadoop-annotations\3.2.0\hadoop-annotations-3.2.0.jar;C:\Users\lk.sun\.m2\repository\com\google\guava\guava\11.0.2\guava-11.0.2.jar;C:\Users\lk.sun\.m2\repository\commons-cli\commons-cli\1.2\commons-cli-1.2.jar;C:\Users\lk.sun\.m2\repository\org\apache\commons\commons-math3\3.1.1\commons-math3-3.1.1.jar;C:\Users\lk.sun\.m2\repository\commons-net\commons-net\3.6\commons-net-3.6.jar;C:\Users\lk.sun\.m2\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;C:\Users\lk.sun\.m2\repository\javax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar;C:\Users\lk.sun\.m2\repository\com\sun\jersey\jersey-servlet\1.19\jersey-servlet-1.19.jar;C:\Users\lk.sun\.m2\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar;C:\Users\lk.sun\.m2\repository\log4j\log4j\1.2.17\log4j-1.2.17.jar;C:\Users\lk.sun\.m2\repository\commons-beanutils\commons-beanutils\1.9.3\commons-beanutils-1.9.3.jar;C:\Users\lk.sun\.m2\repository\org\apache\commons\commons-configuration2\2.1.1\commons-configuration2-2.1.1.jar;C:\Users\lk.sun\.m2\repository\org\apache\commons\commons-text\1.4\commons-text-1.4.jar;C:\Users\lk.sun\.m2\repository\org\slf4j\slf4j-log4j12\1.7.25\slf4j-log4j12-1.7.25.jar;C:\Users\lk.sun\.m2\repository\org\apache\avro\avro\1.7.7\avro-1.7.7.jar;C:\Users\lk.sun\.m2\repository\org\codehaus\jackson\jackson-core-asl\1.9.13\jackson-core-asl-1.9.13.jar;C:\Users\lk.sun\.m2\repository\org\codehaus\jackson\jackson-mapper-asl\1.9.13\jackson-mapper-asl-1.9.13.jar;C:\Users\lk.sun\.m2\repository\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;C:\Users\lk.sun\.m2\repository\org\xerial\snappy\snappy-java\1.0.5\snappy-java-1.0.5.jar;C:\Users\lk.sun\.m2\repository\com\google\re2j\re2j\1.1\re2j-1.1.jar;C:\Users\lk.sun\.m2\repository\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;C:\Users\lk.sun\.m2\repository\com\google\code\gson\gson\2.2.4\gson-2.2.4.jar;C:\Users\lk.sun\.m2\repository\com\jcraft\jsch\0.1.54\jsch-0.1.54.jar;C:\Users\lk.sun\.m2\repository\org\apache\curator\curator-client\2.12.0\curator-client-2.12.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\curator\curator-recipes\2.12.0\curator-recipes-2.12.0.jar;C:\Users\lk.sun\.m2\repository\com\google\code\findbugs\jsr305\3.0.0\jsr305-3.0.0.jar;C:\Users\lk.sun\.m2\repository\org\apache\htrace\htrace-core4\4.1.0-incubating\htrace-core4-4.1.0-incubating.jar;C:\Users\lk.sun\.m2\repository\org\apache\commons\commons-compress\1.4.1\commons-compress-1.4.1.jar;C:\Users\lk.sun\.m2\repository\org\tukaani\xz\1.0\xz-1.0.jar;C:\Users\lk.sun\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.9.5\jackson-databind-2.9.5.jar;C:\Users\lk.sun\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.9.0\jackson-annotations-2.9.0.jar;C:\Users\lk.sun\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.9.5\jackson-core-2.9.5.jar;C:\Users\lk.sun\.m2\repository\org\codehaus\woodstox\stax2-api\3.1.4\stax2-api-3.1.4.jar;C:\Users\lk.sun\.m2\repository\com\fasterxml\woodstox\woodstox-core\5.0.3\woodstox-core-5.0.3.jar;C:\Users\lk.sun\.m2\repository\dnsjava\dnsjava\2.1.7\dnsjava-2.1.7.jar;C:\Users\lk.sun\.m2\repository\org\apache\yetus\audience-annotations\0.5.0\audience-annotations-0.5.0.jar" helloHbase
Exception in thread "main" org.apache.hadoop.hbase.exceptions.MasterRegistryFetchException: Exception making rpc to masters [192.168.0.104,16000,-1]
    at java.lang.Thread.getStackTrace(Thread.java:1559)
    at org.apache.hadoop.hbase.util.FutureUtils.setStackTrace(FutureUtils.java:130)
    at org.apache.hadoop.hbase.util.FutureUtils.rethrow(FutureUtils.java:149)
    at org.apache.hadoop.hbase.util.FutureUtils.get(FutureUtils.java:172)
    at org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:231)
    at org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:130)
    at helloHbase.main(helloHbase.java:31)
    at --------Future.get--------(Unknown Source)
    at org.apache.hadoop.hbase.client.MasterRegistry.lambda$groupCall$1(MasterRegistry.java:232)
    at org.apache.hadoop.hbase.util.FutureUtils.lambda$addListener$0(FutureUtils.java:68)
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
    at org.apache.hadoop.hbase.client.MasterRegistry.lambda$call$0(MasterRegistry.java:186)
    at org.apache.hbase.thirdparty.com.google.protobuf.RpcUtil$1.run(RpcUtil.java:79)
    at org.apache.hbase.thirdparty.com.google.protobuf.RpcUtil$1.run(RpcUtil.java:70)
    at org.apache.hadoop.hbase.ipc.AbstractRpcClient.onCallFinished(AbstractRpcClient.java:388)
    at org.apache.hadoop.hbase.ipc.AbstractRpcClient.access$100(AbstractRpcClient.java:92)
    at org.apache.hadoop.hbase.ipc.AbstractRpcClient$3.run(AbstractRpcClient.java:424)
    at org.apache.hadoop.hbase.ipc.AbstractRpcClient$3.run(AbstractRpcClient.java:419)
    at org.apache.hadoop.hbase.ipc.Call.callComplete(Call.java:119)
    at org.apache.hadoop.hbase.ipc.Call.setException(Call.java:134)
    at org.apache.hadoop.hbase.ipc.BufferCallBeforeInitHandler.userEventTriggered(BufferCallBeforeInitHandler.java:92)
    at org.apache.hbase.thirdparty.io.netty.channel.AbstractChannelHandlerContext.invokeUserEventTriggered(AbstractChannelHandlerContext.java:346)
    at org.apache.hbase.thirdparty.io.netty.channel.AbstractChannelHandlerContext.invokeUserEventTriggered(AbstractChannelHandlerContext.java:332)
    at org.apache.hbase.thirdparty.io.netty.channel.AbstractChannelHandlerContext.fireUserEventTriggered(AbstractChannelHandlerContext.java:324)
    at org.apache.hbase.thirdparty.io.netty.channel.DefaultChannelPipeline$HeadContext.userEventTriggered(DefaultChannelPipeline.java:1428)
    at org.apache.hbase.thirdparty.io.netty.channel.AbstractChannelHandlerContext.invokeUserEventTriggered(AbstractChannelHandlerContext.java:346)
    at org.apache.hbase.thirdparty.io.netty.channel.AbstractChannelHandlerContext.invokeUserEventTriggered(AbstractChannelHandlerContext.java:332)
    at org.apache.hbase.thirdparty.io.netty.channel.DefaultChannelPipeline.fireUserEventTriggered(DefaultChannelPipeline.java:913)
    at org.apache.hadoop.hbase.ipc.NettyRpcConnection.failInit(NettyRpcConnection.java:198)
    at org.apache.hadoop.hbase.ipc.NettyRpcConnection.access$300(NettyRpcConnection.java:78)
    at org.apache.hadoop.hbase.ipc.NettyRpcConnection$2.operationComplete(NettyRpcConnection.java:287)
    at org.apache.hadoop.hbase.ipc.NettyRpcConnection$2.operationComplete(NettyRpcConnection.java:281)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:571)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:550)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:117)
    at org.apache.hbase.thirdparty.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:321)
    at org.apache.hbase.thirdparty.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:337)
    at org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:707)
    at org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)
    at org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)
    at org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
    at org.apache.hbase.thirdparty.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
    at org.apache.hbase.thirdparty.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.hadoop.hbase.client.RetriesExhaustedException: Failed contacting masters after 1 attempts.
Exceptions:
java.net.ConnectException: Call to address=192.168.0.104:16000 failed on connection exception: org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /192.168.0.104:16000
 
    at org.apache.hadoop.hbase.client.MasterRegistry.lambda$groupCall$1(MasterRegistry.java:231)
    ... 43 more
 
Process finished with exit code 1

 

664 Views
0 Kudos
0 REPLIES 0
Take a Tour of the Community
Don't have an account?
Register
Your experience may be limited. Sign in to explore more.
Announcements
Product Announcements
CDP Public Cloud: May 2023 Release Summary
What's New @ Cloudera
Cloudera Operational Database (COD) provides enhancements to the --scale-type CDP CLI option
What's New @ Cloudera
Cloudera Operational Database (COD) UI supports creating a smaller cluster using a predefined Data Lake template
What's New @ Cloudera
Cloudera Operational Database (COD) supports scaling up the clusters vertically
Product Announcements
CDP Public Cloud: April 2023 Release Summary
View More Announcements