flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase
Date Tue, 19 May 2015 08:59:01 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550068#comment-14550068
] 

Robert Metzger commented on FLINK-2036:
---------------------------------------

No, this is still an open issue.
I am recreating new environments because its not possible to reuse a StreamExecutionEnvironment
for submitting multiple (different!) topologies. I've added the {{StreamGraph.clear()}} method,
while trying to fix this, but I still got unexpected behavior.
This should be not too hard to fix, I just was not caring enough about this issue. I have
to see when I have time to work on this issue.
If somebody else is interested in fixing this, please assign it to yourself. I'll keep myself
assigned to remember the issue.

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

Mime
View raw message