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