You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yuan Mei (Jira)" <ji...@apache.org> on 2023/04/24 13:52:00 UTC
[jira] [Commented] (FLINK-30729) AggregateITCase generates stacktraces of IllegalStateExceptions in Maven output but doesn't fail
[ https://issues.apache.org/jira/browse/FLINK-30729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715819#comment-17715819 ]
Yuan Mei commented on FLINK-30729:
----------------------------------
merged commit [{{4ca3604}}|https://github.com/apache/flink/commit/4ca3604a6afb7dace03464fafe7c5f14ab95fc5b] into apache:master
> 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: Improvement
> Components: Runtime / State Backends, Table SQL / API
> Affects Versions: 1.17.0
> Reporter: Matthias Pohl
> Assignee: Yanfei Lei
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.17.1
>
>
> 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)