[jira] [Work logged] (BEAM-6733) Use Flink 1.6/1.7 prepareSnapshotPreBarrier to replace BufferedOutputManager

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

[jira] [Work logged] (BEAM-8645) TimestampCombiner incorrect in beam python

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

[jira] [Updated] (BEAM-8816) Load balance bundle processing w/ multiple SDK workers

[ https://issues.apache.org/jira/browse/BEAM-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated BEAM-8816: --- Description: We found skewed utilization of SDK workers causing excessive latency with

[jira] [Work logged] (BEAM-6668) use add experiment methods (Java and Python)

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

[jira] [Work logged] (BEAM-7560) Python local filesystem match does not work without directory separator.

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

[jira] [Created] (BEAM-8815) Portable pipeline execution without artifact staging

Thomas Weise created BEAM-8815: -- Summary: Portable pipeline execution without artifact staging Key: BEAM-8815 URL: https://issues.apache.org/jira/browse/BEAM-8815 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-8816) Load balance bundle processing w/ multiple SDK workers

Thomas Weise created BEAM-8816: -- Summary: Load balance bundle processing w/ multiple SDK workers Key: BEAM-8816 URL: https://issues.apache.org/jira/browse/BEAM-8816 Project: Beam Issue Type:

[jira] [Commented] (BEAM-8733) The "KeyError: u'-47'" error from line 305 of sdk_worker.py

[ https://issues.apache.org/jira/browse/BEAM-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16980836#comment-16980836 ] Luke Cwik commented on BEAM-8733: - Yes. > The "KeyError: u'-47'" error from line 305 of sdk_worker.py >

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Assigned] (BEAM-3032) Add RedshiftIO

[ https://issues.apache.org/jira/browse/BEAM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cam Mach reassigned BEAM-3032: -- Assignee: Cam Mach > Add RedshiftIO > -- > > Key: BEAM-3032 >

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Work logged] (BEAM-8815) Portable pipeline execution without artifact staging

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

[jira] [Work logged] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

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

[jira] [Work logged] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

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

[jira] [Work logged] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

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

[jira] [Created] (BEAM-8817) Beam SQL dialects should share table registration and name resolution logic

Kenneth Knowles created BEAM-8817: - Summary: Beam SQL dialects should share table registration and name resolution logic Key: BEAM-8817 URL: https://issues.apache.org/jira/browse/BEAM-8817 Project:

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Assigned] (BEAM-8815) Portable pipeline execution without artifact staging

[ https://issues.apache.org/jira/browse/BEAM-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned BEAM-8815: -- Assignee: Thomas Weise > Portable pipeline execution without artifact staging >