[
https://issues.apache.org/jira/browse/FLINK-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897129#comment-16897129
]
Robert Metzger commented on FLINK-13459:
----------------------------------------
Are you writing out the data immediately after the source operator, or is there
anything in between?
This is how writing the data immediately would look like:
{code:java}
DataStream<String> stream = env.addSource(new
RMQSource<String>(connectionConfig, queueName, true, new SimpleStringSchema()))
.setParallelism(1);
stream.print();{code}
> 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
(v7.6.14#76016)
