[
https://issues.apache.org/jira/browse/FLINK-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-13459.
------------------------------------
Resolution: Abandoned
There was no more activity from the reporter.
> Violation of the order queue messages from RabbitMQ.
> ----------------------------------------------------
>
> Key: FLINK-13459
> URL: https://issues.apache.org/jira/browse/FLINK-13459
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream, Connectors/ RabbitMQ
> Affects Versions: 1.8.1
> Reporter: Dmitry Kharlashko
> Priority: Critical
>
> When receiving an accumulated message queue from RabbitMQ their order is
> disturbed. Messages come from Rabbit in the correct order but in the stream
> they are mixed. Stream created as written in the documentation.
> DataStream<String> stream = env.addSource(new
> RMQSource<String>(connectionConfig, queueName, true, new
> SimpleStringSchema()))
> .setParallelism(1);
> Example:
> In the RabbitMQ message queue is :\{message1,message2,message 3,message4...}.
> In the flink stream queue messages is :
> {message1,message3,message4,message2...}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
