[
https://issues.apache.org/jira/browse/BEAM-12007?focusedWorklogId=570418&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-570418
]
ASF GitHub Bot logged work on BEAM-12007:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 23/Mar/21 13:09
Start Date: 23/Mar/21 13:09
Worklog Time Spent: 10m
Work Description: dpcollins-google commented on pull request #14294:
URL: https://github.com/apache/beam/pull/14294#issuecomment-804889499
> We would expect that when a consumer of a subscription, with ordering
enabled, would receive the outputted messages (with the same ordering key) in
the order they were published.
This will likely not be achieved by this PR. The beam model does not
preserve ordering within a PCollection, allowing elements to be reordered
arbitrarily.
> The order in which these messages are published is as far as I know
determined by the timestamp of each element.
I do not believe a Beam runner is required to process windows in timestamp
order: if processing of a given window stalls, another window can begin to
proceed concurrently. In this case, it would result in disordered messages
between windows.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 570418)
Time Spent: 1h 20m (was: 1h 10m)
> Set message ordering key for Google Pubsub
> ------------------------------------------
>
> Key: BEAM-12007
> URL: https://issues.apache.org/jira/browse/BEAM-12007
> Project: Beam
> Issue Type: Improvement
> Components: io-java-gcp
> Reporter: Victor Devos
> Priority: P2
> Labels: PubSubIO, gcp, pubsub, pubsubio
> Time Spent: 1h 20m
> Remaining Estimate: 0h
>
> Message ordering is currently not supported on the producer side.
> [https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessage.java#L44]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
