flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (JIRA) <j...@apache.org>
Subject [jira] [Created] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase
Date Mon, 18 May 2015 13:20:00 GMT
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

View raw message