[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16004424#comment-16004424 ]
ASF GitHub Bot commented on FLINK-6397: --------------------------------------- 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. > MultipleProgramsTestBase does not reset ContextEnvironment > ---------------------------------------------------------- > > Key: FLINK-6397 > URL: https://issues.apache.org/jira/browse/FLINK-6397 > Project: Flink > Issue Type: Bug > Components: Tests > Affects Versions: 1.3.0, 1.4.0 > Reporter: Chesnay Schepler > Assignee: Biao Liu > Priority: Critical > > The MultipleProgramsTestBase sets a new TestEnvironment as a context > environment but never explicitly unsets it, which can result subsequent tests > categorically failing. > The CustomDistributionITCase doesn't unset the context either; and some > streaming test that i haven't quite nailed down yet. -- This message was sent by Atlassian JIRA (v6.3.15#6346)