Kurt Young created FLINK-17234:
----------------------------------
Summary: Show more error messages in taskmanager's log
Key: FLINK-17234
URL: https://issues.apache.org/jira/browse/FLINK-17234
Project: Flink
Issue Type: Improvement
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Runtime
/ Task
Reporter: Kurt Young
Fix For: 1.11.0
I created a csv table in sql client and trying to view the table content by
executing a simple SELECT * query.
First I got the error message printed in sql cli:
{code:java}
[ERROR] Could not execute SQL statement. Reason:
java.lang.IllegalStateException: can't switch state from terminal state READING
to CLOSED{code}
And then I open the TM's log to fin more information about what went wrong. The
only information I got from log file is similar with sql cli:
{code:java}
2020-04-19 11:50:28,630 WARN org.apache.flink.runtime.taskmanager.Task
[] - CsvTableSource(read fields: t, author) ->
SourceConversion(table=[default_catalog.default_database.contri, source:
[CsvTableSource(read fields: t, author)]], fields=[t, author]) ->
SinkConversionToRow -> Sink: Unnamed (1/1) (ed397f0f69e8f48b320c568f91a5976e)
switched from RUNNING to FAILED.2020-04-19 11:50:28,630 WARN
org.apache.flink.runtime.taskmanager.Task [] -
CsvTableSource(read fields: t, author) ->
SourceConversion(table=[default_catalog.default_database.contri, source:
[CsvTableSource(read fields: t, author)]], fields=[t, author]) ->
SinkConversionToRow -> Sink: Unnamed (1/1) (ed397f0f69e8f48b320c568f91a5976e)
switched from RUNNING to FAILED.java.lang.IllegalStateException: can't switch
state from terminal state READING to CLOSED at
org.apache.flink.util.Preconditions.checkState(Preconditions.java:217)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.switchState(ContinuousFileReaderOperator.java:366)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.lambda$new$0(ContinuousFileReaderOperator.java:213)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.run(StreamTaskActionExecutor.java:42)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:276)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:205)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:196)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:490)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:470)
~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:718)
[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:542)
[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]{code}
Finally, it turns out I specified wrong column type of the csv table, and
something should have go wrong when reading the data file, but I can't get any
useful information from log file.
I'm not sure whether the root cause is the error message never thrown by csv
parser or got eat up by mailbox model yet.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
