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] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase
Date Tue, 19 May 2015 09:04:00 GMT

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

Márton Balassi commented on FLINK-2036:
---------------------------------------

You can submit multiple different topologies, but then you have no guarantee on the execution
order. If I understand correctly that is the issue in your case. Is it different from the
batch solution?

> 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