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

["Dmitry Kharlashko (JIRA)" <ji...@apache.org>]

Dmitry Kharlashko created FLINK-13459:
-----------------------------------------

             Summary: 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
    Affects Versions: 1.8.1
            Reporter: Dmitry Kharlashko


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)