[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-8836) ExternalTransform is not providing a unique name

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

[jira] [Work logged] (BEAM-8847) Handle the registration request synchronously in the Java SDK harness

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

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

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

[jira] [Work logged] (BEAM-8846) Force synchronization of the stream observer in BeamFnControlClient

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

[jira] [Work logged] (BEAM-7949) Add time-based cache threshold support in the data service of the Python SDK harness

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

[jira] [Work logged] (BEAM-8406) TextTable support JSON format

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

[jira] [Created] (BEAM-8850) Flink: Batch translation context respects provided PTransform during Input / Output lookups.

David Moravek created BEAM-8850: --- Summary: Flink: Batch translation context respects provided PTransform during Input / Output lookups. Key: BEAM-8850 URL: https://issues.apache.org/jira/browse/BEAM-8850

[jira] [Created] (BEAM-8848) Flink: Memory efficient GBK implementation for batch runner

David Moravek created BEAM-8848: --- Summary: Flink: Memory efficient GBK implementation for batch runner Key: BEAM-8848 URL: https://issues.apache.org/jira/browse/BEAM-8848 Project: Beam Issue

[jira] [Resolved] (BEAM-8406) TextTable support JSON format

[ https://issues.apache.org/jira/browse/BEAM-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen resolved BEAM-8406. - Fix Version/s: Not applicable Resolution: Done > TextTable support JSON format >

[jira] [Created] (BEAM-8849) Flink: Support multiple translation or a single URN in batch runner.

David Moravek created BEAM-8849: --- Summary: Flink: Support multiple translation or a single URN in batch runner. Key: BEAM-8849 URL: https://issues.apache.org/jira/browse/BEAM-8849 Project: Beam

[jira] [Resolved] (BEAM-7952) Make the input queue of the input buffer in Python SDK Harness size limited.

[ https://issues.apache.org/jira/browse/BEAM-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng resolved BEAM-7952. --- Fix Version/s: 2.18.0 Resolution: Duplicate https://issues.apache.org/jira/browse/BEAM-8667 >

[jira] [Work logged] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

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

[jira] [Created] (BEAM-8846) Force synchronization of the stream observer in BeamFnControlClient

sunjincheng created BEAM-8846: - Summary: Force synchronization of the stream observer in BeamFnControlClient Key: BEAM-8846 URL: https://issues.apache.org/jira/browse/BEAM-8846 Project: Beam

[jira] [Created] (BEAM-8847) Handle the registration request synchronously in the Java SDK harness

sunjincheng created BEAM-8847: - Summary: Handle the registration request synchronously in the Java SDK harness Key: BEAM-8847 URL: https://issues.apache.org/jira/browse/BEAM-8847 Project: Beam

[jira] [Work logged] (BEAM-8846) Force synchronization of the stream observer in BeamFnControlClient

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

[jira] [Work logged] (BEAM-8847) Handle the registration request synchronously in the Java SDK harness

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

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

[jira] [Work logged] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

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

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

[jira] [Resolved] (BEAM-8656) flink_master_url usage in flink_runner.py

[ https://issues.apache.org/jira/browse/BEAM-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8656. -- Fix Version/s: Not applicable Resolution: Fixed > flink_master_url usage in

[jira] [Work logged] (BEAM-8656) flink_master_url usage in flink_runner.py

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

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

[jira] [Work logged] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

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

[jira] [Work logged] (BEAM-8656) flink_master_url usage in flink_runner.py

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-8822) Hadoop Client version 2.8 from 2.7

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

[jira] [Closed] (BEAM-5918) Add Cast transform for Rows

[ https://issues.apache.org/jira/browse/BEAM-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gleb Kanterov closed BEAM-5918. --- > Add Cast transform for Rows > --- > > Key: BEAM-5918 >

[jira] [Resolved] (BEAM-5918) Add Cast transform for Rows

[ https://issues.apache.org/jira/browse/BEAM-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gleb Kanterov resolved BEAM-5918. - Fix Version/s: Not applicable Resolution: Fixed > Add Cast transform for Rows >

[jira] [Work logged] (BEAM-8338) Support ES 7.x for ElasticsearchIO

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

[jira] [Work logged] (BEAM-8338) Support ES 7.x for ElasticsearchIO

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

[jira] [Work logged] (BEAM-8656) flink_master_url usage in flink_runner.py

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-8822) Hadoop Client version 2.8 from 2.7

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

[jira] [Work logged] (BEAM-7434) RabbitMqIO uses a deprecated API

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

[jira] [Commented] (BEAM-7219) Spark portable runner: support Spark metrics

[ https://issues.apache.org/jira/browse/BEAM-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984510#comment-16984510 ] Ismaël Mejía commented on BEAM-7219: Just for ref Metrics result reporting is happening now in the

[jira] [Work logged] (BEAM-7949) Add time-based cache threshold support in the data service of the Python SDK harness

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

[jira] [Work logged] (BEAM-8338) Support ES 7.x for ElasticsearchIO

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