nsivabalan

/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home/bin/java -ea -Dlog4j.configuration=file:///Users/sivabala/Documents/personal/projects/siva_hudi/apache_hudi/hudi/hudi-utilities/src/test/resources/log4j-surefire.properties -Didea.test.cyclic.buffer.size=1048576000 -javaagent:/Applications/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar=59745:/Applications/IntelliJ IDEA CE.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Applications/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar:/Applications/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit5-rt.jar:/Applications/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit-rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMac

nsivabalan

package io.grpc.examples.routeguide;

import com.google.common.annotations.VisibleForTesting;
import com.google.protobuf.Message;
import io.grpc.Channel;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.Status;
import io.grpc.StatusRuntimeException;
import io.grpc.examples.routeguide.RouteGuideGrpc.RouteGuideBlockingStub;

nsivabalan

20/10/22 21:02:34 ERROR DagScheduler: Exception executing node
20/10/22 21:02:34 ERROR HoodieTestSuiteJob: Failed to run Test Suite 
java.util.concurrent.ExecutionException: org.apache.hudi.exception.HoodieException: java.lang.NullPointerException
	at java.util.concurrent.FutureTask.report(FutureTask.java:122)
	at java.util.concurrent.FutureTask.get(FutureTask.java:206)
	at org.apache.hudi.integ.testsuite.dag.scheduler.DagScheduler.execute(DagScheduler.java:112)
	at org.apache.hudi.integ.testsuite.dag.scheduler.DagScheduler.schedule(DagScheduler.java:69)
	at org.apache.hudi.integ.testsuite.HoodieTestSuiteJob.runTestSuite(HoodieTestSuiteJob.java:137)
	at org.apache.hudi.integ.testsuite.HoodieTestSuiteJob.main(HoodieTestSuiteJob.java:117)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

nsivabalan

package com.ubercab.network.ramengrpc;

public class FetchTokenResponse {

  private Throwable throwable;
  private String token;

  public FetchTokenResponse(String token){
    this.token = token;
  }

nsivabalan

public class ValidateDatasetNode extends DagNode<Boolean> {

  private static Logger log = LoggerFactory.getLogger(ValidateDatasetNode.class);

  public ValidateDatasetNode(Config config) {
    this.config = config;
  }

  @Override
  public void execute(ExecutionContext context) throws Exception {

nsivabalan

20/10/13 00:32:48 ERROR HoodieTestSuiteJob: Failed to run Test Suite 
java.util.concurrent.ExecutionException: java.lang.NoSuchFieldError: HIVE_STATS_JDBC_TIMEOUT
	at java.util.concurrent.FutureTask.report(FutureTask.java:122)
	at java.util.concurrent.FutureTask.get(FutureTask.java:206)
	at org.apache.hudi.integ.testsuite.dag.scheduler.DagScheduler.execute(DagScheduler.java:109)
	at org.apache.hudi.integ.testsuite.dag.scheduler.DagScheduler.schedule(DagScheduler.java:68)
	at org.apache.hudi.integ.testsuite.HoodieTestSuiteJob.runTestSuite(HoodieTestSuiteJob.java:137)
	at org.apache.hudi.integ.testsuite.HoodieTestSuiteJob.main(HoodieTestSuiteJob.java:117)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

nsivabalan

package com.ubercab.ramen.proto.test.helloworld;

import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
import static io.grpc.stub.ClientCalls.asyncUnaryCall;
import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
import static io.grpc.stub.ClientCalls.futureUnaryCall;

nsivabalan

public class CustomStopWatch2 implements Runnable {

  private final long timeoutMs;
  private final TimeoutCallBack callBack;
  private AtomicBoolean eventTriggered = new AtomicBoolean(false);
  private AtomicBoolean shutdownInvoked = new AtomicBoolean(false);
  private AtomicBoolean paused = new AtomicBoolean(false);
  private Lock lock = new ReentrantLock();
  private Condition awaitCondition = lock.newCondition();

nsivabalan

/** Interface to fetch access token by triggering a network call to backend. */
public interface OAuthTokenFetcher {

 /**
  * Make a remote network call to fetch access token. Implementation should ensure only one remote
  * call is in flux at any point in time.
  *
  * @param oldAccessToken old access token.
  * @param isBlocking true if blocking, else false.
  * @return the access token.

nsivabalan

package com.ubercab.network.ramengrpc;

import com.uber.streaming.ramen.RamenStreamingResponse;
import io.grpc.stub.StreamObserver;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

public class ConnectionManager {

  private ConnectionState curConnectionState = ConnectionState.Disconected;