[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski closed FLINK-18587.
--------------------------------
Resolution: Not A Problem
> java.lang.IllegalArgumentException: Position out of bounds when reading Long
> state
> ----------------------------------------------------------------------------------
>
> Key: FLINK-18587
> URL: https://issues.apache.org/jira/browse/FLINK-18587
> Project: Flink
> Issue Type: Bug
> Components: Runtime / State Backends
> Affects Versions: 1.10.0
> Environment: {code:java}
> Starting YARN TaskExecutor runner (Version: 1.10.0, Rev:<unknown>,
> Date:<unknown>)
> OS current user: yarn
> Current Hadoop/Kerberos user: hadoop
> JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.141-b15
> Maximum heap size: 28960 MiBytes
> JAVA_HOME: /usr/java/jdk1.8.0_141/jre
> Hadoop version: 2.8.5-amzn-6
> JVM Options:
> -Xmx30360049728
> -Xms30360049728
> -XX:MaxDirectMemorySize=4429185024
> -XX:MaxMetaspaceSize=1073741824
> -XX:+UseG1GC
>
> -Dlog.file=/var/log/hadoop-yarn/containers/application_1594539266405_0024/container_1594539266405_0024_01_000050/taskmanager.log
> -Dlog4j.configuration=file:./log4j.properties
> Program Arguments:
> -D taskmanager.memory.framework.off-heap.size=134217728b
> -D taskmanager.memory.network.max=1073741824b
> -D taskmanager.memory.network.min=1073741824b
> -D taskmanager.memory.framework.heap.size=134217728b
> -D taskmanager.memory.managed.size=23192823744b
> -D taskmanager.cpu.cores=7.0
> -D taskmanager.memory.task.heap.size=30225832000b
> -D taskmanager.memory.task.off-heap.size=3221225472b
> --configDir .
> -Djobmanager.rpc.address=ip-10-180-28-59.us-west-2.compute.internal
> -Dweb.port=0
> -Dweb.tmpdir=/tmp/flink-web-90514561-0a82-48c4-a8b1-c23bf7d814c0
> -Djobmanager.rpc.port=38887
> -Drest.address=ip-10-180-28-59.us-west-2.compute.internal{code}
> Reporter: Ori Popowski
> Priority: Major
>
> Getting {{java.lang.IllegalArgumentException: Position out of bounds}} when
> calling {{value()}} on {{ValueState[java.lang.Long]}}
>
> Stacktrace:
>
> {code:java}
> Caused by: java.lang.IllegalArgumentException: Position out of bounds.
> at
> org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:139)
> at
> org.apache.flink.core.memory.DataOutputSerializer.setPosition(DataOutputSerializer.java:368)
> at
> org.apache.flink.contrib.streaming.state.RocksDBSerializedCompositeKeyBuilder.resetToKey(RocksDBSerializedCompositeKeyBuilder.java:189)
> at
> org.apache.flink.contrib.streaming.state.RocksDBSerializedCompositeKeyBuilder.buildCompositeKeyNamespace(RocksDBSerializedCompositeKeyBuilder.java:116)
> at
> org.apache.flink.contrib.streaming.state.AbstractRocksDBState.serializeCurrentKeyWithGroupAndNamespace(AbstractRocksDBState.java:163)
> at
> org.apache.flink.contrib.streaming.state.RocksDBValueState.value(RocksDBValueState.java:84)
> at
> org.apache.flink.runtime.state.ttl.AbstractTtlDecorator.getWrappedWithTtlCheckAndUpdate(AbstractTtlDecorator.java:92)
> at
> org.apache.flink.runtime.state.ttl.AbstractTtlDecorator.getWithTtlCheckAndUpdate(AbstractTtlDecorator.java:84)
> at
> org.apache.flink.runtime.state.ttl.AbstractTtlState.getWithTtlCheckAndUpdate(AbstractTtlState.java:56)
> at
> org.apache.flink.runtime.state.ttl.TtlValueState.value(TtlValueState.java:44)
> at
> walkme.flink.TruncateLargeSessions.processElement(TruncateLargeSessions.scala:28)
> at
> walkme.flink.TruncateLargeSessions.processElement(TruncateLargeSessions.scala:14)
> at
> org.apache.flink.streaming.api.operators.KeyedProcessOperator.processElement(KeyedProcessOperator.java:85)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:173)
> at
> org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:151)
> at
> org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:128)
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:69)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:311)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:187)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:487)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:470)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
