win连接远程kudu失败

来源:7-4 API操作之创建表

慕标2366677

2020-05-21

webUI界面可以打开,服务器可以ping通,window上配置好hadoop000的host地址。
报错信息如下:

Exception in thread "main" org.apache.kudu.client.NonRecoverableException: can not complete before timeout: KuduRpc(method=CreateTable, tablet=null, attempt=24, DeadlineTracker(timeout=30000, elapsed=30415), Traces: [0ms] querying master, [221ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [440ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x0a6dc74c, /192.168.1.5:50579 => hadoop000/47.113.90.32:7051], [448ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x0a6dc74c, /192.168.1.5:50579 => hadoop000/47.113.90.32:7051], [459ms] querying master, [460ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [488ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x649412b3, /192.168.1.5:50580 => hadoop000/47.113.90.32:7051], [488ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x649412b3, /192.168.1.5:50580 => hadoop000/47.113.90.32:7051], [498ms] querying master, [499ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [525ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x2a388d1f, /192.168.1.5:50581 => hadoop000/47.113.90.32:7051], [525ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x2a388d1f, /192.168.1.5:50581 => hadoop000/47.113.90.32:7051], [541ms] querying master, [541ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [568ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x99f56c4e, /192.168.1.5:50582 => hadoop000/47.113.90.32:7051], [568ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x99f56c4e, /192.168.1.5:50582 => hadoop000/47.113.90.32:7051], [579ms] querying master, [580ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [614ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xb7946921, /192.168.1.5:50583 => hadoop000/47.113.90.32:7051], [614ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xb7946921, /192.168.1.5:50583 => hadoop000/47.113.90.32:7051], [659ms] querying master, [659ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [1414ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xabd142b0, /192.168.1.5:50584 => hadoop000/47.113.90.32:7051], [1414ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xabd142b0, /192.168.1.5:50584 => hadoop000/47.113.90.32:7051], [1460ms] querying master, [1460ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [1493ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x315ccf1d, /192.168.1.5:50585 => hadoop000/47.113.90.32:7051], [1493ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x315ccf1d, /192.168.1.5:50585 => hadoop000/47.113.90.32:7051], [1620ms] querying master, [1620ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [2394ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x0de9f0ba, /192.168.1.5:50586 => hadoop000/47.113.90.32:7051], [2394ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x0de9f0ba, /192.168.1.5:50586 => hadoop000/47.113.90.32:7051], [2481ms] querying master, [2481ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [2516ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xdd1316e2, /192.168.1.5:50587 => hadoop000/47.113.90.32:7051], [2516ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xdd1316e2, /192.168.1.5:50587 => hadoop000/47.113.90.32:7051], [2620ms] querying master, [2620ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [3393ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x8621a5cd, /192.168.1.5:50588 => hadoop000/47.113.90.32:7051], [3393ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x8621a5cd, /192.168.1.5:50588 => hadoop000/47.113.90.32:7051], [3800ms] querying master, [3800ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [4423ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x23accb42, /192.168.1.5:50589 => hadoop000/47.113.90.32:7051], [4424ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x23accb42, /192.168.1.5:50589 => hadoop000/47.113.90.32:7051], [5719ms] querying master, [5719ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [6427ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xedd96591, /192.168.1.5:50591 => hadoop000/47.113.90.32:7051], [6427ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xedd96591, /192.168.1.5:50591 => hadoop000/47.113.90.32:7051], [7719ms] querying master, [7719ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [8433ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xa4e3f856, /192.168.1.5:50593 => hadoop000/47.113.90.32:7051], [8434ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xa4e3f856, /192.168.1.5:50593 => hadoop000/47.113.90.32:7051], [9100ms] querying master, [9100ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [9422ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x19514fbc, /192.168.1.5:50594 => hadoop000/47.113.90.32:7051], [9423ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x19514fbc, /192.168.1.5:50594 => hadoop000/47.113.90.32:7051], [10579ms] querying master, [10580ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [10636ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x493208b8, /192.168.1.5:50595 => hadoop000/47.113.90.32:7051], [10636ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x493208b8, /192.168.1.5:50595 => hadoop000/47.113.90.32:7051], [13561ms] querying master, [13561ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [13602ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x2e404a89, /192.168.1.5:50599 => hadoop000/47.113.90.32:7051], [13603ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x2e404a89, /192.168.1.5:50599 => hadoop000/47.113.90.32:7051], [16579ms] querying master, [16579ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [16616ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x7fb4ad95, /192.168.1.5:50600 => hadoop000/47.113.90.32:7051], [16617ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x7fb4ad95, /192.168.1.5:50600 => hadoop000/47.113.90.32:7051], [19920ms] querying master, [19920ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [20432ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x20dd418c, /192.168.1.5:50602 => hadoop000/47.113.90.32:7051], [20433ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x20dd418c, /192.168.1.5:50602 => hadoop000/47.113.90.32:7051], [20600ms] querying master, [20600ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [20626ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x48ddb3ba, /192.168.1.5:50604 => hadoop000/47.113.90.32:7051], [20626ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x48ddb3ba, /192.168.1.5:50604 => hadoop000/47.113.90.32:7051], [23860ms] querying master, [23860ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [24414ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x0f2a33ec, /192.168.1.5:50605 => hadoop000/47.113.90.32:7051], [24416ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0x0f2a33ec, /192.168.1.5:50605 => hadoop000/47.113.90.32:7051], [24939ms] querying master, [24939ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [25421ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xc2001813, /192.168.1.5:50606 => hadoop000/47.113.90.32:7051], [25422ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xc2001813, /192.168.1.5:50606 => hadoop000/47.113.90.32:7051], [27399ms] querying master, [27399ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [27431ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xc4379861, /192.168.1.5:50609 => hadoop000/47.113.90.32:7051], [27432ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xc4379861, /192.168.1.5:50609 => hadoop000/47.113.90.32:7051], [28879ms] querying master, [28879ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [29412ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xcb763833, /192.168.1.5:50610 => hadoop000/47.113.90.32:7051], [29413ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xcb763833, /192.168.1.5:50610 => hadoop000/47.113.90.32:7051], [29939ms] querying master, [29939ms] Sub rpc: ConnectToMaster sending RPC to server master-hadoop000:7051, [30413ms] Sub rpc: ConnectToMaster received from server master-hadoop000:7051 response Network error: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xbb7bfa64, /192.168.1.5:50612 => hadoop000/47.113.90.32:7051], [30413ms] delaying RPC due to Service unavailable: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xbb7bfa64, /192.168.1.5:50612 => hadoop000/47.113.90.32:7051], Deferred@199035748(state=PENDING, result=null, callback=(continuation of Deferred@990206160 after retry RPC after error@37680159) -> (continuation of Deferred@98931436 after retry RPC after error@1547939580) -> (continuation of Deferred@1372608687 after retry RPC after error@1441777354) -> (continuation of Deferred@1144317161 after retry RPC after error@1074489392) -> (continuation of Deferred@1309164032 after retry RPC after error@1245175710) -> (continuation of Deferred@2053568524 after retry RPC after error@2119791391) -> (continuation of Deferred@419125142 after retry RPC after error@482656470) -> (continuation of Deferred@1034979101 after retry RPC after error@965674228) -> (continuation of Deferred@674964595 after retry RPC after error@738506027) -> (continuation of Deferred@895483255 after retry RPC after error@828407683) -> (continuation of Deferred@46033375 after retry RPC after error@109178327) -> (continuation of Deferred@994145507 after retry RPC after error@1065281492) -> (continuation of Deferred@1263901130 after retry RPC after error@1332348159) -> (continuation of Deferred@1047761992 after retry RPC after error@978061273) -> (continuation of Deferred@1690864063 after retry RPC after error@1626804601) -> (continuation of Deferred@84587689 after retry RPC after error@20262999) -> (continuation of Deferred@1101526630 after retry RPC after error@1419046798) -> (continuation of Deferred@1013731763 after retry RPC after error@2107192498) -> (continuation of Deferred@621608428 after retry RPC after error@243180415) -> (continuation of Deferred@813507150 after retry RPC after error@724342259) -> (continuation of Deferred@986397538 after retry RPC after error@1316279837) -> (continuation of Deferred@236012863 after retry RPC after error@996477127) -> (continuation of Deferred@1819185628 after retry RPC after error@1444297144), errback=(continuation of Deferred@990206160 after retry RPC after error@37680159) -> (continuation of Deferred@98931436 after retry RPC after error@1547939580) -> (continuation of Deferred@1372608687 after retry RPC after error@1441777354) -> (continuation of Deferred@1144317161 after retry RPC after error@1074489392) -> (continuation of Deferred@1309164032 after retry RPC after error@1245175710) -> (continuation of Deferred@2053568524 after retry RPC after error@2119791391) -> (continuation of Deferred@419125142 after retry RPC after error@482656470) -> (continuation of Deferred@1034979101 after retry RPC after error@965674228) -> (continuation of Deferred@674964595 after retry RPC after error@738506027) -> (continuation of Deferred@895483255 after retry RPC after error@828407683) -> (continuation of Deferred@46033375 after retry RPC after error@109178327) -> (continuation of Deferred@994145507 after retry RPC after error@1065281492) -> (continuation of Deferred@1263901130 after retry RPC after error@1332348159) -> (continuation of Deferred@1047761992 after retry RPC after error@978061273) -> (continuation of Deferred@1690864063 after retry RPC after error@1626804601) -> (continuation of Deferred@84587689 after retry RPC after error@20262999) -> (continuation of Deferred@1101526630 after retry RPC after error@1419046798) -> (continuation of Deferred@1013731763 after retry RPC after error@2107192498) -> (continuation of Deferred@621608428 after retry RPC after error@243180415) -> (continuation of Deferred@813507150 after retry RPC after error@724342259) -> (continuation of Deferred@986397538 after retry RPC after error@1316279837) -> (continuation of Deferred@236012863 after retry RPC after error@996477127) -> (continuation of Deferred@1819185628 after retry RPC after error@1444297144)))
	at org.apache.kudu.client.KuduException.transformException(KuduException.java:110)
	at org.apache.kudu.client.KuduClient.joinAndHandleException(KuduClient.java:352)
	at org.apache.kudu.client.KuduClient.createTable(KuduClient.java:96)
	at org.yoleen.spark.KUDUApp$.createTable(KUDUApp.scala:42)
	at org.yoleen.spark.KUDUApp$.main(KUDUApp.scala:19)
	at org.yoleen.spark.KUDUApp.main(KUDUApp.scala)
	Suppressed: org.apache.kudu.client.KuduException$OriginalException: Original asynchronous stack trace
		at org.apache.kudu.client.AsyncKuduClient.tooManyAttemptsOrTimeout(AsyncKuduClient.java:1444)
		at org.apache.kudu.client.AsyncKuduClient.delayedSendRpcToTablet(AsyncKuduClient.java:1725)
		at org.apache.kudu.client.AsyncKuduClient.access$900(AsyncKuduClient.java:254)
		at org.apache.kudu.client.AsyncKuduClient$RetryRpcErrback.call(AsyncKuduClient.java:1102)
		at org.apache.kudu.client.AsyncKuduClient$RetryRpcErrback.call(AsyncKuduClient.java:1092)
		at com.stumbleupon.async.Deferred.doCall(Deferred.java:1280)
		at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1259)
		at com.stumbleupon.async.Deferred.callback(Deferred.java:1002)
		at org.apache.kudu.client.ConnectToCluster.incrementCountAndCheckExhausted(ConnectToCluster.java:291)
		at org.apache.kudu.client.ConnectToCluster.access$100(ConnectToCluster.java:49)
		at org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB.call(ConnectToCluster.java:365)
		at org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB.call(ConnectToCluster.java:354)
		at com.stumbleupon.async.Deferred.doCall(Deferred.java:1280)
		at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1259)
		at com.stumbleupon.async.Deferred.handleContinuation(Deferred.java:1315)
		at com.stumbleupon.async.Deferred.doCall(Deferred.java:1286)
		at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1259)
		at com.stumbleupon.async.Deferred.callback(Deferred.java:1002)
		at org.apache.kudu.client.KuduRpc.handleCallback(KuduRpc.java:246)
		at org.apache.kudu.client.KuduRpc.errback(KuduRpc.java:300)
		at org.apache.kudu.client.RpcProxy.failOrRetryRpc(RpcProxy.java:388)
		at org.apache.kudu.client.RpcProxy.responseReceived(RpcProxy.java:217)
		at org.apache.kudu.client.RpcProxy.access$000(RpcProxy.java:60)
		at org.apache.kudu.client.RpcProxy$1.call(RpcProxy.java:132)
		at org.apache.kudu.client.RpcProxy$1.call(RpcProxy.java:128)
		at org.apache.kudu.client.Connection.cleanup(Connection.java:715)
		at org.apache.kudu.client.Connection.exceptionCaught(Connection.java:460)
		at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
		at org.apache.kudu.client.Connection.handleUpstream(Connection.java:244)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
		at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.exceptionCaught(SimpleChannelUpstreamHandler.java:153)
		at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
		at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.exceptionCaught(SimpleChannelUpstreamHandler.java:153)
		at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
		at org.apache.kudu.shaded.org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:60)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
		at org.apache.kudu.shaded.org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
		at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
		at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
		at org.apache.kudu.shaded.org.jboss.netty.channel.Channels.fireExceptionCaught(Channels.java:525)
		at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:74)
		at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
		at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
		at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
		at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
		at org.apache.kudu.shaded.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
		at org.apache.kudu.shaded.org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
		at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.kudu.client.NoLeaderFoundException: Master config (hadoop000:7051) has no leader. Exceptions received: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xbb7bfa64, /192.168.1.5:50612 => hadoop000/47.113.90.32:7051]
	at org.apache.kudu.client.ConnectToCluster.incrementCountAndCheckExhausted(ConnectToCluster.java:289)
	at org.apache.kudu.client.ConnectToCluster.access$100(ConnectToCluster.java:49)
	at org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB.call(ConnectToCluster.java:365)
	at org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB.call(ConnectToCluster.java:354)
	at com.stumbleupon.async.Deferred.doCall(Deferred.java:1280)
	at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1259)
	at com.stumbleupon.async.Deferred.handleContinuation(Deferred.java:1315)
	at com.stumbleupon.async.Deferred.doCall(Deferred.java:1286)
	at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1259)
	at com.stumbleupon.async.Deferred.callback(Deferred.java:1002)
	at org.apache.kudu.client.KuduRpc.handleCallback(KuduRpc.java:246)
	at org.apache.kudu.client.KuduRpc.errback(KuduRpc.java:300)
	at org.apache.kudu.client.RpcProxy.failOrRetryRpc(RpcProxy.java:388)
	at org.apache.kudu.client.RpcProxy.responseReceived(RpcProxy.java:217)
	at org.apache.kudu.client.RpcProxy.access$000(RpcProxy.java:60)
	at org.apache.kudu.client.RpcProxy$1.call(RpcProxy.java:132)
	at org.apache.kudu.client.RpcProxy$1.call(RpcProxy.java:128)
	at org.apache.kudu.client.Connection.cleanup(Connection.java:715)
	at org.apache.kudu.client.Connection.exceptionCaught(Connection.java:460)
	at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
	at org.apache.kudu.client.Connection.handleUpstream(Connection.java:244)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.exceptionCaught(SimpleChannelUpstreamHandler.java:153)
	at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.exceptionCaught(SimpleChannelUpstreamHandler.java:153)
	at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.apache.kudu.shaded.org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:60)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.apache.kudu.shaded.org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
	at org.apache.kudu.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:112)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.apache.kudu.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.apache.kudu.shaded.org.jboss.netty.channel.Channels.fireExceptionCaught(Channels.java:525)
	at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:74)
	at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.apache.kudu.shaded.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.apache.kudu.shaded.org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.kudu.client.RecoverableException: [peer master-hadoop000:7051(hadoop000:7051)] unexpected exception from downstream on [id: 0xbb7bfa64, /192.168.1.5:50612 => hadoop000/47.113.90.32:7051]
	at org.apache.kudu.client.Connection.exceptionCaught(Connection.java:456)
	... 30 more
Caused by: java.io.IOException: 远程主机强迫关闭了一个现有的连接。
	at sun.nio.ch.SocketDispatcher.read0(Native Method)
	at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
	at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
	at sun.nio.ch.IOUtil.read(IOUtil.java:192)
	at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
	at org.apache.kudu.shaded.org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64)
	... 9 more

Process finished with exit code 1

master.gflagfile 中的配置

--fs_wal_dir=/data/kudu/kudu_master_data
--fs_data_dirs=/data/kudu/kudu_master_data
--rpc_encryption=disabled
--rpc_authentication=disabled
--trusted_subnets=0.0.0.0/0

tserver.gflagfile 中的配置

--fs_wal_dir=/data/kudu/kudu_tserver_data
--fs_data_dirs=/data/kudu/kudu_tserver_data
--tserver_master_addrs=hadoop000:7051
--rpc_encryption=disabled
--rpc_authentication=disabled
--trusted_subnets=0.0.0.0/0

求大佬帮我解决,谷歌上的方法试过很多了T-T

写回答

1回答

慕标2366677

提问者

2020-05-22

查看日志后发现,原来服务没有正常启动,虽然启动时报了ok,在日志中发现缺少了一些插件。

通过以下命令成功解决。

yum install gcc python-devel
yum install cyrus-sasl*

3
0

SparkSQL入门 整合Kudu实现广告业务数据分析

大数据工程师干货课程 带你从入门到实战掌握SparkSQL

535 学习 · 192 问题

查看课程