You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/02 11:32:00 UTC
[jira] [Assigned] (FLINK-26431) Release Testing: Exception history for the adaptive scheduler
[ https://issues.apache.org/jira/browse/FLINK-26431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Niklas Semmler reassigned FLINK-26431:
--------------------------------------
Assignee: Jichun Liu
> Release Testing: Exception history for the adaptive scheduler
> -------------------------------------------------------------
>
> Key: FLINK-26431
> URL: https://issues.apache.org/jira/browse/FLINK-26431
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Coordination
> Affects Versions: 1.15.0
> Reporter: Niklas Semmler
> Assignee: Jichun Liu
> Priority: Blocker
> Labels: release-testing
> Fix For: 1.15.0
>
>
> FLINK-21439 adds support for the exception history to the adaptive scheduler.
> To evaluate the functionality follow the following steps:
> Add the following lines to your flink config
> {code:java}
> taskmanager.host: localhost # a workaround
> scheduler-mode: reactive
> restart-strategy: fixeddelay
> restart-strategy.fixed-delay.attempts: 100
> {code}
> Create the test job JAR and move it to the usrlib folder. (You may have to create it.) Here "$FLINK-HOME" refers to the folder of your flink installation.
> {code:java}
> $ git clone git@github.com:metaswirl/checkpoint-crasher-job.git
> $ cd checkpoint-crasher-job
> $ mvn install
> $ mv target/checkpoint-crasher-job-0.1.jar $FLINK_HOME/usrlib
> {code}
> Start the job
> {code:java}
> $ bin/taskmanager.sh start
> $ bin/taskmanager.sh start
> $ bin/taskmanager.sh start
> $ bin/standalone-job.sh start --main-class org.apache.niklassemmler.flinkjobs.CheckpointCrasherJob
> {code}
> You should be able to find the exception `java.lang.RuntimeException: Test exception` in the web interface under Jobs->Running Jobs->Exceptions.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)