jiazhizhong created ZEPPELIN-5638:
-------------------------------------
Summary: zeppelin-interpreter-flink-yarn produce a lot of logs,
caused disk space to run out
Key: ZEPPELIN-5638
URL: https://issues.apache.org/jira/browse/ZEPPELIN-5638
Project: Zeppelin
Issue Type: Bug
Components: flink
Affects Versions: 0.10.0
Environment: Zeppelin 0.10.0
flink 1.13.2
hadoop: hdp 3.1.5
Reporter: jiazhizhong
Submit the Flink task to the yarn cluster through the yarn mode,
code can run normally
but zeppelin-interpreter-flink-yarn produce a lot of logs, caused disk space
to run out
log content as blow:
2022-01-19 10:29:33,598 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,605 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,605 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,605 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,605 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,605 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,605 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
at
org.apache.zeppelin.flink.JobManager$FlinkJobProgressPoller.run(JobManager.java:211)
[zeppelin-flink-0.10.0-2.11.jar:0.10.0]
2022-01-19 10:29:33,606 ERROR org.apache.zeppelin.flink.JobManager
[] - Fail to poll flink job progress via rest api
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Object.wait(Native Method) ~[?:1.8.0_191]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
