[jira] [Updated] (BEAM-6503) PCollectionViews$SimplePCollectionView.hashCode once again allocates memory (fix reverted, then fixed again)

[ https://issues.apache.org/jira/browse/BEAM-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6503: Labels: (was: stale-assigned) > PCollectionViews$SimplePCollectionView.hashCode once again

[jira] [Commented] (BEAM-5275) Beam SQL RAND(seed) function isn't compatible with dofn

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

[jira] [Updated] (BEAM-5254) Add Samza Runner translator registrar and refactor config generation

[ https://issues.apache.org/jira/browse/BEAM-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5254: Labels: (was: stale-assigned) > Add Samza Runner translator registrar and refactor config

[jira] [Updated] (BEAM-4613) Improve performance of SchemaCoder

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

[jira] [Assigned] (BEAM-6345) BigtableWriteIT. testE2EBigtableWrite got stuck with portable dataflow worker

[ https://issues.apache.org/jira/browse/BEAM-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6345: --- Assignee: (was: Boyuan Zhang) > BigtableWriteIT. testE2EBigtableWrite got stuck with

[jira] [Updated] (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 updated BEAM-4459: Labels: (was: stale-assigned) > Schemas across pipeline modifications >

[jira] [Commented] (BEAM-6557) Add IPython notebooks for quickstarts and custom I/O

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

[jira] [Updated] (BEAM-5468) Allow runner to set worker log level in Python SDK harness.

[ https://issues.apache.org/jira/browse/BEAM-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5468: Labels: (was: stale-assigned) > Allow runner to set worker log level in Python SDK harness. >

[jira] [Assigned] (BEAM-6757) Random "IllegalStateException: TimestampCombiner moved element from X to Y" seen in running topology

[ https://issues.apache.org/jira/browse/BEAM-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6757: --- Assignee: (was: Kenneth Knowles) > Random "IllegalStateException: TimestampCombiner

[jira] [Commented] (BEAM-4676) Samza runner documentation

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

[jira] [Commented] (BEAM-5330) Support zero-shuffle grouping operations

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

[jira] [Updated] (BEAM-6252) SamzaRunner: Add a registrar to allow customized DoFnInvoker

[ https://issues.apache.org/jira/browse/BEAM-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6252: Labels: (was: stale-assigned) > SamzaRunner: Add a registrar to allow customized DoFnInvoker >

[jira] [Updated] (BEAM-6004) DirectRunner doesn't trigger deserialization of coders.

[ https://issues.apache.org/jira/browse/BEAM-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6004: Labels: (was: stale-assigned) > DirectRunner doesn't trigger deserialization of coders. >

[jira] [Updated] (BEAM-6887) Streaming Spanner Writer transform

[ https://issues.apache.org/jira/browse/BEAM-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6887: Labels: (was: stale-assigned) > Streaming Spanner Writer transform >

[jira] [Updated] (BEAM-6253) SamzaRunner: Add a few customized transforms for runner use cases

[ https://issues.apache.org/jira/browse/BEAM-6253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6253: Labels: (was: stale-assigned) > SamzaRunner: Add a few customized transforms for runner use cases

[jira] [Commented] (BEAM-5795) Can SQL Query 5 be simplified?

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

[jira] [Commented] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

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

[jira] [Assigned] (BEAM-5670) Add more integration tests for BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-5670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5670: --- Assignee: (was: Pablo Estrada) > Add more integration tests for BigQueryIO >

[jira] [Assigned] (BEAM-6499) Support HDFS for artifact staging with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6499: --- Assignee: (was: Ankur Goenka) > Support HDFS for artifact staging with Flink Runner >

[jira] [Assigned] (BEAM-4747) Python LocalFileSystem directory-creation semantics

[ https://issues.apache.org/jira/browse/BEAM-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-4747: --- Assignee: (was: Ryan Williams) > Python LocalFileSystem directory-creation semantics >

[jira] [Assigned] (BEAM-6392) Add support for new BigQuery streaming read API to BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-6392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6392: --- Assignee: (was: Kenneth Jung) > Add support for new BigQuery streaming read API to

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

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

[jira] [Commented] (BEAM-6831) python sdk WriteToBigQuery excessive usage of metered API

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

[jira] [Commented] (BEAM-6444) Equality tests in coders.py are broken

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

[jira] [Updated] (BEAM-6903) Go IT fails on quota issues frequently

[ https://issues.apache.org/jira/browse/BEAM-6903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6903: Labels: flake (was: flake stale-assigned) > Go IT fails on quota issues frequently >

[jira] [Commented] (BEAM-5504) PubsubAvroTable

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

[jira] [Assigned] (BEAM-5898) Beam Dependency Update Request: io.grpc:grpc-core

[ https://issues.apache.org/jira/browse/BEAM-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5898: --- Assignee: (was: Tomo Suzuki) > Beam Dependency Update Request: io.grpc:grpc-core >

[jira] [Updated] (BEAM-4298) Perfkit runs are always "official" while running them with Jenkins

[ https://issues.apache.org/jira/browse/BEAM-4298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4298: Labels: stale-P2 triaged (was: triaged) > Perfkit runs are always "official" while running them

[jira] [Assigned] (BEAM-4613) Improve performance of SchemaCoder

[ https://issues.apache.org/jira/browse/BEAM-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-4613: --- Assignee: (was: Reuven Lax) > Improve performance of SchemaCoder >

[jira] [Updated] (BEAM-6149) Resolving gcp extra dependencies breaks ssl support when contacting google

[ https://issues.apache.org/jira/browse/BEAM-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6149: Labels: easyfix usability (was: easyfix stale-assigned usability) > Resolving gcp extra

[jira] [Commented] (BEAM-6493) examples in Kotlin

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

[jira] [Updated] (BEAM-5198) add functions to add/remove/list tables in BeamSqlEnv

[ https://issues.apache.org/jira/browse/BEAM-5198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5198: Labels: (was: stale-assigned) > add functions to add/remove/list tables in BeamSqlEnv >

[jira] [Commented] (BEAM-6775) Fix "unparseable args" warning for --kms_key_name

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

[jira] [Updated] (BEAM-6385) Add support for dynamic destinations when writing to Kafka

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

[jira] [Assigned] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6197: --- Assignee: (was: Alan Myrvold) > Log time for Dataflow GCS upload of staged files >

[jira] [Updated] (BEAM-6299) Update JUnit to fix incompatibility between parameterized tests and include categories

[ https://issues.apache.org/jira/browse/BEAM-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6299: Labels: (was: stale-assigned) > Update JUnit to fix incompatibility between parameterized tests

[jira] [Updated] (BEAM-5130) Support ALL (sub query)

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

[jira] [Assigned] (BEAM-5097) Increment counter for "small words" in go SDK example

[ https://issues.apache.org/jira/browse/BEAM-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5097: --- Assignee: (was: Holden Karau) > Increment counter for "small words" in go SDK example >

[jira] [Assigned] (BEAM-6525) Allow calling stored proc in JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-6525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6525: --- Assignee: (was: Jean-Baptiste Onofré) > Allow calling stored proc in JdbcIO >

[jira] [Updated] (BEAM-6404) FnAPI translation error

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

[jira] [Assigned] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub

[ https://issues.apache.org/jira/browse/BEAM-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5539: --- Assignee: (was: Udi Meiri) > Beam Dependency Update Request: google-cloud-pubsub >

[jira] [Assigned] (BEAM-4468) Go SDK-Tune in memory pre-combine caching for Lifted Combines.

[ https://issues.apache.org/jira/browse/BEAM-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-4468: --- Assignee: (was: Robert Burke) > Go SDK-Tune in memory pre-combine caching for Lifted

[jira] [Commented] (BEAM-6107) Logging on Dataflow for Python's Beam 2.7.0 and 2.8.0 not working

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

[jira] [Assigned] (BEAM-4864) run_validatescontainer.sh in Python sdk has hard-coded bucket of sadness

[ https://issues.apache.org/jira/browse/BEAM-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-4864: --- Assignee: (was: Holden Karau) > run_validatescontainer.sh in Python sdk has hard-coded

[jira] [Assigned] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

[ https://issues.apache.org/jira/browse/BEAM-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6073: --- Assignee: (was: Robert Burke) > Go PostCommit Broken -> gogradle needs

[jira] [Commented] (BEAM-6258) Data channel failing after some time for 1G data input

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

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

[ https://issues.apache.org/jira/browse/BEAM-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6733: --- Assignee: (was: Maximilian Michels) > Use Flink 1.6/1.7 prepareSnapshotPreBarrier to

[jira] [Commented] (BEAM-4412) SQL operators and primitive values should use a richer type system than SqlTypeName

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

[jira] [Commented] (BEAM-4298) Perfkit runs are always "official" while running them with Jenkins

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

[jira] [Commented] (BEAM-6253) SamzaRunner: Add a few customized transforms for runner use cases

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

[jira] [Updated] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub

[ https://issues.apache.org/jira/browse/BEAM-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5539: Labels: (was: stale-assigned) > Beam Dependency Update Request: google-cloud-pubsub >

[jira] [Updated] (BEAM-5070) nexmark.sources.UnboundedEventSourceTest.resumeFromCheckpoint is flaky

[ https://issues.apache.org/jira/browse/BEAM-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5070: -- Labels: flake stale-assigned (was: stale-assigned) >

[jira] [Assigned] (BEAM-6972) LTS backport: CassandraIO is broken because of use of bad relocation of guava

[ https://issues.apache.org/jira/browse/BEAM-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6972: --- Assignee: (was: Kenneth Knowles) > LTS backport: CassandraIO is broken because of use of

[jira] [Commented] (BEAM-6715) ./gradlew :beam-runners-google-cloud-dataflow-java:validatesRunner fails due to invalid GCS path

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

[jira] [Commented] (BEAM-6932) SamzaRunner: migrate to use new Samza 1.1.0 liraries

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

[jira] [Commented] (BEAM-6149) Resolving gcp extra dependencies breaks ssl support when contacting google

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

[jira] [Assigned] (BEAM-6372) Direct Runner should marshal data in a similar way to Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-6372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6372: --- Assignee: (was: Robert Burke) > Direct Runner should marshal data in a similar way to

[jira] [Commented] (BEAM-4778) Less wasteful ArtifactStagingService

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

[jira] [Updated] (BEAM-5721) tempRoot flag with trailing slash causes errors.

[ https://issues.apache.org/jira/browse/BEAM-5721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5721: Labels: (was: stale-assigned) > tempRoot flag with trailing slash causes errors. >

[jira] [Commented] (BEAM-6482) starcgen tool should introspect struct doFns/combineFns for embedded types and lift their methods where applicable.

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

[jira] [Updated] (BEAM-6370) Flaky python3 test in Python PreCommit

[ https://issues.apache.org/jira/browse/BEAM-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6370: Labels: (was: stale-assigned) > Flaky python3 test in Python PreCommit >

[jira] [Updated] (BEAM-4790) Make it easier to select code reviewers for PRs

[ https://issues.apache.org/jira/browse/BEAM-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4790: Labels: (was: stale-assigned) > Make it easier to select code reviewers for PRs >

[jira] [Commented] (BEAM-6029) Tensor flow on Flink taking too much time to process data

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

[jira] [Commented] (BEAM-5298) Determine what painpoints exist for the Go SDK WRT the Go Generics Draft Design

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

[jira] [Updated] (BEAM-4831) Fix broken go vet task in the gradle build

[ https://issues.apache.org/jira/browse/BEAM-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4831: Labels: (was: stale-assigned) > Fix broken go vet task in the gradle build >

[jira] [Commented] (BEAM-4747) Python LocalFileSystem directory-creation semantics

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

[jira] [Assigned] (BEAM-6144) Add support for the autoscalingAlgorithm flag

[ https://issues.apache.org/jira/browse/BEAM-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6144: --- Assignee: (was: Robert Burke) > Add support for the autoscalingAlgorithm flag >

[jira] [Updated] (BEAM-5658) Enable SpotBugs in dataflow java worker code

[ https://issues.apache.org/jira/browse/BEAM-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5658: Labels: (was: stale-assigned) > Enable SpotBugs in dataflow java worker code >

[jira] [Updated] (BEAM-6610) [beam_PostCommit_Python_Verify, beam_PostCommit_Java]ResourceExhausted: 429 Your project has exceeded a limit: (type="topics-per-project", current=10000, maximum=10000)

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

[jira] [Updated] (BEAM-4362) Kubectl version on beam executors must be upgraded to at least 1.9.3

[ https://issues.apache.org/jira/browse/BEAM-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4362: Labels: stale-P2 (was: ) > Kubectl version on beam executors must be upgraded to at least 1.9.3 >

[jira] [Updated] (BEAM-6136) Shade conscrypt within the Dataflow legacy worker jar

[ https://issues.apache.org/jira/browse/BEAM-6136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6136: Labels: (was: stale-assigned) > Shade conscrypt within the Dataflow legacy worker jar >

[jira] [Updated] (BEAM-6599) build_release_candidate.sh should not be interactive

[jira] [Assigned] (BEAM-6871) apache_beam.io.parquetio_test.TestParquet is very flaky

[ https://issues.apache.org/jira/browse/BEAM-6871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6871: --- Assignee: (was: Heejong Lee) > apache_beam.io.parquetio_test.TestParquet is very flaky >

[jira] [Updated] (BEAM-6414) Automatically unassign bugs that aren't getting attention

[ https://issues.apache.org/jira/browse/BEAM-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6414: Labels: (was: stale-assigned) > Automatically unassign bugs that aren't getting attention >

[jira] [Updated] (BEAM-4491) DockerJobBundleFactory's ProvisionInfo is empty.

[ https://issues.apache.org/jira/browse/BEAM-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4491: Labels: (was: stale-assigned) > DockerJobBundleFactory's ProvisionInfo is empty. >

[jira] [Updated] (BEAM-6972) LTS backport: CassandraIO is broken because of use of bad relocation of guava

[ https://issues.apache.org/jira/browse/BEAM-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6972: Labels: (was: stale-assigned) > LTS backport: CassandraIO is broken because of use of bad

[jira] [Assigned] (BEAM-5517) Update Python BigQuery source to use fastavro module to read exported data

[ https://issues.apache.org/jira/browse/BEAM-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5517: --- Assignee: (was: Chamikara Madhusanka Jayalath) > Update Python BigQuery source to use

[jira] [Assigned] (BEAM-5819) Vendor dependencies that are currently shaded

[ https://issues.apache.org/jira/browse/BEAM-5819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5819: --- Assignee: (was: Kenneth Knowles) > Vendor dependencies that are currently shaded >

[jira] [Updated] (BEAM-6499) Support HDFS for artifact staging with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6499: Labels: portability (was: portability stale-assigned) > Support HDFS for artifact staging with

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

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

[jira] [Assigned] (BEAM-5775) Make the spark runner not serialize data unless spark is spilling to disk

[ https://issues.apache.org/jira/browse/BEAM-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5775: --- Assignee: (was: Mike Kaplinskiy) > Make the spark runner not serialize data unless spark

[jira] [Updated] (BEAM-4650) Add retry policy to Python BQ streaming sink

[ https://issues.apache.org/jira/browse/BEAM-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4650: Labels: (was: stale-assigned) > Add retry policy to Python BQ streaming sink >

[jira] [Updated] (BEAM-6168) Allow modification of JSON value before writing to ElasticSearch

[ https://issues.apache.org/jira/browse/BEAM-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6168: Labels: (was: stale-assigned) > Allow modification of JSON value before writing to ElasticSearch

[jira] [Updated] (BEAM-4767) Java should update dataflow.container_version automatically for each release

[ https://issues.apache.org/jira/browse/BEAM-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4767: Labels: (was: stale-assigned) > Java should update dataflow.container_version automatically for

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

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

[jira] [Commented] (BEAM-6610) [beam_PostCommit_Python_Verify, beam_PostCommit_Java]ResourceExhausted: 429 Your project has exceeded a limit: (type="topics-per-project", current=10000, maximum=10000)

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

[jira] [Assigned] (BEAM-5998) beam-runners-flink_2.11-job-server:validatesPortableRunner failing due to "insufficient memory"

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

[jira] [Assigned] (BEAM-6286) Add SamzaRunner profile to mvn archetype

[ https://issues.apache.org/jira/browse/BEAM-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-6286: --- Assignee: (was: Xinyu Liu) > Add SamzaRunner profile to mvn archetype >

[jira] [Assigned] (BEAM-4778) Less wasteful ArtifactStagingService

[ https://issues.apache.org/jira/browse/BEAM-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-4778: --- Assignee: (was: Ryan Williams) > Less wasteful ArtifactStagingService >

[jira] [Updated] (BEAM-4416) Change google-cloud-platform IOITs to write then read style Performance Tests

[ https://issues.apache.org/jira/browse/BEAM-4416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4416: Labels: stale-P2 (was: ) > Change google-cloud-platform IOITs to write then read style Performance

[jira] [Updated] (BEAM-6511) AbstractGlobalCombineFn hierarchy is inconsistent

[ https://issues.apache.org/jira/browse/BEAM-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6511: Labels: (was: stale-assigned) > AbstractGlobalCombineFn hierarchy is inconsistent >

[jira] [Updated] (BEAM-4460) Investigate other encoding mechanism for SchemaCoder

[ https://issues.apache.org/jira/browse/BEAM-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4460: Labels: (was: stale-assigned) > Investigate other encoding mechanism for SchemaCoder >

[jira] [Updated] (BEAM-4466) Add Go TF-IDF example

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

[jira] [Commented] (BEAM-4715) Have Beam tests running and passing on Python 3

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

[jira] [Assigned] (BEAM-5328) Java starter archetype does not contain dependency versions

[ https://issues.apache.org/jira/browse/BEAM-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-5328: --- Assignee: (was: Mikhail Ivanov) > Java starter archetype does not contain dependency

[jira] [Commented] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub

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

[jira] [Updated] (BEAM-6767) SamzaRunner: Add more parameters to SamzaPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6767: Labels: (was: stale-assigned) > SamzaRunner: Add more parameters to SamzaPipelineOptions >

[jira] [Updated] (BEAM-9741) Split timers to multiple workers in ParallelBundleManager

[ https://issues.apache.org/jira/browse/BEAM-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9741: Labels: stale-P2 (was: ) > Split timers to multiple workers in ParallelBundleManager >

[jira] [Commented] (BEAM-5468) Allow runner to set worker log level in Python SDK harness.

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

[jira] [Commented] (BEAM-6192) Release related scripts should be more resilient to failures

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

<    1   2   3   4   5   6   7   8   9   10   >