[jira] [Created] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

[Shang Yuanchun (Jira)]

Márton Balassi created FLINK-2036:
-------------------------------------

             Summary: StreamExecutionEnvironment usage in KafkaITcase
                 Key: FLINK-2036
                 URL: https://issues.apache.org/jira/browse/FLINK-2036
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector, Streaming
    Affects Versions: 0.9
            Reporter: Márton Balassi
            Assignee: Robert Metzger
            Priority: Minor


The KafkaITCase currently creates a lot of LocalStreamExecution environments. It would be more desirable to use TestStreamEnvironments and maybe reuse some them if it is possible.

I have started working on this [1], but some tests fail with the TestStreamEnvironment. A pair of additional eyes would come in handy.

[1] https://github.com/mbalassi/flink/commit/0df13dc91fb16efe5bedd1917a5a5e1c8615b1ed



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)