Package org.apache.hadoop.ipc

Examples of org.apache.hadoop.ipc.RemoteException

243
244
245
246
247
248
249
250
251
      if (num_calls > num_calls_allowed) {
        throw new IOException("addBlock called more times than "
                              + RETRY_CONFIG
                              + " allows.");
      } else {
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    ADD_BLOCK_EXCEPTION);
      }
    }
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
89
90
91
        @Override
        public boolean shouldRetry(Exception e, int retries) throws Exception {
          //see (1) and (2) in the javadoc of this method.
          final RetryPolicy p;
          if (e instanceof RemoteException) {
            final RemoteException re = (RemoteException)e;
            RetryPolicy found = null;
            for(Class<? extends Exception> reToRetry : remoteExceptionsToRetry) {
              if (reToRetry.getName().equals(re.getClassName())) {
                found = multipleLinearRandomRetry;
                break;
              }
            }
            p = found != null? found: RetryPolicies.TRY_ONCE_THEN_FAIL;         
View Full Code Here
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
          if (call != null) {
            call.setValue(value);
          }
        } else if (state == Status.ERROR.state) {
          if (call != null) {
            call.setException(new RemoteException(WritableUtils.readString(in), WritableUtils
                .readString(in)));
          }
        } else if (state == Status.FATAL.state) {
          RemoteException exception = new RemoteException(WritableUtils.readString(in),
              WritableUtils.readString(in));
          // the call will be removed from call map, we must set Exception here to notify
          // the thread waited on the call
          if (call != null) {
            call.setException(exception);
View Full Code Here
320
321
322
323
324
325
326
327
328
329
            + ", message=" + conn.getResponseMessage());
      } else if (m.get(RemoteException.class.getSimpleName()) == null) {
        return m;
      }

      final RemoteException re = JsonUtil.toRemoteException(m);
      throw unwrapException? toIOException(re): re;
    }
    return null;
  }
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
        retryCount++;
        System.out.println("addBlock has been called "  + retryCount + " times");
        if(retryCount > maxRetries + 1) // First call was not a retry
          throw new IOException("Retried too many times: " + retryCount);
        else
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    exceptionMsg);
      }
    };
    when(mockNN.addBlock(anyString(),
                         anyString(),
View Full Code Here
152
153
154
155
156
157
158
  /** Convert a Json map to a RemoteException. */
  public static RemoteException toRemoteException(final Map<?, ?> json) {
    final Map<?, ?> m = (Map<?, ?>)json.get(RemoteException.class.getSimpleName());
    final String message = (String)m.get("message");
    final String javaClassName = (String)m.get("javaClassName");
    return new RemoteException(javaClassName, message);
  }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
      try {
        final MD5MD5CRC32FileChecksum checksum = DFSClient.getFileChecksum(
            filename, nnproxy, socketFactory, socketTimeout);
        MD5MD5CRC32FileChecksum.write(xml, checksum);
      } catch(IOException ioe) {
        new RemoteException(ioe.getClass().getName(), ioe.getMessage()
            ).writeXml(filename, xml);
      }
      xml.endDocument();
    }
View Full Code Here
106
107
108
109
110
111
112
113
114
  }

  private static void readStatus(DataInputStream inStream) throws IOException {
    int status = inStream.readInt(); // read status
    if (status != SaslStatus.SUCCESS.state) {
      throw new RemoteException(WritableUtils.readString(inStream),
          WritableUtils.readString(inStream));
    }
  }
View Full Code Here
351
352
353
354
355
356
357
358
359
360
361
      responseWrapper.readFields(inStream);
      RpcResponseHeaderProto header = responseWrapper.getMessageHeader();
      switch (header.getStatus()) {
        case ERROR: // might get a RPC error during
        case FATAL:
          throw new RemoteException(header.getExceptionClassName(),
                                    header.getErrorMsg());
        default: break;
      }
      if (totalLen != responseWrapper.getLength()) {
        throw new SaslException("Received malformed response length");
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
        retryCount++;
        System.out.println("addBlock has been called "  + retryCount + " times");
        if(retryCount > maxRetries + 1) // First call was not a retry
          throw new IOException("Retried too many times: " + retryCount);
        else
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    exceptionMsg);
      }
    };
    when(mockNN.addBlock(anyString(),
                         anyString(),
View Full Code Here
TOP

Related Classes of org.apache.hadoop.ipc.RemoteException

  • com.alibaba.wasp.ipc.NettyTransceiver
  • org.apache.hadoop.fs.shell.TestAclCommands$StubFileSystem
  • org.apache.hadoop.fs.shell.TestPathExceptions
  • org.apache.hadoop.hbase.client.ConnectionManager
  • org.apache.hadoop.hbase.client.HConnectionManager
  • org.apache.hadoop.hbase.client.TestFastFailWithoutTestUtil
  • org.apache.hadoop.hbase.ipc.HBaseClient$Connection
  • org.apache.hadoop.hbase.ipc.RpcClient$Connection
  • org.apache.hadoop.hbase.ipc.SecureClient$SecureConnection
  • org.apache.hadoop.hbase.security.HBaseSaslRpcClient
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.