This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# | |
# A fatal error has been detected by the Java Runtime Environment: | |
# | |
# SIGSEGV (0xb) at pc=0x00007f5ad0db478f, pid=1, tid=527 | |
# | |
# JRE version: OpenJDK Runtime Environment JDK-11 | |
# Java VM: OpenJDK 64-Bit Server VM JDK-11 (mixed mode, tiered, compressed oops, g1 gc, linux-amd64) | |
# Problematic frame: | |
# V [libjvm.so+0x79478f] Exceptions::_throw_oop(Thread*, char const*, int, oopDesc*)+0x15f | |
# |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2022-05-06 03:06:04,960 i.j.o.p.e.ReconciliationDispatcher [ERROR Error during error status handling. | |
io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: PUT at: https://address/apis/flink.apache.org/v1beta1/namespaces/myns/flinkdeployments/flink-job/status. Message: Operation cannot be fulfilled on flinkdeployments.flink.apache.org "flink-job": the object has been modified; please apply your changes to the latest version and try again. Received status: Status(apiVersion=v1, code=409, details=StatusDetails(causes=[], group=flink.apache.org, kind=flinkdeployments, name=flink-job, retryAfterSeconds=null, uid=null, additionalProperties={}), kind=Status, message=Operation cannot be fulfilled on flinkdeployments.flink.apache.org "flink-job": the object has been modified; please apply your changes to the latest version and try again, metadata=ListMeta(_continue=null, remainingItemCount=null, resourceVersion=null, selfLink=null, additionalProperties={}), reason=Conflict, status=Failure, additi |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2019/05/14-09:15:38.844689 7fbe6a8ee700 [utilities/checkpoint/checkpoint_impl.cc:61] Started the snapshot process -- creating snapshot in directory /fjord/hadoop/data/nvme/splat/yarn-local-dir/usercache/splat/appcache/application_1553773169749_0032/localState/aid_AllocationID{34f2586915013f18b9ef755a99b9794f}/jid_cae4bac93a6f1f57e7da26e8a09c059d/vtx_707eed42a9b74f065cc8bb6798b04782_sti_176/chk_64180/rocks_db | |
2019/05/14-09:15:38.844744 7fbe6a8ee700 [db/db_filesnapshot.cc:34] File Deletions Disabled | |
2019/05/14-09:15:38.844772 7fbe6a8ee700 [db/db_impl_write.cc:1127] [SessionState] New memtable created with log file: #111757. Immutable memtables: 0. | |
2019/05/14-09:15:45.593151 7fb3cdc1d700 (Original Log Time 2019/05/14-09:15:45.593124) [db/db_impl_compaction_flush.cc:1216] Calling FlushMemTableToOutputFile with column family [SessionState], flush slots available 1, compaction slots available 1, flush slots scheduled 1, compaction slots scheduled 0 | |
2019/05/14-09:15:45.593174 7fb3cdc1d700 [db/flush_job.cc:264] [Sess |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
AsynchronousException{java.lang.Exception: Could not materialize checkpoint 1 for operator Source: Kafka[rbeaDeploymentsplattest1] -> Max watermark -> Drop errors -> Filter for topic (1/1).} | |
at org.apache.flink.streaming.runtime.tasks.StreamTask$AsyncCheckpointRunnable.run(StreamTask.java:966) | |
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) | |
at java.lang.Thread.run(Thread.java:748) | |
Caused by: java.lang.Exception: Could not materialize checkpoint 1 for operator Source: Kafka[rbeaDeploymentsplattest1] -> Max watermark -> Drop errors -> Filter for topic (1/1). | |
... 6 more | |
Caused by: java.util.concurrent.ExecutionException: java.io.IOException: Could not open output stream for state backend |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public class ExampleProgram { | |
public static void main(String[] args) throws Exception { | |
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); | |
env.socketTextStream("localhost", 9999) | |
.shuffle() | |
.filter(new StatefulFilter()).uid("f") | |
.shuffle() | |
// .map(x -> x) | |
.print(); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
java.lang.AbstractMethodError | |
at io.netty.util.ReferenceCountUtil.touch(ReferenceCountUtil.java:73) | |
at io.netty.channel.DefaultChannelPipeline.touch(DefaultChannelPipeline.java:107) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) | |
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) | |
at io.netty.handler.codec.http.router.Handler.routed(Handler.java:62) | |
at io.netty.handler.codec.http.router.DualAbstractHandler.channelRead0(DualAbstractHandler.java:57) | |
at io.netty.handler.codec.http.router.DualAbstractHandler.channelRead0(DualAbstractHandler.java:20) | |
at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# | |
# A fatal error has been detected by the Java Runtime Environment: | |
# | |
# SIGSEGV (0xb) at pc=0x00007fffb54e8047, pid=43065, tid=14595 | |
# | |
# JRE version: Java(TM) SE Runtime Environment (8.0_74-b02) (build 1.8.0_74-b02) | |
# Java VM: Java HotSpot(TM) 64-Bit Server VM (25.74-b02 mixed mode bsd-amd64 compressed oops) | |
# Problematic frame: | |
# C [libz.1.dylib+0x7047] inflateEnd+0x25 | |
# |