Key Default Type Description
kubernetes.operator.exception.field.max.length
2048 Integer Maximum length of each exception field including stack trace to be included in CR status error field.
kubernetes.operator.exception.stacktrace.enabled
false Boolean Enable exception stacktrace to be included in CR status error field.
kubernetes.operator.exception.stacktrace.max.length
2048 Integer Maximum length of stacktrace to be included in CR status error field.
kubernetes.operator.exception.throwable.list.max.count
2 Integer Maximum number of throwable to be included in CR status error field.
kubernetes.operator.flink.client.cancel.timeout
1 min Duration The timeout for the reconciler to wait for flink to cancel job.
kubernetes.operator.flink.client.timeout
10 s Duration The timeout for the observer to wait the flink rest client to return.
kubernetes.operator.job.submission.timeout
10 min Duration The timeout for session job submissions.
kubernetes.operator.reconcile.interval
1 min Duration The interval for the controller to reschedule the reconcile process.
kubernetes.operator.resource.cleanup.timeout
5 min Duration The timeout for the resource clean up to wait for flink to shutdown cluster.
kubernetes.operator.user.artifacts.allowed-schemes
"https" List<String> Comma separated list of URI schemes that are allowed for the FlinkSessionJob jarURI. Only 'https' is allowed by default. Operators that need to fetch artifacts via other schemes (such as 's3' or 'hdfs') can extend this list. Scheme matching is case-insensitive.
kubernetes.operator.user.artifacts.base.dir
"/opt/flink/artifacts" String The base dir to put the session job artifacts.
kubernetes.operator.user.artifacts.disallow-restricted-hosts
true Boolean If enabled, FlinkSessionJob jarURI hosts that resolve to loopback, link-local, site-local, wildcard or multicast addresses are rejected during validation. Disable only if the operator legitimately needs to fetch from such addresses.
kubernetes.operator.user.artifacts.http.socket-timeout
30 s Duration The connect and socket read timeout for downloading a FlinkSessionJob jarURI over http(s). Bounds how long the reconcile thread can be blocked establishing the connection, or waiting for the next byte, from an unresponsive artifact host.
kubernetes.operator.user.artifacts.http.total-timeout
5 min Duration The total wall-clock budget for downloading a FlinkSessionJob jarURI over http(s), covering all redirects and the full body transfer. Unlike the socket timeout, this bounds the overall download even against a slow host that keeps trickling data fast enough to avoid tripping it.
kubernetes.operator.user.artifacts.max-size
1 gb MemorySize The maximum size of a FlinkSessionJob jarURI artifact fetched over http(s). The download is rejected once it exceeds this size, whether or not the server declares a Content-Length up front.