Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C2BD017D89 for ; Wed, 23 Sep 2015 09:16:32 +0000 (UTC) Received: (qmail 55990 invoked by uid 500); 23 Sep 2015 09:16:27 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 55921 invoked by uid 500); 23 Sep 2015 09:16:27 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 55912 invoked by uid 99); 23 Sep 2015 09:16:27 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 23 Sep 2015 09:16:27 +0000 Received: from mail-la0-f50.google.com (mail-la0-f50.google.com [209.85.215.50]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id D08CB1A009C for ; Wed, 23 Sep 2015 09:16:26 +0000 (UTC) Received: by lacao8 with SMTP id ao8so19647505lac.3 for ; Wed, 23 Sep 2015 02:16:25 -0700 (PDT) X-Received: by 10.112.202.35 with SMTP id kf3mr1323162lbc.19.1442999785460; Wed, 23 Sep 2015 02:16:25 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Aljoscha Krettek Date: Wed, 23 Sep 2015 09:16:16 +0000 Message-ID: Subject: Re: HBase issue To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a11c377a29f9dcb0520669148 --001a11c377a29f9dcb0520669148 Content-Type: text/plain; charset=UTF-8 It might me that this is causing the problem: https://issues.apache.org/jira/browse/HBASE-10304 In your log I see the same exception. Anyone has any idea what we could do about this? On Tue, 22 Sep 2015 at 22:40 Lydia Ickler wrote: > Hi, > > I am trying to get the HBaseReadExample to run. I have filled a table with > the HBaseWriteExample and purposely split it over 3 regions. > Now when I try to read from it the first split seems to be scanned (170 > rows) fine and after that the Connections of Zookeeper and RCP are suddenly > closed down. > > Does anyone has an idea why this is happening? > > Best regards, > Lydia > > > 22:28:10,178 DEBUG org.apache.flink.runtime.operators.DataSourceTask > - Opening input split Locatable Split (2) at [grips5:60020]: > DataSource (at createInput(ExecutionEnvironment.java:502) > (org.apache.flink.HBaseReadExample$1)) (1/1) > 22:28:10,178 INFO org.apache.flink.addons.hbase.TableInputFormat > - opening split [2|[grips5:60020]|aaaaaaaa|-] > 22:28:10,189 DEBUG org.apache.zookeeper.ClientCnxn > - Reading reply sessionid:0x24ff6a96ecd000a, packet:: clientPath:null > serverPath:null finished:false header:: 3,4 replyHeader:: 3,51539607639,0 > request:: '/hbase/meta-region-server,F response:: > #ffffffff0001a726567696f6e7365727665723a363030$ > 22:28:10,202 DEBUG org.apache.zookeeper.ClientCnxn > - Reading reply sessionid:0x24ff6a96ecd000a, packet:: clientPath:null > serverPath:null finished:false header:: 4,4 replyHeader:: 4,51539607639,0 > request:: '/hbase/meta-region-server,F response:: > #ffffffff0001a726567696f6e7365727665723a363030$ > 22:28:10,211 DEBUG LocalActorRefProvider(akka://flink) > - resolve of path sequence [/temp/$b] failed > 22:28:10,233 DEBUG org.apache.hadoop.hbase.util.ByteStringer > - Failed to classload HBaseZeroCopyByteString: > java.lang.IllegalAccessError: class > com.google.protobuf.HBaseZeroCopyByteString cannot access its superclass > com.google.protobuf.LiteralByteString > 22:28:10,358 DEBUG org.apache.hadoop.ipc.RpcClient > - Use SIMPLE authentication for service ClientService, sasl=false > 22:28:10,370 DEBUG org.apache.hadoop.ipc.RpcClient > - Connecting to grips1/130.73.20.14:60020 > 22:28:10,380 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: starting, connections 1 > 22:28:10,394 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: got response header call_id: 0, totalSize: 469 bytes > 22:28:10,397 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: wrote request header call_id: 0 method_name: "Get" > request_param: true > 22:28:10,413 DEBUG org.apache.zookeeper.ClientCnxn > - Reading reply sessionid:0x24ff6a96ecd000a, packet:: clientPath:null > serverPath:null finished:false header:: 5,4 replyHeader:: 5,51539607639,0 > request:: '/hbase/meta-region-server,F response:: > #ffffffff0001a726567696f6e7365727665723a363030$ > 22:28:10,424 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: wrote request header call_id: 1 method_name: "Scan" > request_param: true priority: 100 > 22:28:10,426 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: got response header call_id: 1 cell_block_meta { length: 480 > }, totalSize: 497 bytes > 22:28:10,432 DEBUG org.apache.hadoop.hbase.client.ClientSmallScanner > - Finished with small scan at {ENCODED => 1588230740, NAME => > 'hbase:meta,,1', STARTKEY => '', ENDKEY => ''} > 22:28:10,434 DEBUG org.apache.hadoop.ipc.RpcClient > - Use SIMPLE authentication for service ClientService, sasl=false > 22:28:10,434 DEBUG org.apache.hadoop.ipc.RpcClient > - Connecting to grips5/130.73.20.16:60020 > 22:28:10,435 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: wrote request header call_id: 2 method_name: "Scan" > request_param: true > 22:28:10,436 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: starting, connections 2 > 22:28:10,437 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: got response header call_id: 2, totalSize: 12 bytes > 22:28:10,438 DEBUG org.apache.flink.runtime.operators.DataSourceTask > - Starting to read input from split Locatable Split (2) at > [grips5:60020]: DataSource (at createInput(ExecutionEnvironment.java:502) > (org.apache.flink.HBaseReadExample$1)) (1/1) > 22:28:10,438 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: wrote request header call_id: 3 method_name: "Scan" > request_param: true > 22:28:10,457 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: got response header call_id: 3 cell_block_meta { length: 4679 > }, totalSize: 4899 bytes > 22:28:10,476 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: wrote request header call_id: 4 method_name: "Scan" > request_param: true > 22:28:10,480 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: got response header call_id: 4 cell_block_meta { length: 3306 > }, totalSize: 3466 bytes > 22:28:10,482 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: got response header call_id: 5, totalSize: 8 bytes > 22:28:10,482 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: wrote request header call_id: 5 method_name: "Scan" > request_param: true > 22:28:10,487 DEBUG org.apache.flink.runtime.operators.DataSourceTask > - Closing input split Locatable Split (2) at [grips5:60020]: > DataSource (at createInput(ExecutionEnvironment.java:502) > (org.apache.flink.HBaseReadExample$1)) (1/1) > 22:28:10,489 INFO > org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation > - Closing zookeeper sessionid=0x24ff6a96ecd000a > 22:28:10,489 DEBUG org.apache.zookeeper.ZooKeeper > - Closing session: 0x24ff6a96ecd000a > 22:28:10,489 DEBUG org.apache.zookeeper.ClientCnxn > - Closing client for session: 0x24ff6a96ecd000a > 22:28:10,499 DEBUG org.apache.zookeeper.ClientCnxn > - Reading reply sessionid:0x24ff6a96ecd000a, packet:: clientPath:null > serverPath:null finished:false header:: 6,-11 replyHeader:: > 6,51539607640,0 request:: null response:: null > 22:28:10,499 DEBUG org.apache.zookeeper.ClientCnxn > - Disconnecting client for session: 0x24ff6a96ecd000a > 22:28:10,499 INFO org.apache.zookeeper.ClientCnxn > - EventThread shut down > 22:28:10,499 INFO org.apache.zookeeper.ZooKeeper > - Session: 0x24ff6a96ecd000a closed > 22:28:10,499 DEBUG org.apache.hadoop.ipc.RpcClient > - Stopping rpc client > 22:28:10,501 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: closed > 22:28:10,502 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 > from hduser: stopped, connections 0 > 22:28:10,502 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: closed > 22:28:10,502 DEBUG org.apache.hadoop.ipc.RpcClient > - IPC Client (2145423150) connection to grips5/130.73.20.16:60020 > from hduser: stopped, connections 0 > 22:28:10,502 INFO org.apache.flink.addons.hbase.TableInputFormat > - Closing split (scanned 170 rows) > 22:28:10,508 DEBUG org.apache.flink.runtime.operators.DataSourceTask > - Opening input split Locatable Split (1) at [grips4:60020]: > DataSource (at createInput(ExecutionEnvironment.java:502) > (org.apache.flink.HBaseReadExample$1)) (1/1) > 22:28:10,509 INFO org.apache.flink.addons.hbase.TableInputFormat > - opening split [1|[grips4:60020]|55555555|aaaaaaaa] > 22:28:11,380 DEBUG org.apache.flink.runtime.taskmanager.TaskManager > - Received message SendHeartbeat at akka://flink/user/taskmanager > from Actor[akka://flink/deadLetters]. > 22:28:11,380 DEBUG org.apache.flink.runtime.taskmanager.TaskManager > - Sending heartbeat to JobManager > > --001a11c377a29f9dcb0520669148 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
It might me that this is causing the problem:=C2=A0https://issues.apach= e.org/jira/browse/HBASE-10304

In your log I see the = same exception. Anyone has any idea what we could do about this?

On Tue, 22 Sep 2015 at 22:40 Lydia= Ickler <icklerly@googlemail.= com> wrote:
Hi,=C2=A0

I a= m trying to get the HBaseReadExample to run. I have filled a table with the= HBaseWriteExample and purposely split it over 3 regions.
Now when I try to read fro= m it the first split seems to be scanned (170 rows) fine and after that the= Connections of Zookeeper and RCP are suddenly closed down.

Does anyone has an idea why this= is happening?

Be= st regards,
Lydia=C2=A0


=
22:28:10,1= 78 DEBUG org.apache.flink.runtime.operators.DataSourceTask =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Opening input split Locatable Split (2) at [g= rips5:60020]:=C2=A0 DataSource (at createInput(ExecutionEnvironment.java:50= 2) (org.apache.flink.HBaseReadExample$1)) (1/1)
22:28:10,178 INFO=C2=A0 org.apache.fli= nk.addons.hbase.TableInputFormat=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 - opening split [2|[grips5:60020]|aaaaaaaa|-]
22:28:10,189 DEBUG org.apa= che.zookeeper.ClientCnxn =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Reading reply ses= sionid:0x24ff6a96ecd000a, packet:: clientPath:null serverPath:null finished= :false header:: 3,4=C2=A0 replyHeader:: 3,51539607639,0=C2=A0 request:: = 9;/hbase/meta-region-server,F=C2=A0 response:: #ffffffff0001a726567696f6e73= 65727665723a363030$
22:28:10,202 DEBUG org.apache.zookeeper.ClientCnxn =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 - Reading reply sessionid:0x24ff6a96ecd000a, packet:: cli= entPath:null serverPath:null finished:false header:: 4,4=C2=A0 replyHeader:= : 4,51539607639,0=C2=A0 request:: '/hbase/meta-region-server,F=C2=A0 re= sponse:: #ffffffff0001a726567696f6e7365727665723a363030$
22:28:10,211 DEBUG LocalActor= RefProvider(akka://flink) =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - resolve of path sequence= [/temp/$b] failed
22:28:10,233 DEBUG org.apache.hadoop.hbase.util.ByteStringer =C2=A0= =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Failed to= classload HBaseZeroCopyByteString: java.lang.IllegalAccessError: class com= .google.protobuf.HBaseZeroCopyByteString cannot access its superclass com.g= oogle.protobuf.LiteralByteString
22:28:10,358 DEBUG org.apache.hadoop.ipc.RpcClient = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Use SIMPLE authentication for service Cli= entService, sasl=3Dfalse
22:28:10,370 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 - Connecting to grips1/130.73.20.14:60020
22:28:10,380 DEBUG org.apache.hadoop.i= pc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0= =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connec= tion to grips1/130.= 73.20.14:60020 from hduser: starting, connections 1
22:28:10,394 DEBUG org.apache.= hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (21454231= 50) connection to grips1/130.73.20.14:60020 from hduser: got response header call_id: 0, t= otalSize: 469 bytes
22:28:10,397 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection to grips1/130.73.20.14:60020 from h= duser: wrote request header call_id: 0 method_name: "Get" request= _param: true
22:28:10,413 DEBUG org.apache.zookeeper.ClientCnxn =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 - Reading reply sessionid:0x24ff6a96ecd000a, packet:: clientPath= :null serverPath:null finished:false header:: 5,4=C2=A0 replyHeader:: 5,515= 39607639,0=C2=A0 request:: '/hbase/meta-region-server,F=C2=A0 response:= : #ffffffff0001a726567696f6e7365727665723a363030$
22:28:10,424 DEBUG org.apache.hadoop= .ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) con= nection to grips1/1= 30.73.20.14:60020 from hduser: wrote request header call_id: 1 method_n= ame: "Scan" request_param: true priority: 100
22:28:10,426 DEBUG org.apache.= hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (21454231= 50) connection to grips1/130.73.20.14:60020 from hduser: got response header call_id: 1 ce= ll_block_meta { length: 480 }, totalSize: 497 bytes
22:28:10,432 DEBUG org.apache.hado= op.hbase.client.ClientSmallScanner =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 - Finished with small scan at {ENCODED =3D> 1588230740, NAME =3D>= 'hbase:meta,,1', STARTKEY =3D> '', ENDKEY =3D> '= '}
22:2= 8:10,434 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 - Use SIMPLE authentication for service ClientService, sasl=3Dfalse
22:28:10,434 DEBUG org.apache.hadoop.ipc.RpcCli= ent =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Connecting to grips5/130.73.20.16:60020
22:28:10,435 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0= =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection to grips5/130.73.20.16:60020= from hduser: wrote request header call_id: 2 method_name: "Scan"= request_param: true
22:28:10,436 DEBUG org.= apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2= 145423150) connection to grips5/130.73.20.16:60020 from hduser: starting, connections 2
22:28:10,437 DEBUG org.apache.hadoop.ipc.RpcCl= ient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection to = grips5/130.73.20.16= :60020 from hduser: got response header call_id: 2, totalSize: 12 bytes=
22:28:10,438 DEBUG org.apache.flink.runtime= .operators.DataSourceTask =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Start= ing to read input from split Locatable Split (2) at [grips5:60020]:=C2=A0 D= ataSource (at createInput(ExecutionEnvironment.java:502) (org.apache.flink.= HBaseReadExample$1)) (1/1)
22:28:10,438 DEBU= G org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0= =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Clien= t (2145423150) connection to grips5/130.73.20.16:60020 from hduser: wrote request header c= all_id: 3 method_name: "Scan" request_param: true
22:28:10,457 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection to grips5/130.73.20.16:60020= from hduser: got response header call_id: 3 cell_block_meta { length: 4679= }, totalSize: 4899 bytes
22:28:10,476 DEBUG= org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client= (2145423150) connection to grips5/130.73.20.16:60020 from hduser: wrote request header ca= ll_id: 4 method_name: "Scan" request_param: true
22:28:10,480 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection to grips5/130.73.20.16:60020= from hduser: got response header call_id: 4 cell_block_meta { length: 3306= }, totalSize: 3466 bytes
22:28:10,482 DEBUG= org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client= (2145423150) connection to grips5/130.73.20.16:60020 from hduser: got response header cal= l_id: 5, totalSize: 8 bytes
22:28:10,482 DEB= UG org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Cl= ient (2145423150) connection to grips5/130.73.20.16:60020 from hduser: wrote request heade= r call_id: 5 method_name: "Scan" request_param: true
22:28:10,487 DEBUG org.apache.flink.runtime.operators.Da= taSourceTask =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Closing input spli= t Locatable Split (2) at [grips5:60020]:=C2=A0 DataSource (at createInput(E= xecutionEnvironment.java:502) (org.apache.flink.HBaseReadExample$1)) (1/1)<= /div>
22:28:10,489 INFO=C2=A0 org.apache.hadoop.hb= ase.client.HConnectionManager$HConnectionImplementation=C2=A0 - Closing zoo= keeper sessionid=3D0x24ff6a96ecd000a
22:28:1= 0,489 DEBUG org.apache.zookeeper.ZooKeeper=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 - Closing session: 0x24ff6a96ecd000a
= 22:28:10,489 DEBUG org.apache.zookeeper.ClientCnxn =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 - Closing client for session: 0x24ff6a96ecd000a
22:28:10,499 DEBUG org.apache.zookeeper.ClientCnxn =C2=A0 =C2=A0= =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 - Reading reply sessionid:0x24ff6a96ecd000a, packet:: cli= entPath:null serverPath:null finished:false header:: 6,-11=C2=A0 replyHeade= r:: 6,51539607640,0=C2=A0 request:: null response:: null
22:28:10,499 DEBUG org.apache.zookeeper.ClientCnxn =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 - Disconnecting client for session: 0x24ff6a96ecd000a<= /div>
22:28:10,499 INFO=C2=A0 org.apache.zookeeper= .ClientCnxn =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - EventThread shut down
22:28:10,499 INFO=C2=A0 org.apache.zookeeper.ZooKeepe= r=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Session: 0x24ff6a96ecd000a closed<= /div>
22:28:10,499 DEBUG org.apache.hadoop.ipc.Rpc= Client =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Stopping rpc client
22:28:10,501 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection to grips1/130.73.20.14:60020= from hduser: closed
22:28:10,502 DEBUG org.= apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2= 145423150) connection to grips1/130.73.20.14:60020 from hduser: stopped, connections 0
22:28:10,502 DEBUG org.apache.hadoop.ipc.R= pcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - IPC Client (2145423150) connection= to grips5/130.73.2= 0.16:60020 from hduser: closed
22:28:10,= 502 DEBUG org.apache.hadoop.ipc.RpcClient =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 -= IPC Client (2145423150) connection to grips5/130.73.20.16:60020 from hduser: stopped, con= nections 0
22:28:10,502 INFO=C2=A0 org.apach= e.flink.addons.hbase.TableInputFormat=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 - Closing split (scanned 170 rows)
22:28:10,508 DEBUG org.apache.flink.runtime.operators.DataSourceTa= sk =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Opening input split Locatabl= e Split (1) at [grips4:60020]:=C2=A0 DataSource (at createInput(ExecutionEn= vironment.java:502) (org.apache.flink.HBaseReadExample$1)) (1/1)
22:28:10,509 INFO=C2=A0 org.apache.flink.addons.hbase.= TableInputFormat=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - o= pening split [1|[grips4:60020]|55555555|aaaaaaaa]
22:28:11,380 DEBUG org.apache.flink.runtime.taskmanager.TaskManager= =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 - Received message SendHea= rtbeat at akka://flink/user/taskmanager from Actor[akka://flink/d= eadLetters].
22:28:11,380 DEBUG org.apac= he.flink.runtime.taskmanager.TaskManager=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 - Sending heartbeat to JobManager

<= /div>
--001a11c377a29f9dcb0520669148--