[jira] [Commented] (BEAM-311) Add 'garbage collection' hold when receive late element

[ https://issues.apache.org/jira/browse/BEAM-311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132165#comment-17132165 ] Beam JIRA Bot commented on BEAM-311: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-2680) Improve scalability of the Watch transform

[ https://issues.apache.org/jira/browse/BEAM-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2680: Labels: stale-assigned (was: ) > Improve scalability of the Watch transform >

[jira] [Commented] (BEAM-1936) Allow user provided function to extract custom timestamp from payload in pubsubIO

[ https://issues.apache.org/jira/browse/BEAM-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132000#comment-17132000 ] Beam JIRA Bot commented on BEAM-1936: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-681) DoFns should be serialized at apply time and deserialized when executing

[ https://issues.apache.org/jira/browse/BEAM-681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132142#comment-17132142 ] Beam JIRA Bot commented on BEAM-681: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-1901) Faling to re-raise exceptions

[ https://issues.apache.org/jira/browse/BEAM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132006#comment-17132006 ] Beam JIRA Bot commented on BEAM-1901: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-1563) Flatten Spark runner libraries.

[ https://issues.apache.org/jira/browse/BEAM-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132051#comment-17132051 ] Beam JIRA Bot commented on BEAM-1563: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-1675) deprecate withCoder() in JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1675: Labels: stale-P2 (was: ) > deprecate withCoder() in JdbcIO > --- > >

[jira] [Updated] (BEAM-601) Enable Kinesis integration tests

[ https://issues.apache.org/jira/browse/BEAM-601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-601: --- Labels: stale-P2 (was: ) > Enable Kinesis integration tests > > >

[jira] [Updated] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure

[ https://issues.apache.org/jira/browse/BEAM-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2837: Labels: stale-assigned (was: ) > Writing To Spanner From Google Cloud DataFlow - Failure >

[jira] [Commented] (BEAM-3567) Update DirectRunner's SDF implementation to support side outputs

[ https://issues.apache.org/jira/browse/BEAM-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132296#comment-17132296 ] Beam JIRA Bot commented on BEAM-3567: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-1089) Jenkins comments on PRs are too many & too large

[ https://issues.apache.org/jira/browse/BEAM-1089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1089: Labels: stale-P2 (was: ) > Jenkins comments on PRs are too many & too large >

[jira] [Commented] (BEAM-1305) Support additional configuration in BigQueryServices.insertAll()

[ https://issues.apache.org/jira/browse/BEAM-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132082#comment-17132082 ] Beam JIRA Bot commented on BEAM-1305: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-1667) Move python content for Pipeline I/O authoring over into new Pipeline I/O section

[ https://issues.apache.org/jira/browse/BEAM-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132035#comment-17132035 ] Beam JIRA Bot commented on BEAM-1667: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-1952) Add more integration tests for python SDK

[ https://issues.apache.org/jira/browse/BEAM-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131994#comment-17131994 ] Beam JIRA Bot commented on BEAM-1952: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-1363) Python SDK should be fully integrated with Maven

[ https://issues.apache.org/jira/browse/BEAM-1363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1363: Labels: stale-P2 (was: ) > Python SDK should be fully integrated with Maven >

[jira] [Updated] (BEAM-1453) Unicode chars in local file system paths break dataflow runner tests.

[ https://issues.apache.org/jira/browse/BEAM-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1453: Labels: stale-P2 (was: ) > Unicode chars in local file system paths break dataflow runner tests. >

[jira] [Updated] (BEAM-1028) Merge content from blog post into /documentation/pipelines/test-your-pipeline.md

[ https://issues.apache.org/jira/browse/BEAM-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1028: Labels: stale-P2 (was: ) > Merge content from blog post into >

[jira] [Updated] (BEAM-1322) Update WordCount snippet in snippets.py

[ https://issues.apache.org/jira/browse/BEAM-1322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1322: Labels: stale-P2 (was: ) > Update WordCount snippet in snippets.py >

[jira] [Commented] (BEAM-1008) KeyedWorkItemCoder claims three coder arguments in getCoderArguments but only has two generic type variables

[ https://issues.apache.org/jira/browse/BEAM-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132114#comment-17132114 ] Beam JIRA Bot commented on BEAM-1008: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-60) FileBasedSource/IOChannelFactory: Custom glob expansion

[ https://issues.apache.org/jira/browse/BEAM-60?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-60: -- Labels: stale-P2 (was: ) > FileBasedSource/IOChannelFactory: Custom glob expansion >

[jira] [Updated] (BEAM-1045) Windows OS compatibilities

[ https://issues.apache.org/jira/browse/BEAM-1045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1045: Labels: stale-P2 (was: ) > Windows OS compatibilities > -- > >

[jira] [Updated] (BEAM-2667) JStorm runner: views translation could be simplified after merge with master

[ https://issues.apache.org/jira/browse/BEAM-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2667: Labels: stale-assigned (was: ) > JStorm runner: views translation could be simplified after merge

[jira] [Commented] (BEAM-1169) MetricsTest matchers should loosen expectations on attempted values

[ https://issues.apache.org/jira/browse/BEAM-1169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132093#comment-17132093 ] Beam JIRA Bot commented on BEAM-1169: - This issue is P2 but has been unassigned without any comment

[jira] [Work logged] (BEAM-9894) Add batch SnowflakeIO.Write to Java SDK

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

[jira] [Updated] (BEAM-792) In WC Walkthrough: Document how logging works on Apache Spark

[ https://issues.apache.org/jira/browse/BEAM-792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-792: --- Labels: stale-P2 (was: ) > In WC Walkthrough: Document how logging works on Apache Spark >

[jira] [Commented] (BEAM-1118) Support for new Timer API in Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-1118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132100#comment-17132100 ] Beam JIRA Bot commented on BEAM-1118: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-585) Support other message than TextMessage in JmsIO

[ https://issues.apache.org/jira/browse/BEAM-585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132511#comment-17132511 ] Beam JIRA Bot commented on BEAM-585: This issue is assigned but has not received an update in 30 days

[jira] [Updated] (BEAM-1924) pip download failed in post commit

[ https://issues.apache.org/jira/browse/BEAM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1924: Labels: stale-P2 (was: ) > pip download failed in post commit > --

[jira] [Commented] (BEAM-2042) Implement Committed Metrics support for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131978#comment-17131978 ] Beam JIRA Bot commented on BEAM-2042: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-169) Need serialized form and serialVersionUID for user-facing superclasses

[ https://issues.apache.org/jira/browse/BEAM-169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132177#comment-17132177 ] Beam JIRA Bot commented on BEAM-169: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-586) CombineFns with no inputs should produce no outputs when used as a main input

[ https://issues.apache.org/jira/browse/BEAM-586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132154#comment-17132154 ] Beam JIRA Bot commented on BEAM-586: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-1367) Need a way to force a page to be set to a specific language for code blocks

[ https://issues.apache.org/jira/browse/BEAM-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132071#comment-17132071 ] Beam JIRA Bot commented on BEAM-1367: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-3352) Look into adding README in beam/examples so Python examples are more discoverable

[ https://issues.apache.org/jira/browse/BEAM-3352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132307#comment-17132307 ] Beam JIRA Bot commented on BEAM-3352: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1614) Add Meter metric type to Java SDK

[ https://issues.apache.org/jira/browse/BEAM-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132040#comment-17132040 ] Beam JIRA Bot commented on BEAM-1614: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-4040) Direct runner does not wait for failed tasks to teardown

[ https://issues.apache.org/jira/browse/BEAM-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132252#comment-17132252 ] Beam JIRA Bot commented on BEAM-4040: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-2417) Add ZeroMQIO

[ https://issues.apache.org/jira/browse/BEAM-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2417: Labels: stale-assigned triaged (was: triaged) > Add ZeroMQIO > > >

[jira] [Commented] (BEAM-1599) Apex Runner support in PerfKit Benchmarker

[ https://issues.apache.org/jira/browse/BEAM-1599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132045#comment-17132045 ] Beam JIRA Bot commented on BEAM-1599: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132127#comment-17132127 ] Beam JIRA Bot commented on BEAM-912: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-1119) Add a trigger that fires when the watermark passes timestamp

[ https://issues.apache.org/jira/browse/BEAM-1119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1119: Labels: stale-P2 (was: ) > Add a trigger that fires when the watermark passes timestamp >

[jira] [Updated] (BEAM-1725) SparkRunner should deduplicate when an UnboundedSource requires Deduping

[ https://issues.apache.org/jira/browse/BEAM-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1725: Labels: stale-P2 (was: ) > SparkRunner should deduplicate when an UnboundedSource requires

[jira] [Commented] (BEAM-1481) Support SetState in Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132054#comment-17132054 ] Beam JIRA Bot commented on BEAM-1481: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-1161) Update Javadoc/Examples/etc.

[ https://issues.apache.org/jira/browse/BEAM-1161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132094#comment-17132094 ] Beam JIRA Bot commented on BEAM-1161: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-1119) Add a trigger that fires when the watermark passes timestamp

[ https://issues.apache.org/jira/browse/BEAM-1119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132099#comment-17132099 ] Beam JIRA Bot commented on BEAM-1119: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-3920) JmsIO should ack the message before the finalizeCheckpoint

[ https://issues.apache.org/jira/browse/BEAM-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3920: Labels: stale-assigned (was: ) > JmsIO should ack the message before the finalizeCheckpoint >

[jira] [Updated] (BEAM-4091) Typehint annotations don't work with @ptransform_fn annotation

[ https://issues.apache.org/jira/browse/BEAM-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4091: Labels: stale-assigned (was: ) > Typehint annotations don't work with @ptransform_fn annotation >

[jira] [Commented] (BEAM-442) Examples demonstrate code, but not project configuration

[ https://issues.apache.org/jira/browse/BEAM-442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132160#comment-17132160 ] Beam JIRA Bot commented on BEAM-442: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-1462) DirectRunner unnecessarily re-scheules tasks after exceptions

[ https://issues.apache.org/jira/browse/BEAM-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1462: Labels: newbie stale-P2 starter (was: newbie starter) > DirectRunner unnecessarily re-scheules

[jira] [Commented] (BEAM-950) DoFn Setup and Teardown methods should have access to PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132126#comment-17132126 ] Beam JIRA Bot commented on BEAM-950: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-9880) touch: build/target/third_party_licenses/skip: No such file or directory

[ https://issues.apache.org/jira/browse/BEAM-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9880: Labels: stale-assigned (was: ) > touch: build/target/third_party_licenses/skip: No such file or

[jira] [Updated] (BEAM-1736) @DefaultCoder annotation should work with Create

[ https://issues.apache.org/jira/browse/BEAM-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1736: Labels: stale-P2 (was: ) > @DefaultCoder annotation should work with Create >

[jira] [Updated] (BEAM-996) Need trademark footer

[ https://issues.apache.org/jira/browse/BEAM-996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-996: --- Labels: stale-P2 (was: ) > Need trademark footer > - > > Key:

[jira] [Updated] (BEAM-1748) Clean DeprecationWarning from SDK/tests

[ https://issues.apache.org/jira/browse/BEAM-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1748: Labels: newbie stale-P2 starter (was: newbie starter) > Clean DeprecationWarning from SDK/tests >

[jira] [Commented] (BEAM-956) Execute ReduceFnRunner Directly in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132123#comment-17132123 ] Beam JIRA Bot commented on BEAM-956: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-1606) Add support for Dataflow service metrics to PKB

[ https://issues.apache.org/jira/browse/BEAM-1606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1606: Labels: stale-assigned (was: ) > Add support for Dataflow service metrics to PKB >

[jira] [Updated] (BEAM-1668) Add java content for Pipeline I/O authoring

[ https://issues.apache.org/jira/browse/BEAM-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1668: Labels: stale-P2 (was: ) > Add java content for Pipeline I/O authoring >

[jira] [Updated] (BEAM-2688) All IOs should log messages

[ https://issues.apache.org/jira/browse/BEAM-2688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2688: Labels: stale-assigned (was: ) > All IOs should log messages > --- > >

[jira] [Updated] (BEAM-1085) Crunch Runner for Beam

[ https://issues.apache.org/jira/browse/BEAM-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1085: Labels: stale-P2 (was: ) > Crunch Runner for Beam > -- > >

[jira] [Updated] (BEAM-1359) Move most of python sdk README.md to website

[ https://issues.apache.org/jira/browse/BEAM-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1359: Labels: stale-P2 (was: ) > Move most of python sdk README.md to website >

[jira] [Updated] (BEAM-175) Don't leak garbage collection timers in GlobalWindow

[ https://issues.apache.org/jira/browse/BEAM-175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-175: --- Labels: stale-P2 (was: ) > Don't leak garbage collection timers in GlobalWindow >

[jira] [Updated] (BEAM-1563) Flatten Spark runner libraries.

[ https://issues.apache.org/jira/browse/BEAM-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1563: Labels: stale-P2 (was: ) > Flatten Spark runner libraries. > --- > >

[jira] [Updated] (BEAM-988) Support for testing how soon output is emitted

[ https://issues.apache.org/jira/browse/BEAM-988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-988: --- Labels: stale-P2 (was: ) > Support for testing how soon output is emitted >

[jira] [Updated] (BEAM-1729) Make Jenkins timeouts a failure

[ https://issues.apache.org/jira/browse/BEAM-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1729: Labels: stale-P2 (was: ) > Make Jenkins timeouts a failure > --- > >

[jira] [Updated] (BEAM-1615) Add Meter metric type to Python SDK

[ https://issues.apache.org/jira/browse/BEAM-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1615: Labels: stale-P2 (was: ) > Add Meter metric type to Python SDK >

[jira] [Commented] (BEAM-4129) Update Gearpump runner instructions for running WordCount example

[ https://issues.apache.org/jira/browse/BEAM-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132238#comment-17132238 ] Beam JIRA Bot commented on BEAM-4129: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-783) Revisit View.AsSingleton custom transform in Apex runner

[ https://issues.apache.org/jira/browse/BEAM-783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132502#comment-17132502 ] Beam JIRA Bot commented on BEAM-783: This issue is assigned but has not received an update in 30 days

[jira] [Updated] (BEAM-791) In WC Walkthrough: Document how logging works on Apache Flink

[ https://issues.apache.org/jira/browse/BEAM-791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-791: --- Labels: stale-P2 (was: ) > In WC Walkthrough: Document how logging works on Apache Flink >

[jira] [Updated] (BEAM-677) Add element modification check to Python Beam

[ https://issues.apache.org/jira/browse/BEAM-677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-677: --- Labels: stale-P2 (was: ) > Add element modification check to Python Beam >

[jira] [Updated] (BEAM-1943) Add Watermark Metrics in Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1943: Labels: stale-P2 (was: ) > Add Watermark Metrics in Dataflow runner >

[jira] [Commented] (BEAM-819) The DirectRunner can complete before reporting the results of all ModelEnforcements

[ https://issues.apache.org/jira/browse/BEAM-819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132133#comment-17132133 ] Beam JIRA Bot commented on BEAM-819: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-303) Add Machine Learning DSL and dedicated functions

[ https://issues.apache.org/jira/browse/BEAM-303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132167#comment-17132167 ] Beam JIRA Bot commented on BEAM-303: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-3672) FlinkRunner: Implement an Artifact service using the Flink DistributedCache

[ https://issues.apache.org/jira/browse/BEAM-3672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3672: Labels: stale-assigned (was: ) > FlinkRunner: Implement an Artifact service using the Flink

[jira] [Commented] (BEAM-935) Pre-aggregation for group-by-key

[ https://issues.apache.org/jira/browse/BEAM-935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132125#comment-17132125 ] Beam JIRA Bot commented on BEAM-935: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-2146) Continuously run ValidatesRunner suite on Dataflow forcing streaming mode

[ https://issues.apache.org/jira/browse/BEAM-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132415#comment-17132415 ] Beam JIRA Bot commented on BEAM-2146: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1919) Standard IO Metrics

[ https://issues.apache.org/jira/browse/BEAM-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132007#comment-17132007 ] Beam JIRA Bot commented on BEAM-1919: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-478) Create Vector, Matrix types and operations to enable linear algebra API

[ https://issues.apache.org/jira/browse/BEAM-478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132161#comment-17132161 ] Beam JIRA Bot commented on BEAM-478: This issue is P2 but has been unassigned without any comment for

[jira] [Updated] (BEAM-1478) Support MapState in Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1478: Labels: stale-P2 (was: ) > Support MapState in Gearpump runner >

[jira] [Updated] (BEAM-950) DoFn Setup and Teardown methods should have access to PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-950: --- Labels: stale-P2 (was: ) > DoFn Setup and Teardown methods should have access to PipelineOptions >

[jira] [Updated] (BEAM-1172) Precommit integration tests should include some merging windows

[ https://issues.apache.org/jira/browse/BEAM-1172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1172: Labels: stale-P2 (was: ) > Precommit integration tests should include some merging windows >

[jira] [Commented] (BEAM-1610) Add support for Python SDK to Dataflow in PKB

[ https://issues.apache.org/jira/browse/BEAM-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132042#comment-17132042 ] Beam JIRA Bot commented on BEAM-1610: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-956) Execute ReduceFnRunner Directly in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-956: --- Labels: stale-P2 (was: ) > Execute ReduceFnRunner Directly in Flink Runner >

[jira] [Updated] (BEAM-1062) Shade SDK based on a whitelist instead of a blacklist

[ https://issues.apache.org/jira/browse/BEAM-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1062: Labels: stale-P2 (was: ) > Shade SDK based on a whitelist instead of a blacklist >

[jira] [Commented] (BEAM-2155) Investigate problem creating Map PCollection view on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131964#comment-17131964 ] Beam JIRA Bot commented on BEAM-2155: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-1359) Move most of python sdk README.md to website

[ https://issues.apache.org/jira/browse/BEAM-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132074#comment-17132074 ] Beam JIRA Bot commented on BEAM-1359: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-1607) Add support for Flink cluster metrics to PerfKit Benchmarker

[ https://issues.apache.org/jira/browse/BEAM-1607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1607: Labels: stale-assigned (was: ) > Add support for Flink cluster metrics to PerfKit Benchmarker >

[jira] [Updated] (BEAM-3663) Port SplittableParDoProcessFnTest off DoFnTester

[ https://issues.apache.org/jira/browse/BEAM-3663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3663: Labels: beginner newbie stale-assigned starter (was: beginner newbie starter) > Port

[jira] [Commented] (BEAM-521) Execute some bounded source reads via composite transform

[ https://issues.apache.org/jira/browse/BEAM-521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132157#comment-17132157 ] Beam JIRA Bot commented on BEAM-521: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-1613) Meter metric type

[ https://issues.apache.org/jira/browse/BEAM-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132041#comment-17132041 ] Beam JIRA Bot commented on BEAM-1613: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-1613) Meter metric type

[ https://issues.apache.org/jira/browse/BEAM-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1613: Labels: stale-P2 (was: ) > Meter metric type > - > > Key:

[jira] [Updated] (BEAM-1911) SnippetsTest print lots of debug log messages

[ https://issues.apache.org/jira/browse/BEAM-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1911: Labels: stale-P2 (was: ) > SnippetsTest print lots of debug log messages >

[jira] [Commented] (BEAM-1602) Spark Runner support for PerfKit Benchmarker

[ https://issues.apache.org/jira/browse/BEAM-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132044#comment-17132044 ] Beam JIRA Bot commented on BEAM-1602: - This issue is P2 but has been unassigned without any comment

[jira] [Updated] (BEAM-623) Integate Flink's RestartStrategies in FlinkPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-623: --- Labels: stale-P2 (was: ) > Integate Flink's RestartStrategies in FlinkPipelineOptions >

[jira] [Commented] (BEAM-2680) Improve scalability of the Watch transform

[ https://issues.apache.org/jira/browse/BEAM-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132369#comment-17132369 ] Beam JIRA Bot commented on BEAM-2680: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1308) Consider removing TimeDomain from user APIs

[ https://issues.apache.org/jira/browse/BEAM-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132081#comment-17132081 ] Beam JIRA Bot commented on BEAM-1308: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-3945) TFRecord Performance Tests doesn't work on hdfs

[ https://issues.apache.org/jira/browse/BEAM-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132258#comment-17132258 ] Beam JIRA Bot commented on BEAM-3945: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-988) Support for testing how soon output is emitted

[ https://issues.apache.org/jira/browse/BEAM-988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132119#comment-17132119 ] Beam JIRA Bot commented on BEAM-988: This issue is P2 but has been unassigned without any comment for

[jira] [Commented] (BEAM-1736) @DefaultCoder annotation should work with Create

[ https://issues.apache.org/jira/browse/BEAM-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132021#comment-17132021 ] Beam JIRA Bot commented on BEAM-1736: - This issue is P2 but has been unassigned without any comment

[jira] [Commented] (BEAM-3680) Revise code on state & timers blog posts

[ https://issues.apache.org/jira/browse/BEAM-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132280#comment-17132280 ] Beam JIRA Bot commented on BEAM-3680: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-1610) Add support for Python SDK to Dataflow in PKB

[ https://issues.apache.org/jira/browse/BEAM-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1610: Labels: stale-P2 (was: ) > Add support for Python SDK to Dataflow in PKB >

[jira] [Updated] (BEAM-1261) State API should allow state to be managed in different windows

[ https://issues.apache.org/jira/browse/BEAM-1261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1261: Labels: stale-P2 (was: ) > State API should allow state to be managed in different windows >

[jira] [Updated] (BEAM-1631) Flink runner: submit job to a Flink-on-YARN cluster

[ https://issues.apache.org/jira/browse/BEAM-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1631: Labels: stale-assigned (was: ) > Flink runner: submit job to a Flink-on-YARN cluster >

<    5   6   7   8   9   10   11   12   13   14   >