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 g...@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)
