[jira] [Created] (FLINK-26431) Release Testing: Exception history for the adaptive scheduler

["Niklas Semmler (Jira)" <ji...@apache.org>]

Niklas Semmler created FLINK-26431:
--------------------------------------

             Summary: 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
             Fix For: 1.7.3, 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)