I am running a process and wondering how to kill or stop the process:

Table raw_table = tableEnv.sqlQuery(data_query);
DataStream<Row> join_stream = tableEnv.toDataStream(raw_table);
join_stream.process(new EMPADProcessor()).setParallelism(4);

My Processor class:

public class EMPADProcessor extends ProcessFunction<Row, String> {

    public EMPADProcessor() {
    }

    @Override
    public void processElement(Row row, ProcessFunction<Row, String>.Context context, Collector<String> collector) {


        try {

            int chunk_id = Integer.parseInt("" + row.getField(0));
...............

I want to stop/kill process when

chunk_id=100