LogLevel

class aws_cdk.aws_kinesisanalytics_flink_alpha.LogLevel(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

(experimental) Available log levels for Flink applications.

Stability:: experimental
ExampleMetadata:: infused

Example:

# bucket: s3.Bucket

flink_app = flink.Application(self, "Application",
    code=flink.ApplicationCode.from_bucket(bucket, "my-app.jar"),
    runtime=flink.Runtime.FLINK_1_20,
    checkpointing_enabled=True,  # default is true
    checkpoint_interval=Duration.seconds(30),  # default is 1 minute
    min_pause_between_checkpoints=Duration.seconds(10),  # default is 5 seconds
    log_level=flink.LogLevel.ERROR,  # default is INFO
    metrics_level=flink.MetricsLevel.PARALLELISM,  # default is APPLICATION
    auto_scaling_enabled=False,  # default is true
    parallelism=32,  # default is 1
    parallelism_per_kpu=2,  # default is 1
    snapshots_enabled=False,  # default is true
    log_group=logs.LogGroup(self, "LogGroup")
)

Attributes

DEBUG

(experimental) Debug level logging.

Stability:: experimental

ERROR

(experimental) Error level logging.

Stability:: experimental

INFO

(experimental) Info level logging.

Stability:: experimental

WARN

(experimental) Warn level logging.

Stability:: experimental