Hello, I have a question about checkpointing. If I...
# troubleshooting
e
Hello, I have a question about checkpointing. If I want to disable checkpointing in flink-sql-client, how can I achieve this? I’ve tried several approaches, but after a few attempts it feels like checkpointing cannot be fully disabled at all. Flink version 2.2.1
Copy code
Flink SQL> SET 'execution.checkpointing.interval' = 0;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.sql.parser.impl.ParseException: Encountered "0" at line 1, column 42.
Was expecting one of:
    <BINARY_STRING_LITERAL> ...
    <QUOTED_STRING> ...
    <PREFIXED_STRING_LITERAL> ...
    <UNICODE_STRING_LITERAL> ...
    <C_STYLE_ESCAPED_STRING_LITERAL> ...
    <BIG_QUERY_DOUBLE_QUOTED_STRING> ...
    <BIG_QUERY_QUOTED_STRING> ...
Copy code
Flink SQL> SET 'execution.checkpointing.interval' = 'false';
[ERROR] Could not execute SQL statement. Reason:
java.lang.NumberFormatException: text does not start with a number, and is not a valid ISO-8601 duration format: false
Copy code
Flink SQL> SET 'execution.checkpointing.interval' = '0s';
[ERROR] Could not execute SQL statement. Reason:
java.lang.IllegalArgumentException: Checkpoint interval must be larger than or equal to 10 ms
Copy code
Flink SQL> SET 'execution.checkpointing.interval' = '0 s';
[ERROR] Could not execute SQL statement. Reason:
java.lang.IllegalArgumentException: Checkpoint interval must be larger than or equal to 10 ms
Copy code
Flink SQL> SET 'execution.checkpointing.interval' = NONE;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.sql.parser.impl.ParseException: Encountered "NONE" at line 1, column 42.
Was expecting one of:
    <BINARY_STRING_LITERAL> ...
    <QUOTED_STRING> ...
    <PREFIXED_STRING_LITERAL> ...
    <UNICODE_STRING_LITERAL> ...
    <C_STYLE_ESCAPED_STRING_LITERAL> ...
    <BIG_QUERY_DOUBLE_QUOTED_STRING> ...
    <BIG_QUERY_QUOTED_STRING> ...
Copy code
Flink SQL> SET 'execution.checkpointing.interval' = NULL;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.sql.parser.impl.ParseException: Encountered "NULL" at line 1, column 42.
Was expecting one of:
    <BINARY_STRING_LITERAL> ...
    <QUOTED_STRING> ...
    <PREFIXED_STRING_LITERAL> ...
    <UNICODE_STRING_LITERAL> ...
    <C_STYLE_ESCAPED_STRING_LITERAL> ...
    <BIG_QUERY_DOUBLE_QUOTED_STRING> ...
    <BIG_QUERY_QUOTED_STRING> ...
m
That's correct, https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/config/ doesn't list checkpointing as a configuration option there
e
it turns out i had to disable checkpointing globally on the cluster level by removing
execution.checkpointing.interval: 1min
from
config.yaml
flink config
👍 1