[jira] [Updated] (BEAM-3454) Make Unbounded to Bounded conversions on IOs able to trigger on maxNumRecords and maxReadTime combined

["Ismaël Mejía (JIRA)" <ji...@apache.org>]

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

Ismaël Mejía updated BEAM-3454:
-------------------------------
    Affects Version/s:     (was: 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: Ismaël Mejía
>            Priority: Minor
>
> 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
(v6.4.14#64029)