Spring Boot Yarn onContainerFailed method diagnostics message

Suppose that we have an SBY application, which includes AppMaster and Container. When the container falls due to an exception, we need to send exception text to the AppMaster. When the container falls, the AppMaster’s onContainerFailed() method is automatically called: The method is in the StaticEventingAppmaster class. Your AppMaster must be inherited from it. We […]

READ MORE

How to run HBase utility class from Java

Suppose you need to run HBase utility class from Java code. Such a class will have a main() method, which we will use. For demonstrating, we will use RowSplitter class. Firstly, we need to add the hbase-server module (for example, version 1.2.3) to pom.xml: In some our own class, let’s call RegionSplitter’s main(): If you […]

READ MORE

Cancelling gRPC server-streaming call from client

When using gRPC server-streaming call, you may need to interrupt the execution of the request on the server from the client side.  We have a service on the server: And the sendRequest() method on the client: Suppose, that at some moment we need to send a message from the client to the server that the […]

READ MORE