Guest User

Untitled

a guest
Sep 19th, 2016
121
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 19.75 KB | None | 0 0
  1. 2016-09-19 13:00:37,941 WARN  org.apache.hadoop.hdfs.DFSClient                              - DataStreamer Exception
  2. java.io.FileNotFoundException: ID mismatch. Request id and saved id: 1403418 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  3.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  4.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  5.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  6.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  7.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  8.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  9.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  10.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  11.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  12.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  13.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  14.     at java.security.AccessController.doPrivileged(Native Method)
  15.     at javax.security.auth.Subject.doAs(Subject.java:422)
  16.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  17.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  18.  
  19.     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  20.     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  21.     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  22.     at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  23.     at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:106)
  24.     at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:73)
  25.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1442)
  26.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.nextBlockOutputStream(DFSOutputStream.java:1261)
  27.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.run(DFSOutputStream.java:525)
  28. Caused by: org.apache.hadoop.ipc.RemoteException(java.io.FileNotFoundException): ID mismatch. Request id and saved id: 1403418 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  29.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  30.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  31.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  32.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  33.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  34.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  35.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  36.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  37.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  38.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  39.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  40.     at java.security.AccessController.doPrivileged(Native Method)
  41.     at javax.security.auth.Subject.doAs(Subject.java:422)
  42.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  43.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  44.  
  45.     at org.apache.hadoop.ipc.Client.call(Client.java:1410)
  46.     at org.apache.hadoop.ipc.Client.call(Client.java:1363)
  47.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
  48.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  49.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  50.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  51.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  52.     at java.lang.reflect.Method.invoke(Method.java:498)
  53.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:190)
  54.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:103)
  55.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  56.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.addBlock(ClientNamenodeProtocolTranslatorPB.java:361)
  57.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1439)
  58.     ... 2 more
  59. 2016-09-19 13:00:37,951 ERROR org.apache.flink.runtime.blob.BlobServerConnection            - PUT operation failed
  60. java.io.FileNotFoundException: ID mismatch. Request id and saved id: 1403418 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  61.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  62.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  63.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  64.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  65.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  66.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  67.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  68.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  69.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  70.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  71.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  72.     at java.security.AccessController.doPrivileged(Native Method)
  73.     at javax.security.auth.Subject.doAs(Subject.java:422)
  74.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  75.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  76.  
  77.     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  78.     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  79.     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  80.     at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  81.     at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:106)
  82.     at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:73)
  83.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1442)
  84.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.nextBlockOutputStream(DFSOutputStream.java:1261)
  85.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.run(DFSOutputStream.java:525)
  86. Caused by: org.apache.hadoop.ipc.RemoteException(java.io.FileNotFoundException): ID mismatch. Request id and saved id: 1403418 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  87.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  88.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  89.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  90.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  91.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  92.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  93.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  94.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  95.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  96.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  97.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  98.     at java.security.AccessController.doPrivileged(Native Method)
  99.     at javax.security.auth.Subject.doAs(Subject.java:422)
  100.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  101.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  102.  
  103.     at org.apache.hadoop.ipc.Client.call(Client.java:1410)
  104.     at org.apache.hadoop.ipc.Client.call(Client.java:1363)
  105.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
  106.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  107.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  108.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  109.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  110.     at java.lang.reflect.Method.invoke(Method.java:498)
  111.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:190)
  112.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:103)
  113.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  114.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.addBlock(ClientNamenodeProtocolTranslatorPB.java:361)
  115.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1439)
  116.     ... 2 more
  117. 2016-09-19 13:00:37,944 WARN  org.apache.hadoop.hdfs.DFSClient                              - DataStreamer Exception
  118. java.io.FileNotFoundException: ID mismatch. Request id and saved id: 1403417 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  119.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  120.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  121.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  122.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  123.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  124.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  125.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  126.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  127.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  128.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  129.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  130.     at java.security.AccessController.doPrivileged(Native Method)
  131.     at javax.security.auth.Subject.doAs(Subject.java:422)
  132.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  133.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  134.  
  135.     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  136.     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  137.     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  138.     at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  139.     at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:106)
  140.     at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:73)
  141.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1442)
  142.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.nextBlockOutputStream(DFSOutputStream.java:1261)
  143.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.run(DFSOutputStream.java:525)
  144. Caused by: org.apache.hadoop.ipc.RemoteException(java.io.FileNotFoundException): ID mismatch. Request id and saved id: 1403417 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  145.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  146.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  147.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  148.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  149.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  150.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  151.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  152.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  153.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  154.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  155.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  156.     at java.security.AccessController.doPrivileged(Native Method)
  157.     at javax.security.auth.Subject.doAs(Subject.java:422)
  158.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  159.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  160.  
  161.     at org.apache.hadoop.ipc.Client.call(Client.java:1410)
  162.     at org.apache.hadoop.ipc.Client.call(Client.java:1363)
  163.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
  164.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  165.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  166.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  167.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  168.     at java.lang.reflect.Method.invoke(Method.java:498)
  169.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:190)
  170.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:103)
  171.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  172.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.addBlock(ClientNamenodeProtocolTranslatorPB.java:361)
  173.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1439)
  174.     ... 2 more
  175. 2016-09-19 13:00:37,967 ERROR org.apache.flink.runtime.blob.BlobServerConnection            - PUT operation failed
  176. java.io.FileNotFoundException: ID mismatch. Request id and saved id: 1403417 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  177.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  178.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  179.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  180.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  181.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  182.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  183.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  184.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  185.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  186.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  187.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  188.     at java.security.AccessController.doPrivileged(Native Method)
  189.     at javax.security.auth.Subject.doAs(Subject.java:422)
  190.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  191.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  192.  
  193.     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  194.     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  195.     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  196.     at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  197.     at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:106)
  198.     at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:73)
  199.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1442)
  200.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.nextBlockOutputStream(DFSOutputStream.java:1261)
  201.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.run(DFSOutputStream.java:525)
  202. Caused by: org.apache.hadoop.ipc.RemoteException(java.io.FileNotFoundException): ID mismatch. Request id and saved id: 1403417 , 1403419 for file /flink/flink-recovery/blob/cache/blob_ad21c112f0f6698cf976002afd75a44c9d48e68f
  203.     at org.apache.hadoop.hdfs.server.namenode.INodeId.checkId(INodeId.java:53)
  204.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.checkLease(FSNamesystem.java:2976)
  205.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.analyzeFileState(FSNamesystem.java:2772)
  206.     at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2680)
  207.     at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.addBlock(NameNodeRpcServer.java:590)
  208.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.addBlock(ClientNamenodeProtocolServerSideTranslatorPB.java:440)
  209.     at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
  210.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:585)
  211.     at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:928)
  212.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2013)
  213.     at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:2009)
  214.     at java.security.AccessController.doPrivileged(Native Method)
  215.     at javax.security.auth.Subject.doAs(Subject.java:422)
  216.     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1594)
  217.     at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2007)
  218.  
  219.     at org.apache.hadoop.ipc.Client.call(Client.java:1410)
  220.     at org.apache.hadoop.ipc.Client.call(Client.java:1363)
  221.     at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
  222.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  223.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  224.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  225.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  226.     at java.lang.reflect.Method.invoke(Method.java:498)
  227.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:190)
  228.     at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:103)
  229.     at com.sun.proxy.$Proxy11.addBlock(Unknown Source)
  230.     at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.addBlock(ClientNamenodeProtocolTranslatorPB.java:361)
  231.     at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.locateFollowingBlock(DFSOutputStream.java:1439)
  232.     ... 2 more
Advertisement
Add Comment
Please, Sign In to add comment