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

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

     [ https://issues.apache.org/jira/browse/FLINK-26431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Niklas Semmler updated FLINK-26431:
-----------------------------------
    Fix Version/s:     (was: 1.7.3)

> 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
>            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)