[FLINK-20268] [core] Declare states with Python SDK in E2E tests
2 files changed