Details
Description
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]
Attachments
Issue Links
- links to