Skip to content

Instantly share code, notes, and snippets.

View gyfora's full-sized avatar

Gyula Fora gyfora

  • Apple, Apache Flink
  • Zürich, Switzerland
  • X @GyulaFora
View GitHub Profile
#
# 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
#
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
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
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
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();
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)
#
# 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
#