[jira] [Updated] (BEAM-318) AvroCoder may be vulnerable to AVRO-607

[ https://issues.apache.org/jira/browse/BEAM-318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-318: - Summary: AvroCoder may be vulnerable to AVRO-607 (was: AvroCoder is vulnerable to AVRO-607) >

[jira] [Updated] (BEAM-318) AvroCoder may be vulnerable to AVRO-607

[ https://issues.apache.org/jira/browse/BEAM-318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-318: - Description: See AVRO-607 The hypothesis is that even though AvroCoder is threadsafe according to

[jira] [Updated] (BEAM-318) AvroCoder may be vulnerable to AVRO-607

[ https://issues.apache.org/jira/browse/BEAM-318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-318: - Description: See AVRO-607 The hypothesis is that even though AvroCoder is threadsafe according to

[jira] [Assigned] (BEAM-292) TextIO.Write.to Empty Files

[ https://issues.apache.org/jira/browse/BEAM-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-292: Assignee: Daniel Halperin > TextIO.Write.to Empty Files > --- > >

[jira] [Resolved] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-52. - Resolution: Fixed > KafkaIO - bounded/unbounded, source/sink >

[jira] [Created] (BEAM-335) beam_PostCommit_RunnableOnService_GoogleCloudDataflow broken since #514

Daniel Halperin created BEAM-335: Summary: beam_PostCommit_RunnableOnService_GoogleCloudDataflow broken since #514 Key: BEAM-335 URL: https://issues.apache.org/jira/browse/BEAM-335 Project: Beam

[jira] [Resolved] (BEAM-334) Dataflow pipeline runner should bump major version number

[ https://issues.apache.org/jira/browse/BEAM-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-334. -- Resolution: Fixed > Dataflow pipeline runner should bump major version number >

[jira] [Created] (BEAM-342) Change Filter#greaterThan, etc. to actually use Filter

Daniel Halperin created BEAM-342: Summary: Change Filter#greaterThan, etc. to actually use Filter Key: BEAM-342 URL: https://issues.apache.org/jira/browse/BEAM-342 Project: Beam Issue Type:

[jira] [Resolved] (BEAM-48) BigQueryIO.Read reimplemented as BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-48?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-48. - Resolution: Fixed > BigQueryIO.Read reimplemented as BoundedSource >

[jira] [Resolved] (BEAM-292) TextIO.Write.to Empty Files

[ https://issues.apache.org/jira/browse/BEAM-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-292. -- Resolution: Fixed > TextIO.Write.to Empty Files > --- > >

[jira] [Created] (BEAM-318) AvroCoder is vulnerable to AVRO-607

Daniel Halperin created BEAM-318: Summary: AvroCoder is vulnerable to AVRO-607 Key: BEAM-318 URL: https://issues.apache.org/jira/browse/BEAM-318 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-33) Make DataflowAssert more window-aware

[ https://issues.apache.org/jira/browse/BEAM-33?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-33. - Resolution: Duplicate > Make DataflowAssert more window-aware >

[jira] [Closed] (BEAM-33) Make DataflowAssert more window-aware

[ https://issues.apache.org/jira/browse/BEAM-33?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-33. --- > Make DataflowAssert more window-aware > - > > Key:

[jira] [Closed] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

[ https://issues.apache.org/jira/browse/BEAM-367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-367. Resolution: Fixed > GetFractionConsumed() inaccurate for non-uniform records >

[jira] [Closed] (BEAM-343) DisplayData error in AfterWatermark

[ https://issues.apache.org/jira/browse/BEAM-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-343. > DisplayData error in AfterWatermark > --- > > Key:

[jira] [Resolved] (BEAM-288) Improve javadoc for UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-288. -- Resolution: Fixed > Improve javadoc for UnboundedSource > --- > >

[jira] [Closed] (BEAM-288) Improve javadoc for UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-288. > Improve javadoc for UnboundedSource > --- > > Key:

[jira] [Closed] (BEAM-314) Support zip compression in TextIO

[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-314. Resolution: Fixed > Support zip compression in TextIO > - > >

[jira] [Resolved] (BEAM-358) JAXB Coder is not thread safe

[ https://issues.apache.org/jira/browse/BEAM-358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-358. -- Resolution: Fixed > JAXB Coder is not thread safe > - > >

[jira] [Resolved] (BEAM-347) Progress updates inaccurate for non-uniform keys in Bigtable

[ https://issues.apache.org/jira/browse/BEAM-347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-347. -- Resolution: Fixed > Progress updates inaccurate for non-uniform keys in Bigtable >

[jira] [Created] (BEAM-350) beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky

Daniel Halperin created BEAM-350: Summary: beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky Key: BEAM-350 URL: https://issues.apache.org/jira/browse/BEAM-350 Project: Beam Issue

[jira] [Created] (BEAM-381) OffsetBasedReader should construct sources before updating the range tracker

Daniel Halperin created BEAM-381: Summary: OffsetBasedReader should construct sources before updating the range tracker Key: BEAM-381 URL: https://issues.apache.org/jira/browse/BEAM-381 Project: Beam

[jira] [Created] (BEAM-382) Audit BoundedReaders for BEAM-381

Daniel Halperin created BEAM-382: Summary: Audit BoundedReaders for BEAM-381 Key: BEAM-382 URL: https://issues.apache.org/jira/browse/BEAM-382 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-288) Improve javadoc for UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-288: - Fix Version/s: 0.2.0-incubating > Improve javadoc for UnboundedSource >

[jira] [Updated] (BEAM-248) Register DisplayData from anonymous implementation PTransforms

[ https://issues.apache.org/jira/browse/BEAM-248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-248: - Fix Version/s: 0.1.0-incubating > Register DisplayData from anonymous implementation PTransforms >

[jira] [Updated] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-52: Fix Version/s: 0.1.0-incubating > KafkaIO - bounded/unbounded, source/sink >

[jira] [Updated] (BEAM-288) Improve javadoc for UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-288: - Issue Type: Improvement (was: Bug) > Improve javadoc for UnboundedSource >

[jira] [Updated] (BEAM-12) Apply GroupByKey transforms on PCollection of normal type other than KV

[ https://issues.apache.org/jira/browse/BEAM-12?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-12: Fix Version/s: Not applicable > Apply GroupByKey transforms on PCollection of normal type other than

[jira] [Updated] (BEAM-36) TimestampedValueInMultipleWindows should use a more compact set representation

[ https://issues.apache.org/jira/browse/BEAM-36?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-36: Fix Version/s: Not applicable > TimestampedValueInMultipleWindows should use a more compact set

[jira] [Updated] (BEAM-99) Travis: Execute Maven "verify" phase

[ https://issues.apache.org/jira/browse/BEAM-99?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-99: Fix Version/s: Not applicable > Travis: Execute Maven "verify" phase >

[jira] [Resolved] (BEAM-128) The transform BigQueryIO.Read is currently not supported.

[ https://issues.apache.org/jira/browse/BEAM-128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-128. -- Resolution: Fixed Now that BEAM-48 is fixed and Flink supports Read transform, should be good! >

[jira] [Updated] (BEAM-358) JAXB Coder is not thread safe

[ https://issues.apache.org/jira/browse/BEAM-358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-358: - Fix Version/s: 0.2.0-incubating > JAXB Coder is not thread safe > - > >

[jira] [Updated] (BEAM-353) Correct the licenses

[ https://issues.apache.org/jira/browse/BEAM-353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-353: - Fix Version/s: Not applicable > Correct the licenses > > >

[jira] [Updated] (BEAM-373) CoGbkResult will crash after 10,000 elements on any runner that does not provide a Reiterator

[ https://issues.apache.org/jira/browse/BEAM-373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-373: - Fix Version/s: Not applicable > CoGbkResult will crash after 10,000 elements on any runner that

[jira] [Updated] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

[ https://issues.apache.org/jira/browse/BEAM-367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-367: - Fix Version/s: 0.2.0-incubating > GetFractionConsumed() inaccurate for non-uniform records >

[jira] [Updated] (BEAM-348) Clean temp_dir usage in _stage_extra_packages

[ https://issues.apache.org/jira/browse/BEAM-348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-348: - Fix Version/s: Not applicable > Clean temp_dir usage in _stage_extra_packages >

[jira] [Updated] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-304: - Fix Version/s: 0.1.0-incubating > Build break: maven is picking up Kafka snapshots >

[jira] [Updated] (BEAM-305) In Spark runner tests - When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

[ https://issues.apache.org/jira/browse/BEAM-305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-305: - Fix Version/s: 0.1.0-incubating > In Spark runner tests - When using Create.of use it's #withCoder

[jira] [Updated] (BEAM-204) truncateStackTrace fails with empty stack trace

[ https://issues.apache.org/jira/browse/BEAM-204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-204: - Fix Version/s: 0.1.0-incubating > truncateStackTrace fails with empty stack trace >

[jira] [Updated] (BEAM-173) Publish DisplayData for PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-173: - Fix Version/s: 0.1.0-incubating > Publish DisplayData for PipelineOptions >

[jira] [Updated] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package

[ https://issues.apache.org/jira/browse/BEAM-247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-247: - Fix Version/s: Not applicable > CombineFn's only definable/usable inside sdk.transforms package >

[jira] [Updated] (BEAM-189) The Spark runner uses valueInEmptyWindow which causes values to be dropped

[ https://issues.apache.org/jira/browse/BEAM-189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-189: - Fix Version/s: 0.1.0-incubating > The Spark runner uses valueInEmptyWindow which causes values to

[jira] [Reopened] (BEAM-159) Support fixed number of shards in sinks

[ https://issues.apache.org/jira/browse/BEAM-159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-159: -- Assignee: Daniel Halperin > Support fixed number of shards in sinks >

[jira] [Updated] (BEAM-227) Log sdk version in worker-startup logs

[ https://issues.apache.org/jira/browse/BEAM-227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-227: - Fix Version/s: Not applicable > Log sdk version in worker-startup logs >

[jira] [Updated] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-185: - Fix Version/s: Not applicable > XmlSink output file pattern missing "." in extension >

[jira] [Updated] (BEAM-139) Print mode (batch/streaming) during translation

[ https://issues.apache.org/jira/browse/BEAM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-139: - Fix Version/s: Not applicable > Print mode (batch/streaming) during translation >

[jira] [Updated] (BEAM-230) Remove WindowedValue#valueInEmptyWindows

[ https://issues.apache.org/jira/browse/BEAM-230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-230: - Fix Version/s: Not applicable > Remove WindowedValue#valueInEmptyWindows >

[jira] [Updated] (BEAM-291) PDone type translation fails

[ https://issues.apache.org/jira/browse/BEAM-291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-291: - Fix Version/s: Not applicable > PDone type translation fails > > >

[jira] [Updated] (BEAM-236) Implement Windowing in batch execution

[ https://issues.apache.org/jira/browse/BEAM-236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-236: - Fix Version/s: Not applicable > Implement Windowing in batch execution >

[jira] [Updated] (BEAM-183) Update package name for DisplayData types

[ https://issues.apache.org/jira/browse/BEAM-183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-183: - Fix Version/s: Not applicable > Update package name for DisplayData types >

[jira] [Updated] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-216: - Fix Version/s: Not applicable > Create Storm Runner > > >

[jira] [Updated] (BEAM-211) When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

[ https://issues.apache.org/jira/browse/BEAM-211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-211: - Fix Version/s: 0.1.0-incubating > When using Create.of use it's #withCoder method instead of the

[jira] [Updated] (BEAM-249) Combine.GroupedValues re-wraps combineFn from Combine.PerKey and loses identity for DisplayData

[ https://issues.apache.org/jira/browse/BEAM-249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-249: - Fix Version/s: 0.1.0-incubating > Combine.GroupedValues re-wraps combineFn from Combine.PerKey and

[jira] [Updated] (BEAM-251) Exclude PipelineOptions with @JsonIgnore from display data

[ https://issues.apache.org/jira/browse/BEAM-251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-251: - Fix Version/s: 0.1.0-incubating > Exclude PipelineOptions with @JsonIgnore from display data >

[jira] [Updated] (BEAM-77) Reorganize Directory structure

[ https://issues.apache.org/jira/browse/BEAM-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-77: Fix Version/s: 0.1.0-incubating > Reorganize Directory structure > -- > >

[jira] [Updated] (BEAM-250) Exclude TextSource.minBundleSize default value from display data.

[ https://issues.apache.org/jira/browse/BEAM-250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-250: - Fix Version/s: 0.1.0-incubating > Exclude TextSource.minBundleSize default value from display data.

[jira] [Updated] (BEAM-292) TextIO.Write.to Empty Files

[ https://issues.apache.org/jira/browse/BEAM-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-292: - Issue Type: Improvement (was: Bug) > TextIO.Write.to Empty Files > --- > >

[jira] [Updated] (BEAM-133) Test flakiness in the Spark runner

[ https://issues.apache.org/jira/browse/BEAM-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-133: - Component/s: (was: project-management) testing > Test flakiness in the Spark

[jira] [Updated] (BEAM-143) Add test for UnboundedSourceWrapper

[ https://issues.apache.org/jira/browse/BEAM-143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-143: - Fix Version/s: Not applicable > Add test for UnboundedSourceWrapper >

[jira] [Updated] (BEAM-133) Test flakiness in the Spark runner

[ https://issues.apache.org/jira/browse/BEAM-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-133: - Fix Version/s: Not applicable > Test flakiness in the Spark runner >

[jira] [Updated] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups

[ https://issues.apache.org/jira/browse/BEAM-323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-323: - Fix Version/s: 0.2.0-incubating > The InProcessPipelineRunner uses user objects for State and Timer

[jira] [Updated] (BEAM-327) Dataflow runner should have configuration for System.out/err handling

[ https://issues.apache.org/jira/browse/BEAM-327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-327: - Fix Version/s: 0.2.0-incubating > Dataflow runner should have configuration for System.out/err

[jira] [Updated] (BEAM-374) Enable dependency-plugin and failOnWarning at global level

[ https://issues.apache.org/jira/browse/BEAM-374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-374: - Priority: Minor (was: Major) > Enable dependency-plugin and failOnWarning at global level >

[jira] [Updated] (BEAM-366) Support Display Data on Composite Transforms

[ https://issues.apache.org/jira/browse/BEAM-366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-366: - Issue Type: Improvement (was: Bug) > Support Display Data on Composite Transforms >

[jira] [Updated] (BEAM-206) FileBasedSink does serial renames

[ https://issues.apache.org/jira/browse/BEAM-206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-206: - Priority: Major (was: Critical) > FileBasedSink does serial renames >

[jira] [Updated] (BEAM-280) TestPipeline should be constructible without a runner

[ https://issues.apache.org/jira/browse/BEAM-280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-280: - Issue Type: Improvement (was: Bug) > TestPipeline should be constructible without a runner >

[jira] [Updated] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

[ https://issues.apache.org/jira/browse/BEAM-234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-234: - Fix Version/s: 0.2.0-incubating > Remove the word Pipeline from the name of all PipelineRunner

[jira] [Updated] (BEAM-22) DirectPipelineRunner: support for unbounded collections

[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-22: Fix Version/s: 0.2.0-incubating > DirectPipelineRunner: support for unbounded collections >

[jira] [Updated] (BEAM-33) Make DataflowAssert more window-aware

[ https://issues.apache.org/jira/browse/BEAM-33?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-33: Fix Version/s: Not applicable > Make DataflowAssert more window-aware >

[jira] [Updated] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

[ https://issues.apache.org/jira/browse/BEAM-234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-234: - Issue Type: Improvement (was: Bug) > Remove the word Pipeline from the name of all PipelineRunner

[jira] [Updated] (BEAM-159) Support fixed number of shards in sinks

[ https://issues.apache.org/jira/browse/BEAM-159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-159: - Fix Version/s: Not applicable > Support fixed number of shards in sinks >

[jira] [Updated] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner

[ https://issues.apache.org/jira/browse/BEAM-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-243: - Fix Version/s: 0.2.0-incubating > Remove DirectPipelineRunner and keep only the

[jira] [Updated] (BEAM-280) TestPipeline should be constructible without a runner

[ https://issues.apache.org/jira/browse/BEAM-280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-280: - Fix Version/s: 0.2.0-incubating > TestPipeline should be constructible without a runner >

[jira] [Updated] (BEAM-240) Add display data link URLs for sources / sinks

[ https://issues.apache.org/jira/browse/BEAM-240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-240: - Fix Version/s: 0.1.0-incubating > Add display data link URLs for sources / sinks >

[jira] [Updated] (BEAM-48) BigQueryIO.Read reimplemented as BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-48?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-48: Fix Version/s: 0.1.0-incubating > BigQueryIO.Read reimplemented as BoundedSource >

[jira] [Updated] (BEAM-272) Flink Runner depends on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-272: - Fix Version/s: 0.1.0-incubating > Flink Runner depends on Dataflow Runner >

[jira] [Updated] (BEAM-199) Improve fluent interface for manipulating DisplayData.Items

[ https://issues.apache.org/jira/browse/BEAM-199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-199: - Fix Version/s: 0.1.0-incubating > Improve fluent interface for manipulating DisplayData.Items >

[jira] [Updated] (BEAM-231) Remove ClassForDisplay infrastructure class.

[ https://issues.apache.org/jira/browse/BEAM-231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-231: - Fix Version/s: 0.1.0-incubating > Remove ClassForDisplay infrastructure class. >

[jira] [Updated] (BEAM-128) The transform BigQueryIO.Read is currently not supported.

[ https://issues.apache.org/jira/browse/BEAM-128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-128: - Fix Version/s: Not applicable > The transform BigQueryIO.Read is currently not supported. >

[jira] [Updated] (BEAM-168) IntervalBoundedExponentialBackOff change broke Beam-on-Dataflow

[ https://issues.apache.org/jira/browse/BEAM-168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-168: - Fix Version/s: 0.1.0-incubating > IntervalBoundedExponentialBackOff change broke Beam-on-Dataflow >

[jira] [Updated] (BEAM-154) Provide Maven BOM

[ https://issues.apache.org/jira/browse/BEAM-154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-154: - Fix Version/s: 0.1.0-incubating > Provide Maven BOM > - > > Key:

[jira] [Updated] (BEAM-78) Rename Dataflow to Beam

[ https://issues.apache.org/jira/browse/BEAM-78?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-78: Fix Version/s: 0.1.0-incubating > Rename Dataflow to Beam > > >

[jira] [Updated] (BEAM-203) Travis Build is Broken

[ https://issues.apache.org/jira/browse/BEAM-203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-203: - Fix Version/s: Not applicable > Travis Build is Broken > -- > >

[jira] [Updated] (BEAM-149) IntelliJ: Java 8 tests configuration

[ https://issues.apache.org/jira/browse/BEAM-149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-149: - Fix Version/s: Not applicable > IntelliJ: Java 8 tests configuration >

[jira] [Updated] (BEAM-208) Flaky test: org.apache.beam.runners.flink.streaming.GroupByNullKeyTest.testJob

[ https://issues.apache.org/jira/browse/BEAM-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-208: - Fix Version/s: Not applicable > Flaky test:

[jira] [Updated] (BEAM-213) Fix README to use refactored package names and use AutoService for Registrar

[ https://issues.apache.org/jira/browse/BEAM-213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-213: - Fix Version/s: Not applicable > Fix README to use refactored package names and use AutoService for

[jira] [Updated] (BEAM-350) beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky

[ https://issues.apache.org/jira/browse/BEAM-350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-350: - Fix Version/s: Not applicable > beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky >

[jira] [Updated] (BEAM-364) Integration Tests for Bigtable Read and Write

[ https://issues.apache.org/jira/browse/BEAM-364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-364: - Assignee: Ian Zhou (was: Daniel Halperin) > Integration Tests for Bigtable Read and Write >

[jira] [Updated] (BEAM-355) Update to Bigtable version 0.3.0

[ https://issues.apache.org/jira/browse/BEAM-355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-355: - Assignee: Ian Zhou (was: Daniel Halperin) > Update to Bigtable version 0.3.0 >

[jira] [Updated] (BEAM-343) DisplayData error in AfterWatermark

[ https://issues.apache.org/jira/browse/BEAM-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-343: - Fix Version/s: 0.2.0-incubating > DisplayData error in AfterWatermark >

[jira] [Updated] (BEAM-341) ReduceFnRunner allows GC time overflow

[ https://issues.apache.org/jira/browse/BEAM-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-341: - Fix Version/s: 0.2.0-incubating > ReduceFnRunner allows GC time overflow >

[jira] [Updated] (BEAM-346) When WindowFn not specified in Window.into(...), NullPointerException

[ https://issues.apache.org/jira/browse/BEAM-346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-346: - Fix Version/s: Not applicable > When WindowFn not specified in Window.into(...),

[jira] [Updated] (BEAM-342) Change Filter#greaterThan, etc. to actually use Filter

[ https://issues.apache.org/jira/browse/BEAM-342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-342: - Fix Version/s: 0.2.0-incubating > Change Filter#greaterThan, etc. to actually use Filter >

[jira] [Updated] (BEAM-180) Add English labels for registered display data

[ https://issues.apache.org/jira/browse/BEAM-180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-180: - Fix Version/s: Not applicable > Add English labels for registered display data >

[jira] [Updated] (BEAM-224) Two assert fails with merging windows and closable triggers

[ https://issues.apache.org/jira/browse/BEAM-224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-224: - Fix Version/s: Not applicable > Two assert fails with merging windows and closable triggers >

[jira] [Updated] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

[ https://issues.apache.org/jira/browse/BEAM-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-205: - Fix Version/s: Not applicable > An 'in process' runner optimized for efficiency rather than

[jira] [Updated] (BEAM-164) Dynamic splitting for unbounded sources

[ https://issues.apache.org/jira/browse/BEAM-164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-164: - Fix Version/s: Not applicable > Dynamic splitting for unbounded sources >

[jira] [Commented] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces

[ https://issues.apache.org/jira/browse/BEAM-372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352464#comment-15352464 ] Daniel Halperin commented on BEAM-372: -- Sounds good to me! > CoderProperties: Test that the coder

[jira] [Assigned] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces

[ https://issues.apache.org/jira/browse/BEAM-372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-372: Assignee: Daniel Halperin > CoderProperties: Test that the coder doesn't consume more bytes

[jira] [Updated] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces

[ https://issues.apache.org/jira/browse/BEAM-372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-372: - Assignee: Chandni Singh (was: Daniel Halperin) > CoderProperties: Test that the coder doesn't

  1   2   3   4   5   6   7   8   9   >