Matthias Pohl created FLINK-30729: ------------------------------------- Summary: 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
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)