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. |