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)
