[jira] [Updated] (BEAM-4381) Provide DoFn to convert a Row (record with schema) to a javax.json.JsonObject

[ https://issues.apache.org/jira/browse/BEAM-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4381: Labels: stale-P2 (was: ) > Provide DoFn to convert a Row (record with schema) to a

[jira] [Updated] (BEAM-6840) PostRelease failing on Dataflow due to java.lang.NoSuchMethodError: DoFnSignature$ProcessElementMethod.getRowParameter(): DoFnSignature$Parameter$RowParameter

[ https://issues.apache.org/jira/browse/BEAM-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6840: Labels: (was: stale-assigned) > PostRelease failing on Dataflow due to

[jira] [Commented] (BEAM-6654) Support SDF within ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-6654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131431#comment-17131431 ] Beam JIRA Bot commented on BEAM-6654: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-4786) Distinct has bad parallelism characteristics

[ https://issues.apache.org/jira/browse/BEAM-4786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131586#comment-17131586 ] Beam JIRA Bot commented on BEAM-4786: - This issue was marked "stale-assigned" and has not received a

[jira] [Assigned] (BEAM-6382) SamzaRunner: add an option to read configs using a user-defined factory

[ https://issues.apache.org/jira/browse/BEAM-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6382: --- Assignee: (was: Xinyu Liu) > SamzaRunner: add an option to read configs using a

[jira] [Commented] (BEAM-3393) Empty flattens cannot be used as side inputs.

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

[jira] [Assigned] (BEAM-4459) Schemas across pipeline modifications

[ https://issues.apache.org/jira/browse/BEAM-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-4459: --- Assignee: (was: Reuven Lax) > Schemas across pipeline modifications >

[jira] [Assigned] (BEAM-8413) test_streaming_pipeline_returns_expected_user_metrics_fnapi_it failed on latest PostCommit Py36

[ https://issues.apache.org/jira/browse/BEAM-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8413: --- Assignee: (was: Ankur Goenka) >

[jira] [Commented] (BEAM-8140) Python API: PTransform should be immutable and reusable

[ https://issues.apache.org/jira/browse/BEAM-8140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131254#comment-17131254 ] Beam JIRA Bot commented on BEAM-8140: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-8154) IOTypeHints: merge None and ((), {}) into one value

[ https://issues.apache.org/jira/browse/BEAM-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131247#comment-17131247 ] Beam JIRA Bot commented on BEAM-8154: - This issue was marked "stale-assigned" and has not received a

[jira] [Assigned] (BEAM-9702) Update Java KinesisIO to support AWS SDK v2

[ https://issues.apache.org/jira/browse/BEAM-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-9702: --- Assignee: (was: Jonothan Farr) > Update Java KinesisIO to support AWS SDK v2 >

[jira] [Updated] (BEAM-9168) AppliedPTransform.from_runner_api fails on unexpected non-ParDo class with PAR_DO.urn

[ https://issues.apache.org/jira/browse/BEAM-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9168: Labels: (was: stale-assigned) > AppliedPTransform.from_runner_api fails on unexpected non-ParDo

[jira] [Assigned] (BEAM-8441) Python 3 pipeline fails with errors in StockUnpickler.find_class() during loading a main session.

[ https://issues.apache.org/jira/browse/BEAM-8441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8441: --- Assignee: (was: Valentyn Tymofieiev) > Python 3 pipeline fails with errors in

[jira] [Updated] (BEAM-9335) update hard-coded coder id when translating Java external transforms

[ https://issues.apache.org/jira/browse/BEAM-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9335: Labels: (was: stale-assigned) > update hard-coded coder id when translating Java external

[jira] [Updated] (BEAM-7934) Dataflow Python SDK logging: step_id is always empty string

[ https://issues.apache.org/jira/browse/BEAM-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7934: Labels: (was: stale-assigned) > Dataflow Python SDK logging: step_id is always empty string >

[jira] [Assigned] (BEAM-7611) Python BigTableIO IT is not running in any test suites

[ https://issues.apache.org/jira/browse/BEAM-7611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7611: --- Assignee: (was: Solomon Duskis) > Python BigTableIO IT is not running in any test suites

[jira] [Assigned] (BEAM-8487) Python typehints: support forward references

[ https://issues.apache.org/jira/browse/BEAM-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8487: --- Assignee: (was: Udi Meiri) > Python typehints: support forward references >

[jira] [Assigned] (BEAM-8018) Detect unexported fields in unregistered types for better error messages

[ https://issues.apache.org/jira/browse/BEAM-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8018: --- Assignee: (was: Robert Burke) > Detect unexported fields in unregistered types for

[jira] [Assigned] (BEAM-8961) GBK Python Load test on Flink fails in Jenkins jobs

[ https://issues.apache.org/jira/browse/BEAM-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8961: --- Assignee: (was: Kamil Wasilewski) > GBK Python Load test on Flink fails in Jenkins jobs

[jira] [Commented] (BEAM-9549) Flaky portableWordCountBatch and portableWordCountStreaming tests

[ https://issues.apache.org/jira/browse/BEAM-9549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131025#comment-17131025 ] Beam JIRA Bot commented on BEAM-9549: - This issue was marked "stale-assigned" and has not received a

[jira] [Updated] (BEAM-9425) explicitly register default environment instead of assuming the first one as a default

[ https://issues.apache.org/jira/browse/BEAM-9425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9425: Labels: (was: stale-assigned) > explicitly register default environment instead of assuming the

[jira] [Assigned] (BEAM-8587) Add TestStream support for Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-8587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8587: --- Assignee: (was: Andrew Crites) > Add TestStream support for Dataflow runner >

[jira] [Assigned] (BEAM-8212) StatefulParDoFn creates GC timers for every record

[ https://issues.apache.org/jira/browse/BEAM-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8212: --- Assignee: (was: Akshay Iyangar) > StatefulParDoFn creates GC timers for every record >

[jira] [Assigned] (BEAM-8322) Log when artifacts can't be fetched on startup

[ https://issues.apache.org/jira/browse/BEAM-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8322: --- Assignee: (was: Kyle Weaver) > Log when artifacts can't be fetched on startup >

[jira] [Assigned] (BEAM-7738) Support PubSubIO to be configured externally for use with other SDKs

[ https://issues.apache.org/jira/browse/BEAM-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7738: --- Assignee: (was: Chad Dombrova) > Support PubSubIO to be configured externally for use

[jira] [Assigned] (BEAM-7992) Unhandled type_constraint in apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests.test_big_query_write_new_types

[ https://issues.apache.org/jira/browse/BEAM-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7992: --- Assignee: (was: Udi Meiri) > Unhandled type_constraint in >

[jira] [Updated] (BEAM-9073) PipelineVisitor is topologically-order dependent

[ https://issues.apache.org/jira/browse/BEAM-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9073: Labels: (was: stale-assigned) > PipelineVisitor is topologically-order dependent >

[jira] [Commented] (BEAM-7964) Multiple triggering SQL pipeline

[ https://issues.apache.org/jira/browse/BEAM-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131277#comment-17131277 ] Beam JIRA Bot commented on BEAM-7964: - This issue was marked "stale-assigned" and has not received a

[jira] [Assigned] (BEAM-9117) Clustering coder does not get used for BQ multi-partitioned tables

[ https://issues.apache.org/jira/browse/BEAM-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-9117: --- Assignee: (was: Chamikara Madhusanka Jayalath) > Clustering coder does not get used for

[jira] [Commented] (BEAM-8843) Limit bigquery.py exponential backoff to 60s

[ https://issues.apache.org/jira/browse/BEAM-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131153#comment-17131153 ] Beam JIRA Bot commented on BEAM-8843: - This issue was marked "stale-assigned" and has not received a

[jira] [Assigned] (BEAM-9071) Ignore pytype untill the typing feature is fully developed

[ https://issues.apache.org/jira/browse/BEAM-9071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-9071: --- Assignee: (was: Udi Meiri) > Ignore pytype untill the typing feature is fully developed

[jira] [Updated] (BEAM-9131) cleanup bug in run_rc_validation.sh

[ https://issues.apache.org/jira/browse/BEAM-9131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9131: Labels: (was: stale-assigned) > cleanup bug in run_rc_validation.sh >

[jira] [Assigned] (BEAM-8580) Request Python API to support windows ClosingBehavior

[ https://issues.apache.org/jira/browse/BEAM-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8580: --- Assignee: (was: Yichi Zhang) > Request Python API to support windows ClosingBehavior >

[jira] [Updated] (BEAM-8023) Allow specifying BigQuery Storage API readOptions at runtime

[ https://issues.apache.org/jira/browse/BEAM-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-8023: Labels: (was: stale-assigned) > Allow specifying BigQuery Storage API readOptions at runtime >

[jira] [Updated] (BEAM-7471) DirectRunner GameStats fails, ValueError: PCollection of size 2 with more than one element accessed as a singleton view. First two elements encountered are "181.611538462"

[ https://issues.apache.org/jira/browse/BEAM-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7471: Labels: (was: stale-assigned) > DirectRunner GameStats fails, ValueError: PCollection of size 2

[jira] [Updated] (BEAM-9624) Combine operation should support only converting to accumulators

[ https://issues.apache.org/jira/browse/BEAM-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9624: Labels: (was: stale-assigned) > Combine operation should support only converting to accumulators

[jira] [Updated] (BEAM-9134) RedisIO.ReadAll incorrectly alters windowing behavior

[ https://issues.apache.org/jira/browse/BEAM-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9134: Labels: (was: stale-assigned) > RedisIO.ReadAll incorrectly alters windowing behavior >

[jira] [Assigned] (BEAM-8541) Beam directRunner documentation java tab has python information

[ https://issues.apache.org/jira/browse/BEAM-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8541: --- Assignee: (was: Brent Worden) > Beam directRunner documentation java tab has python

[jira] [Assigned] (BEAM-7925) ParquetIO supports neither column projection nor filter predicate

[ https://issues.apache.org/jira/browse/BEAM-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7925: --- Assignee: (was: Heejong Lee) > ParquetIO supports neither column projection nor filter

[jira] [Assigned] (BEAM-7968) UDF case insensitive

[ https://issues.apache.org/jira/browse/BEAM-7968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7968: --- Assignee: (was: Andrew Pilloud) > UDF case insensitive > > >

[jira] [Assigned] (BEAM-8307) NPE in Calcite dialect when input PCollection has logical type in schema, from JdbcIO Transform

[ https://issues.apache.org/jira/browse/BEAM-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8307: --- Assignee: (was: Rahul Patwari) > NPE in Calcite dialect when input PCollection has

[jira] [Updated] (BEAM-9750) Streaming Word Count Example Documents is out of date (Python)

[ https://issues.apache.org/jira/browse/BEAM-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9750: Labels: (was: stale-assigned) > Streaming Word Count Example Documents is out of date (Python) >

[jira] [Updated] (BEAM-8125) SchemaCoder/RowCoder.verifyDeterministic throws NPE when schema has a logical type

[ https://issues.apache.org/jira/browse/BEAM-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-8125: Labels: (was: stale-assigned) > SchemaCoder/RowCoder.verifyDeterministic throws NPE when schema

[jira] [Assigned] (BEAM-7983) Template parameters don't work if they are only used in DoFns

[ https://issues.apache.org/jira/browse/BEAM-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7983: --- Assignee: (was: Luke Cwik) > Template parameters don't work if they are only used in

[jira] [Assigned] (BEAM-8823) Make FnApiRunner work by executing ready elements instead of stages

[ https://issues.apache.org/jira/browse/BEAM-8823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-8823: --- Assignee: (was: Pablo Estrada) > Make FnApiRunner work by executing ready elements

[jira] [Commented] (BEAM-8681) Beam Dependency Update Request: com.google.api.grpc:proto-google-cloud-pubsub-v1

[ https://issues.apache.org/jira/browse/BEAM-8681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131164#comment-17131164 ] Beam JIRA Bot commented on BEAM-8681: - This issue was marked "stale-assigned" and has not received a

[jira] [Updated] (BEAM-7984) [python] The coder returned for typehints.List should be IterableCoder

[ https://issues.apache.org/jira/browse/BEAM-7984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7984: Labels: (was: stale-assigned) > [python] The coder returned for typehints.List should be

[jira] [Assigned] (BEAM-9780) Add a DICOM IO Connector for Google Cloud Healthcare API

[ https://issues.apache.org/jira/browse/BEAM-9780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-9780: --- Assignee: (was: David Anderson) > Add a DICOM IO Connector for Google Cloud Healthcare

[jira] [Updated] (BEAM-8572) tox environment: assert on Cython source file presence

[ https://issues.apache.org/jira/browse/BEAM-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-8572: Labels: (was: stale-assigned) > tox environment: assert on Cython source file presence >

[jira] [Updated] (BEAM-8571) Use SDK version in default Go container tag

[ https://issues.apache.org/jira/browse/BEAM-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-8571: Labels: (was: stale-assigned) > Use SDK version in default Go container tag >

[jira] [Commented] (BEAM-8613) Add environment variable support to Docker environment

[ https://issues.apache.org/jira/browse/BEAM-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131171#comment-17131171 ] Beam JIRA Bot commented on BEAM-8613: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-8510) SamzaJobServerDriver to extend JobServerDriver

[ https://issues.apache.org/jira/browse/BEAM-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131186#comment-17131186 ] Beam JIRA Bot commented on BEAM-8510: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-8388) Update Avro to 1.9.1 from 1.8.2

[ https://issues.apache.org/jira/browse/BEAM-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131203#comment-17131203 ] Beam JIRA Bot commented on BEAM-8388: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-8809) AvroWriteRequest should have a public constructor

[ https://issues.apache.org/jira/browse/BEAM-8809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131156#comment-17131156 ] Beam JIRA Bot commented on BEAM-8809: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-8276) Document Flink pipeline jars on website

[ https://issues.apache.org/jira/browse/BEAM-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131224#comment-17131224 ] Beam JIRA Bot commented on BEAM-8276: - This issue was marked "stale-assigned" and has not received a

[jira] [Updated] (BEAM-8277) Make docker build quicker

[ https://issues.apache.org/jira/browse/BEAM-8277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-8277: Labels: (was: stale-assigned) > Make docker build quicker > - > >

[jira] [Commented] (BEAM-8912) PreCommit_Python2_PVR_Flink_Commit flaky

[ https://issues.apache.org/jira/browse/BEAM-8912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131142#comment-17131142 ] Beam JIRA Bot commented on BEAM-8912: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-7391) Colab examples for other transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131351#comment-17131351 ] Beam JIRA Bot commented on BEAM-7391: - This issue was marked "stale-assigned" and has not received a

[jira] [Assigned] (BEAM-7888) Test Multi Process Direct Runner With Largish Data

[ https://issues.apache.org/jira/browse/BEAM-7888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-7888: --- Assignee: (was: Hannah Jiang) > Test Multi Process Direct Runner With Largish Data >

[jira] [Commented] (BEAM-8364) SchemaCoder inconsistent equality behavior for POJO

[ https://issues.apache.org/jira/browse/BEAM-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131207#comment-17131207 ] Beam JIRA Bot commented on BEAM-8364: - This issue was marked "stale-assigned" and has not received a

[jira] [Updated] (BEAM-7765) Add test for snippet accessing_valueprovider_info_after_run

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

[jira] [Commented] (BEAM-8424) Java Dataflow ValidatesRunner tests are timeouting

[ https://issues.apache.org/jira/browse/BEAM-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131200#comment-17131200 ] Beam JIRA Bot commented on BEAM-8424: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-8924) Beam Dependency Update Request: org.apache.tika

[ https://issues.apache.org/jira/browse/BEAM-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17131137#comment-17131137 ] Beam JIRA Bot commented on BEAM-8924: - This issue was marked "stale-assigned" and has not received a

[jira] [Commented] (BEAM-2230) Core SDK ApiSurface should be only org.apache.beam.sdk and should be defined outside of the general ApiSurface class

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

[jira] [Updated] (BEAM-2428) Enforce all inputs and outputs are properly declared in Transform Hierarchy

[ https://issues.apache.org/jira/browse/BEAM-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2428: Labels: stale-P2 (was: ) > Enforce all inputs and outputs are properly declared in Transform

[jira] [Updated] (BEAM-2341) Make our Python pom files virtualenv-compatible.

[ https://issues.apache.org/jira/browse/BEAM-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2341: Labels: stale-P2 (was: ) > Make our Python pom files virtualenv-compatible. >

[jira] [Updated] (BEAM-2470) Inconsistent behavior on the functioning of the dataflow templates?

[ https://issues.apache.org/jira/browse/BEAM-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2470: Labels: stale-P2 (was: ) > Inconsistent behavior on the functioning of the dataflow templates? >

[jira] [Commented] (BEAM-2458) Move HashingFn from test -> main to make it more accessible

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

[jira] [Commented] (BEAM-3783) Streaming Beam SQL benchmarks on all of our runners

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

[jira] [Updated] (BEAM-349) Spark runner should provide a default BoM

[ https://issues.apache.org/jira/browse/BEAM-349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-349: --- Labels: stale-assigned (was: ) > Spark runner should provide a default BoM >

[jira] [Updated] (BEAM-1330) DatastoreIO Writes should flush early when duplicate keys arrive.

[ https://issues.apache.org/jira/browse/BEAM-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1330: Labels: stale-assigned (was: ) > DatastoreIO Writes should flush early when duplicate keys arrive.

[jira] [Commented] (BEAM-92) Data-dependent sinks

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

[jira] [Updated] (BEAM-4152) Support Go session windowing

[ https://issues.apache.org/jira/browse/BEAM-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4152: Labels: stale-assigned (was: ) > Support Go session windowing > > >

[jira] [Updated] (BEAM-2363) Function composition for SerializableFunction

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

[jira] [Updated] (BEAM-4070) Disable cython profiling by default

[ https://issues.apache.org/jira/browse/BEAM-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4070: Labels: stale-assigned (was: ) > Disable cython profiling by default >

[jira] [Commented] (BEAM-4132) Element type inference doesn't work for multi-output DoFns

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

[jira] [Commented] (BEAM-4114) Allow null as leftNullValue/rightNullValue in Join.fullOuterJoin()

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

[jira] [Updated] (BEAM-9354) How long does PubSubIO message deduplication last?

[ https://issues.apache.org/jira/browse/BEAM-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9354: Labels: gcp pubsubio (was: gcp pubsubio stale-assigned) > How long does PubSubIO message

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

[ https://issues.apache.org/jira/browse/BEAM-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3680: Labels: stale-assigned (was: ) > Revise code on state & timers blog posts >

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

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

[jira] [Commented] (BEAM-1759) add guideline doc 'run on YARN' in page 'Apache Flink Runner'

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

[jira] [Commented] (BEAM-2404) BigQueryIO reading stalls if no data is returned by query

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

[jira] [Updated] (BEAM-2085) Transforms could give hints to runners on resource requirements

[ https://issues.apache.org/jira/browse/BEAM-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2085: Labels: stale-assigned (was: ) > Transforms could give hints to runners on resource requirements >

[jira] [Updated] (BEAM-2693) GearpumpRunner Fn API based ParDo operator

[ https://issues.apache.org/jira/browse/BEAM-2693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2693: Labels: stale-assigned (was: ) > GearpumpRunner Fn API based ParDo operator >

[jira] [Updated] (BEAM-1525) RuntimeWarning: Unable to load plugin beam_test_plugin when using nosetests

[ https://issues.apache.org/jira/browse/BEAM-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1525: Labels: stale-assigned test (was: test) > RuntimeWarning: Unable to load plugin beam_test_plugin

[jira] [Updated] (BEAM-2696) Support new State API in GearpumpRunner

[ https://issues.apache.org/jira/browse/BEAM-2696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2696: Labels: stale-assigned (was: ) > Support new State API in GearpumpRunner >

[jira] [Commented] (BEAM-454) Validate Pubsub Topic exists when reading

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

[jira] [Updated] (BEAM-3289) Add ReadFromBigQuery and several other cleanups of bigquery.py

[ https://issues.apache.org/jira/browse/BEAM-3289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3289: Labels: stale-assigned (was: ) > Add ReadFromBigQuery and several other cleanups of bigquery.py >

[jira] [Updated] (BEAM-482) Log RPC requests when they fails to improve error messages

[ https://issues.apache.org/jira/browse/BEAM-482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-482: --- Labels: stale-assigned (was: ) > Log RPC requests when they fails to improve error messages >

[jira] [Commented] (BEAM-2792) Populate All Runner API Components from the Python SDK

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

[jira] [Commented] (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:comment-tabpanel=17132345#comment-17132345 ] Beam JIRA Bot commented on BEAM-2837: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-9932) Add documentation describing cross-language test pipelines

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

[jira] [Commented] (BEAM-4379) Make ParquetIO Read splittable

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

[jira] [Updated] (BEAM-1754) Will Dataflow ever support Node.js with an SDK similar to Java or Python?

[ https://issues.apache.org/jira/browse/BEAM-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1754: Labels: node.js stale-assigned (was: node.js) > Will Dataflow ever support Node.js with an SDK

[jira] [Updated] (BEAM-1800) Can't save datastore objects

[ https://issues.apache.org/jira/browse/BEAM-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1800: Labels: stale-assigned (was: ) > Can't save datastore objects > > >

[jira] [Updated] (BEAM-2416) Add AkkaIO

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

[jira] [Commented] (BEAM-621) Add MapValues and MapKeys functions

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

[jira] [Updated] (BEAM-3937) Track performance of output_counter before feature enabled

[ https://issues.apache.org/jira/browse/BEAM-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3937: Labels: stale-assigned (was: ) > Track performance of output_counter before feature enabled >

[jira] [Commented] (BEAM-1800) Can't save datastore objects

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

[jira] [Commented] (BEAM-9) Storm Runner

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

  1   2   3   4   5   6   7   8   9   10   >