FilKarnicki commented on pull request #307: URL: https://github.com/apache/flink-statefun/pull/307#issuecomment-1065878580
Hi @igalshilman, thank you for your continued support, I really appreciate it. As the code stands now in this pull request, when I add some logging and run this job via the web client wtih `execution.checkpointing.interval` set to `1000`  I see that globalConfigurations does indeed contain my interval setting ``` 723d5f18b87c_dockercompose_jobmanager_1 | 2022-03-12 12:12:30,428 INFO org.apache.flink.client.ClientUtils [] - Starting program (detached: true) 723d5f18b87c_dockercompose_jobmanager_1 | 2022-03-12 12:12:30,429 WARN org.apache.flink.statefun.flink.core.StatefulFunctionsJob [] - args: --execution.checkpointing.interval,1000 723d5f18b87c_dockercompose_jobmanager_1 | 2022-03-12 12:12:30,430 WARN org.apache.flink.statefun.flink.core.StatefulFunctionsJob [] - argsParameterTool: {"execution.checkpointing.interval":"1000"} 723d5f18b87c_dockercompose_jobmanager_1 | 2022-03-12 12:12:30,433 WARN org.apache.flink.statefun.flink.core.StatefulFunctionsJob [] - flinkConfigFromEnv: {"blob.server.port":"6124","taskmanager.memory.process.size":"1728m","jobmanager.execution.failover-strategy":"region","jobmanager.rpc.address":"jobmanager","jobmanager.memory.off-heap.size":"134217728b","jobmanager.memory.jvm-overhead.min":"201326592b","execution.target":"embedded","jobmanager.memory.process.size":"1600m","web.tmpdir":"/tmp/flink-web-7c6f8090-b2ab-47e7-9053-5cf7718afd6f","jobmanager.rpc.port":"6123","query.server.port":"6125","execution.savepoint.ignore-unclaimed-state":"false","execution.attached":"false","pipeline.jars":"file:/tmp/flink-web-7c6f8090-b2ab-47e7-9053-5cf7718afd6f/flink-web-upload/3d7f46f1-9395-4bb3-902f-aa1864fae86c_flinkjob-1.0-SNAPSHOT.jar","parallelism.default":"1","taskmanager.numberOfTaskSlots":"1","pipeline.classpaths":"","jobmanager.memory.jvm-metaspace.size":"268435456b","classloader. parent-first-patterns.additional":"org.apache.flink.statefun;org.apache.kafka;com.google.protobuf","jobmanager.memory.heap.size":"1073741824b","jobmanager.memory.jvm-overhead.max":"201326592b"} 723d5f18b87c_dockercompose_jobmanager_1 | 2022-03-12 12:12:30,436 WARN org.apache.flink.statefun.flink.core.StatefulFunctionsJob [] - statefunConfigGlobalConfigurations: {"execution.checkpointing.interval":"1000"} ``` Should I expect the checkpointing to be enabled? It doesn't look like it is  The way that I'm testing this is: 1. `mvn package` this project https://github.com/FilKarnicki/statefun-flinkjob/blob/master/pom.xml 2. `docker-compose up` this yaml https://github.com/FilKarnicki/statefun-flinkjob/blob/master/docker-compose/docker-compose.yml 3. run this shell script https://github.com/FilKarnicki/statefun-flinkjob/blob/master/statefunCoreWithConfigLogging/patchCore.sh 4. upload `flinkjob-1.0-SNAPSHOT.jar` to http://localhost:8081/#/submit -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
