LogLevel

class aws_cdk.aws_kinesisanalytics_flink.LogLevel(value)

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_13,
    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