Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3810
Not quite; the `CassandraConnectorITCase` was broken in the process. This
test contains both batch and streaming jobs that rely on different
TestEnvironments. When the batch `TestEnvironment` is set as the context the
streaming tests will fail.
`StreamExecutionEnvironment#getExecutionEnvironment()` doesn't account for
this case, and tries to create a `LocalStreamEnvironment` which however fails
since no explicit environment may be create when a context environment was set.
This is more or less a problem of the cassandra test; it shouldn't actually
run any streaming jobs. Let me fix that, then we'll get back to this PR.
Besides that i don't see any problems right now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
