Hi, is there anyone familiar with running flink app in AWS kinesis analytics? I was trying to run a python flink app, it failed to start with the error message below. I couldn’t find any useful information there. Does anyone know how to troubleshoot? Thanks!

Hi. In order to get an error from python code you need to look for logs coming from PythonDriver, you can filter logs by field

logger

. You should be able to see messages with traceback there. PythonDriver surfaces all python output to

INFO

logs, so be sure to check if you are filtering by messageType.

The Python error I got was

"AttributeError: type object 'EnvironmentSettings' has no attribute 'in_streaming_mode'"

It is probably due to the code:

env_settings = EnvironmentSettings.in_streaming_mode()
table_env = TableEnvironment.create(env_settings)

Although I don’t know why this is wrong.

Which version of Flink you trying to use? If it is before 1.14 you need to create environment differently

EnvironmentSettings.new_instance().in_streaming_mode().use_blink_planner().build()

Thanks for the hint. And it works! I was using 1.12