[ 
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)

Reply via email to