Unsubscribe

Unsubscribe

Unable to write checkpoint metadata to s3 using pyflink (1.16.0)

t;s3a://myBucket/bot_detection_test/", Encoder.simple_string_encoder("UTF-8")) \ .with_rolling_policy(RollingPolicy.default_rolling_policy(part_size=1024*1024 * 1, rollover_interval=5 * 60 * 1000, inactivity_interval=5 * 60 * 1000)) \ .build() kinesis_filtered.sink_to(sink) # kine