[
https://issues.apache.org/jira/browse/BEAM-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía resolved BEAM-3454.
--------------------------------
Resolution: Fixed
Fix Version/s: 2.3.0
> Make Unbounded to Bounded conversions on IOs able to trigger on maxNumRecords
> and maxReadTime combined
> ------------------------------------------------------------------------------------------------------
>
> Key: BEAM-3454
> URL: https://issues.apache.org/jira/browse/BEAM-3454
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-extensions
> Reporter: Ismaël Mejía
> Assignee: Ryan Skraba
> Priority: Minor
> Fix For: 2.3.0
>
>
> Some Beam IOs expose the ability to turn an unbounded source into a bounded
> source. These IOs have two methods withMaxNumRecords and withMaxReadTime.
> Both methods are exclusive at runtime but they shouldn't be because
> BoundedReadFromUnboundedSource supports to combine the options so the first
> condition reached can stop the source if the user provides both..
> There is already a ticket for KafkaIO and a fix for KinesisIO on the works,
> this ticket is to add this to the other Sources (e.g. MqttIO, JmsIO, etc).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
