jenkins - Jenkins - return ステートメントの後に Groovy スクリプトが終了しない

Question

Jenkins でスケジュールされた Groovy スクリプトを実行しようとしていますが、問題が発生しました。「return」ステートメントに到達しても、実行が終了しません。

社内の依存関係とクラスを使用していますが、省略した場合、スクリプトが正常に返されるコード行を見つけました。しかし、残念ながらこの行は省略できません:(

Jenkins のビルド ステップがスタックしたままになる原因について何か考えはありますか?

コードの「犯人」行が内部的に次を実行することに気付きました。 this.executorService.scheduleWithFixedDelay(this.eventsPublisher, 3L, 3L, TimeUnit.SECONDS);

Executor で遊んで、Jenkins のビルド手順を台無しにすることは可能ですか?

私はいくつかの助けが欲しいです、どうもありがとう:)

アップデート：

コード：

import java.sql.DriverManager
import java.sql.ResultSet
import java.text.DateFormat
import java.text.SimpleDateFormat
import hudson.model.*


def verticaConn = null
def verticaStmt = null
def mongoConnection = null

try {

    println("start script: vertica_to_kafka")

    // get params
    def verticaHostName = System.getenv("verticaHostName") //dev=192.168.247.11:5433 prod=192.168.251.120:5433
    def verticaDbName = System.getenv("verticaDbName")
    def verticaTBName = System.getenv("verticaTBName")
    def bootstrapServers = System.getenv("bootstrapServers")
    def limitNum = System.getenv("limitNum").toInteger()
    def startTime = System.getenv("startTime")


    MyKafkaStringProducer producer = new MyKafkaStringProducer();
    producer.init()

    MyEventDao eventDao = new MyEventDao();
    eventDao.setStringProducer(stringProducer);

    Class.forName("com.vertica.jdbc.Driver")
    String verticaConnectionString = "jdbc:vertica://${verticaHostName}/${verticaDbName}"

    Properties verticaProp = new Properties();
    verticaProp.put("user", "user");
    verticaProp.put("password", "password");
    verticaProp.put("ConnectionLoadBalance", 1);

    verticaConn = DriverManager.getConnection(verticaConnectionString, verticaProp);
    verticaStmt = verticaConn.createStatement()

    // vertica execution timestamp
    long currentTS = System.currentTimeMillis()
    DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    String startTS = "1970-01-01 00:00:00";

    String command= "select * from ${verticaTBName} where ts >'${startTS}' "
    if (limitNum > 0) command += "limit ${limitNum}"

    println("querying vertica")
    verticaStmt.execute(command)
    ResultSet results = verticaStmt.getResultSet()


    println("start to send data to kafka")
    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
    while(results.next()){
        long id = results.getLong("id");
        String domain = results.getString("domain");
        String text = results.getString("text");
        Date ts = dateFormat.parse(results.getString("ts"));
        MyEntity myEntity = new MyEntity(id, domain, text, ts);
        eventDao.saveEntity(myEntity);
    }

} catch (Exception e){
    println(e.printStackTrace())
} finally {
    println("going to release resources");
    if (verticaStmt != null){
        try{
            verticaStmt.close()
            println("vertica statement closed successfully!");
        } catch (Exception e) {
            //println("error in close the vertica statement {}", e.getMessage());
        }
    }
    if (verticaConn != null){
        try{
            verticaConn.close()
            println("vertica connection closed successfully!");
        } catch (Exception e) {
            //println("error in close the vertica connection {}", e.getMessage());
        }
    }

    if (mongoConnection != null){
        try {
            mongoConnection.getMongo().close();
            println("mongo connection closed successfully!");
        } catch (Exception e) {
            //println("error in close the mongo connection {}", e.getMessage());
        }
    }
    println("end script: vertica_to_kafka")
}
return
System.exit(0)

MyKafkaStringProducer で、次のことがわかりました。

public synchronized void init() {
    if(this.active) {
        this.initKafkaProducer();
        this.executorService.scheduleWithFixedDelay(this.eventsPublisher, 3L, 3L, TimeUnit.SECONDS);
    }

}