[jira] [Assigned] (BEAM-6938) Add support for dynamic destinations when writing to MQTT

[ https://issues.apache.org/jira/browse/BEAM-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6938: -- Assignee: LI Guobao > Add support for dynamic destinations when writing to MQTT > -

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6876?focusedWorklogId=220536&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220536 ] ASF GitHub Bot logged work on BEAM-6876: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6876?focusedWorklogId=220529&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220529 ] ASF GitHub Bot logged work on BEAM-6876: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6938) Add support for dynamic destinations when writing to MQTT

Ismaël Mejía created BEAM-6938: -- Summary: Add support for dynamic destinations when writing to MQTT Key: BEAM-6938 URL: https://issues.apache.org/jira/browse/BEAM-6938 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6876?focusedWorklogId=220526&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220526 ] ASF GitHub Bot logged work on BEAM-6876: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6876?focusedWorklogId=220521&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220521 ] ASF GitHub Bot logged work on BEAM-6876: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6876?focusedWorklogId=220520&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220520 ] ASF GitHub Bot logged work on BEAM-6876: Author: ASF GitHub Bot

[jira] [Work started] (BEAM-3312) Add convenient "with" to MqttIO.ConnectionConfiguration

[ https://issues.apache.org/jira/browse/BEAM-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-3312 started by LI Guobao. --- > Add convenient "with" to MqttIO.ConnectionConfiguration > ---

[jira] [Work logged] (BEAM-6937) Streaming FlinkTransformOverrides are not applied without explicit streaming mode

[ https://issues.apache.org/jira/browse/BEAM-6937?focusedWorklogId=220511&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220511 ] ASF GitHub Bot logged work on BEAM-6937: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6937) Streaming FlinkTransformOverrides are not applied without explicit streaming mode

Maximilian Michels created BEAM-6937: Summary: Streaming FlinkTransformOverrides are not applied without explicit streaming mode Key: BEAM-6937 URL: https://issues.apache.org/jira/browse/BEAM-6937

[jira] [Work logged] (BEAM-3312) Add convenient "with" to MqttIO.ConnectionConfiguration

[ https://issues.apache.org/jira/browse/BEAM-3312?focusedWorklogId=220491&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220491 ] ASF GitHub Bot logged work on BEAM-3312: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6929?focusedWorklogId=220487&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220487 ] ASF GitHub Bot logged work on BEAM-6929: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3312) Add convenient "with" to MqttIO.ConnectionConfiguration

[ https://issues.apache.org/jira/browse/BEAM-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804794#comment-16804794 ] LI Guobao commented on BEAM-3312: - So let us just extend the `ConnectionConfiguration` cur

[jira] [Updated] (BEAM-3312) Add convenient "with" to MqttIO.ConnectionConfiguration

[ https://issues.apache.org/jira/browse/BEAM-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-3312: --- Summary: Add convenient "with" to MqttIO.ConnectionConfiguration (was: Add IO convenient "with" metho

[jira] [Assigned] (BEAM-3312) Add IO convenient "with" methods

[ https://issues.apache.org/jira/browse/BEAM-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LI Guobao reassigned BEAM-3312: --- Assignee: LI Guobao (was: Jean-Baptiste Onofré) > Add IO convenient "with" methods > ---

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=220479&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220479 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Reopened] (BEAM-3604) MqttIOTest testReadNoClientId failure timeout

[ https://issues.apache.org/jira/browse/BEAM-3604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reopened BEAM-3604: The test was disabled but it has not been fixed yet. > MqttIOTest testReadNoClientId failure timeout >

[jira] [Commented] (BEAM-3312) Add IO convenient "with" methods

[ https://issues.apache.org/jira/browse/BEAM-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804770#comment-16804770 ] Ismaël Mejía commented on BEAM-3312: We need to add the methods to the `ConnectionConf

[jira] [Updated] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6929: - Priority: Critical (was: Major) > Session Windows with lateness cause NullPointerExceptio

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6929?focusedWorklogId=220472&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220472 ] ASF GitHub Bot logged work on BEAM-6929: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6929?focusedWorklogId=220470&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220470 ] ASF GitHub Bot logged work on BEAM-6929: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-1893) Add IO module for Couchbase

[ https://issues.apache.org/jira/browse/BEAM-1893?focusedWorklogId=220467&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220467 ] ASF GitHub Bot logged work on BEAM-1893: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-1893) Add IO module for Couchbase

[ https://issues.apache.org/jira/browse/BEAM-1893?focusedWorklogId=220465&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220465 ] ASF GitHub Bot logged work on BEAM-1893: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220439&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220439 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220438&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220438 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220441&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220441 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220440&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220440 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220435&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220435 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220436&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220436 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6922) Remove LGPL test library dependency in cassandraio-test

[ https://issues.apache.org/jira/browse/BEAM-6922?focusedWorklogId=220433&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220433 ] ASF GitHub Bot logged work on BEAM-6922: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220432&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220432 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5995) Create Jenkins jobs to run the load tests

[ https://issues.apache.org/jira/browse/BEAM-5995?focusedWorklogId=220431&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220431 ] ASF GitHub Bot logged work on BEAM-5995: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6910) Beam does not consider BigQuery's processing location when getting query results

[ https://issues.apache.org/jira/browse/BEAM-6910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804669#comment-16804669 ] niklas Hansson commented on BEAM-6910: -- As far as I understand this issue is solved i

[jira] [Created] (BEAM-6936) Add a Jenkins job running Java examples on Java 11 Dataflow

Michal Walenia created BEAM-6936: Summary: Add a Jenkins job running Java examples on Java 11 Dataflow Key: BEAM-6936 URL: https://issues.apache.org/jira/browse/BEAM-6936 Project: Beam Issue

[jira] [Closed] (BEAM-6703) Support Java 11 in Jenkins

[ https://issues.apache.org/jira/browse/BEAM-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Walenia closed BEAM-6703. Resolution: Done Fix Version/s: Not applicable > Support Java 11 in Jenkins > ---

[jira] [Work logged] (BEAM-3072) Improve error handling at staging time time for DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-3072?focusedWorklogId=220423&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220423 ] ASF GitHub Bot logged work on BEAM-3072: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3072) Improve error handling at staging time time for DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-3072?focusedWorklogId=220422&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-220422 ] ASF GitHub Bot logged work on BEAM-3072: Author: ASF GitHub Bot

<    1   2