Apache Flink Application

fields @timestamp, message | sort @timestamp asc | filter logger like /PythonDriver/ | limit 1000

InputStream0 ├── aws.region = ap-northeast-2 ├── stream.name = input-stream └── stream.arn = arn:aws:kinesis:ap-northeast-2:362708816803:stream/input-stream OutputStream0 ├── aws.region = ap-northeast-2 ├── stream.name = output-stream └── stream.arn = arn:aws:kinesis:ap-northeast-2:362708816803:stream/output-stream kinesis.analytics.flink.run.options ├── python = main.py └── jarfile = lib/pyflink-dependencies.jar