Hazelcast Jet Job Arayüzü

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.Job;

getMetrics metodu

JobMetrics nesnesi döner

join metodu

Şunları fırlatabilir

1. java.util.concurrent.CancellationException  : İşin iptal edildiğini gösterir.

2. java.util.concurrent.CompletionException : İşin exception ile sonlandığını gösterir.

resume metodu

JobConfig#setTimeoutMillis() yüzünden iş iptal olduysa ve suspend() çağrısından sonra resume() çağrılırsa şu hatayı alırız

java.lang.IllegalStateException: Job already completed

restart metodu

Açıklaması şöyle

Gracefully stops the current execution and schedules a new execution with the current member list of the Jet cluster.

...

Conceptually this call is equivalent to suspend() & resume(). Not supported for light jobs.

İşi durdurur ve tekrar başlatır. İşin bitmesini beklemez! Eğer Job içinde Kafka  Consumer kullanıyorsak

Kafka Consumer durdurulur ve tekrar yaratılır

Örnek

Şöyle yaparız

JetService instance1 = ...
JetService instance2 = ...

// build the pipeline by adding computation stages
Pipeline pipeline = ...;

// configure the job
JobConfig jobConfig = new JobConfig();
jobConfig.setProcessingGuarantee(EXACTLY_ONCE);
jobConfig.setSnapshotIntervalMillis(2000);

Job job = instance1.newJob(pipeline, jobConfig);

// just wait until the job starts and takes a couple of snapshots
Thread.sleep(10_000);

// add a new node to the cluster
JetService instance3 = ...;

// scale up the job
job.restart();

suspend metodu

JobConfig#setTimeoutMillis() yüzünden iş iptal olduysa ve suspend() çağrılırsa şu hatayı alırız

java.lang.IllegalStateException: Cannot SUSPEND_GRACEFUL job 0a77-ce8b-eb80-0001 because it already has a result: JobResult{jobId=0a77-ce8b-eb80-0001, name=null, creationTime=2023-09-13T14:13:11.717, completionTime=2023-09-13T14:13:18.147, failureText=java.util.concurrent.CancellationException