java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602
-
Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 
问题：Caused by: java.lang.RuntimeException: Record has Long.MIN_VALUE timestamp (= no times…