[jira] [Created] (FLINK-17234) Show more error messages in taskmanager's log

[Shang Yuanchun (Jira)]

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)