diff --git a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeFactory.java b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeFactory.java index fd8a7bebb7a9f..cae1ca004c856 100644 --- a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeFactory.java +++ b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeFactory.java @@ -30,6 +30,8 @@ public interface RuntimeFactory extends AutoCloseable { * Create a function container to execute a java instance. * * @param instanceConfig java instance config + * @param codeFile code file + * @param expectedHealthCheckInterval expected health check interval in seconds * @return function container to start/stop instance */ Runtime createContainer( diff --git a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java index d4d61e0b1c804..423ccd9903190 100644 --- a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java +++ b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java @@ -73,7 +73,7 @@ public void start() throws Exception { details.getName(), this.instanceConfig.getInstanceId()); runtime = runtimeFactory.createContainer(this.instanceConfig, codeFile, originalCodeFileName, - instanceLivenessCheckFreqMs * 1000); + instanceLivenessCheckFreqMs / 1000); runtime.start(); // monitor function runtime to make sure it is running. If not, restart the function runtime