[jira] [Updated] (FLINK-13459) Violation of the order queue messages from RabbitMQ.

["Robert Metzger (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger updated FLINK-13459:
-----------------------------------
    Component/s: Connectors/ RabbitMQ

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