[
https://issues.apache.org/jira/browse/FLINK-30729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684439#comment-17684439
]
Yanfei Lei commented on FLINK-30729:
------------------------------------
I open a PR to replace {{checkState()}} with {{LOG.warn()}} when
StateChangelogWriter is closed, to avoid the `IllegalStateException`
stacktrace, [~masteryhx] could you please help take a look?
> AggregateITCase generates stacktraces of IllegalStateExceptions in Maven
> output but doesn't fail
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-30729
> URL: https://issues.apache.org/jira/browse/FLINK-30729
> Project: Flink
> Issue Type: Bug
> Components: Runtime / State Backends, Table SQL / API
> Affects Versions: 1.17.0
> Reporter: Matthias Pohl
> Priority: Critical
> Labels: pull-request-available
>
> We're seeing some weird IllegalStateException stacktraces in CI for
> {{o.a.f.table.planner.runtime.stream.table.AggregateITCase}} which,
> interestingly, doesn't cause the test to fail. That's something we should
> investigate, I guess:
> {code}
> java.lang.IllegalStateException: LogWriter is closed
> at
> org.apache.flink.util.Preconditions.checkState(Preconditions.java:193)
> at
> org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter.appendMeta(InMemoryStateChangelogWriter.java:64)
> at
> org.apache.flink.state.changelog.AbstractStateChangeLogger.logMetaIfNeeded(AbstractStateChangeLogger.java:156)
> at
> org.apache.flink.state.changelog.AbstractStateChangeLogger.log(AbstractStateChangeLogger.java:140)
> at
> org.apache.flink.state.changelog.AbstractStateChangeLogger.valueCleared(AbstractStateChangeLogger.java:104)
> at
> org.apache.flink.state.changelog.ChangelogListState.clear(ChangelogListState.java:113)
> at
> org.apache.flink.runtime.state.ttl.TtlListState$IteratorWithCleanup.cleanupIfEmpty(TtlListState.java:193)
> at
> org.apache.flink.runtime.state.ttl.TtlListState$IteratorWithCleanup.hasNext(TtlListState.java:186)
> at
> org.apache.flink.table.planner.runtime.utils.JavaUserDefinedAggFunctions$DataViewTestAgg.getValue(JavaUserDefinedAggFunctions.java:355)
> at GroupAggsHandler$10675.getValue(Unknown Source)
> at
> org.apache.flink.table.runtime.operators.aggregate.GroupAggFunction.processElement(GroupAggFunction.java:146)
> at
> org.apache.flink.table.runtime.operators.aggregate.GroupAggFunction.processElement(GroupAggFunction.java:43)
> at
> org.apache.flink.streaming.api.operators.KeyedProcessOperator.processElement(KeyedProcessOperator.java:83)
> at
> org.apache.flink.streaming.runtime.io.RecordProcessorUtils.lambda$getRecordProcessor$0(RecordProcessorUtils.java:60)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:236)
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:546)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:835)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:784)
> at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:945)
> at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:924)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:738)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:556)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=44987&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4&l=13847
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
