Merge pull request #299 from alex268/master

Fixed NPE and logs

Author: alex268

core/src/main/java/tech/ydb/core/impl/call/ReadStreamCall.java

@@ -114,7 +114,7 @@ public void onMessage(RespT message) {
     @Override
     public void onClose(io.grpc.Status status, @Nullable Metadata trailers) {
         if (logger.isTraceEnabled()) {
-            logger.trace("ReadStreamCall[{}] closed with status {}", status);
+            logger.trace("ReadStreamCall[{}] closed with status {}", traceId, status);
         }
 
         statusConsumer.accept(status, trailers);

query/src/main/java/tech/ydb/query/impl/SessionImpl.java

@@ -275,12 +275,16 @@ public CompletableFuture<Result<QueryInfo>> execute(PartsHandler handler) {
                     handleTxMeta(msg.getTxMeta());
                 }
                 if (issues.length > 0) {
-                    handler.onIssues(issues);
+                    if (handler != null) {
+                        handler.onIssues(issues);
+                    } else {
+                        logger.trace("{} lost issues message", SessionImpl.this);
+                    }
                 }
                 if (msg.hasExecStats()) {
                     QueryStats old = stats.getAndSet(new QueryStats(msg.getExecStats()));
                     if (old != null) {
-                        logger.warn("{} got lost previous exec stats {}", SessionImpl.this, old);
+                        logger.warn("{} lost previous exec stats {}", SessionImpl.this, old);
                     }
                 }
 
@@ -289,7 +293,7 @@ public CompletableFuture<Result<QueryInfo>> execute(PartsHandler handler) {
                     if (handler != null) {
                         handler.onNextPart(new QueryResultPart(index, msg.getResultSet()));
                     } else {
-                        logger.warn("{} got lost result set part with index {}", SessionImpl.this, index);
+                        logger.trace("{} lost result set part with index {}", SessionImpl.this, index);
                     }
                 }
             }).whenComplete((status, th) -> {