[jira] [Updated] (BEAM-81) Move --update PipelineOption to DataflowPipelineOptions from DataflowPipelineDebugOptions

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-81?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-81: Summary: Move --update PipelineOption to DataflowPipelineOptions from DataflowPipelineDebugOptions (wa

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-78?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-78: - > Rename Dataflow to Beam > > > Key: BEAM-78 >

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-77: Labels: backward-incompatible (was: ) > Reorganize Directory structure > -

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-77. --- Resolution: Fixed > Reorganize Directory structure > -- > > K

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-77: - > Reorganize Directory structure > -- > > Key: BEAM-77 >

[jira] [Closed] (BEAM-63) DatastoreIO.Read: dynamic work rebalancing

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-63?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-63. --- Resolution: Fixed Assignee: Vikas Kedigehalli Fix Version/s: 0.3.0-incubating > Datastore

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-78?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-78. --- Resolution: Fixed > Rename Dataflow to Beam > > > Key: BEAM-78

[jira] [Closed] (BEAM-61) DatastoreIO: unbounded sink

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-61?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-61. --- Resolution: Fixed Assignee: Vikas Kedigehalli Fix Version/s: 0.3.0-incubating > Datastore

[jira] [Updated] (BEAM-57) FileBasedSink should write intermediate output to a different folder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-57?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-57: Assignee: Eugene Kirpichov > FileBasedSink should write intermediate output to a different folder > ---

[jira] [Updated] (BEAM-414) Removed IntraBundleParallelization

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-414: - Summary: Removed IntraBundleParallelization (was: IntraBundleParallelization needs to be removed)

[jira] [Closed] (BEAM-49) BigQueryIO: support BYTES

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-49?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-49. --- Resolution: Fixed Assignee: Pei He Fix Version/s: 0.3.0-incubating > BigQueryIO: support

[jira] [Closed] (BEAM-50) BigQueryIO.Write: reimplement in Java

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-50?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-50. --- > BigQueryIO.Write: reimplement in Java > - > > Key: BEAM

[jira] [Updated] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-32?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-32: Assignee: (was: Mark Shields) > Consider not emitting empty ON_TIME pane unless requested > ---

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-78?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-78: Labels: backward-incompatible (was: ) > Rename Dataflow to Beam > > >

[jira] [Updated] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-32?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-32: Labels: Triggers Windowing backward-incompatible (was: Triggers Windowing) > Consider not emitting emp

[jira] [Closed] (BEAM-81) Move --update PipelineOption to DataflowPipelineOptions from DataflowPipelineDebugOptions

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-81?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-81. --- Resolution: Fixed > Move --update PipelineOption to DataflowPipelineOptions from > DataflowPipelineDebug

[jira] [Updated] (BEAM-73) IO design pattern: Decouple Parsers and Coders

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-73?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-73: Labels: backward-incompatible (was: ) > IO design pattern: Decouple Parsers and Coders > -

[jira] [Closed] (BEAM-328) Provide a fallback SerializableCoder for `T extends Serializable` by default

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-328. Resolution: Fixed Fix Version/s: 0.2.0-incubating > Provide a fallback SerializableCoder for `T

[jira] [Updated] (BEAM-40) Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate)

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-40?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-40: Labels: Java8 backward-incompatible (was: Java8) > Replace rawtype lambda-incompatible uses of Seriali

[jira] [Updated] (BEAM-38) Reuse DoFns across multiple bundles rather than deserializing per-bundle

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-38?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-38: Summary: Reuse DoFns across multiple bundles rather than deserializing per-bundle (was: Avoid repeated

[jira] [Updated] (BEAM-38) Avoid repeated DoFn deserialization

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-38?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-38: Labels: backward-incompatible (was: ) > Avoid repeated DoFn deserialization >

[jira] [Updated] (BEAM-44) Return the input coder in NullableCoder.of() if it is a NullableCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-44?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-44: Labels: backward-incompatible (was: ) > Return the input coder in NullableCoder.of() if it is a Nullab

[jira] [Updated] (BEAM-34) Change default output timestamp for combined values to end of window

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-34?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-34: Labels: Windowing backward-incompatible (was: Windowing) > Change default output timestamp for combine

[jira] [Commented] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592648#comment-15592648 ] Daniel Halperin commented on BEAM-787: -- Link: https://builds.apache.org/job/beam_PostC

[jira] [Created] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking

2016-10-20 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-787: Summary: org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking Key: BEAM-787 URL: https://issues.apache.org/jira/browse/BEAM-787 Project: B

[jira] [Updated] (BEAM-307) Upgrade/Test to Kafka 0.10

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-307: - Labels: backward-incompatible (was: ) > Upgrade/Test to Kafka 0.10 > -- > >

[jira] [Reopened] (BEAM-81) --update PipelineOption is in the wrong interface

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-81?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-81: - > --update PipelineOption is in the wrong interface > - >

[jira] [Closed] (BEAM-44) Return the input coder in NullableCoder.of() if it is a NullableCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-44?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-44. --- > Return the input coder in NullableCoder.of() if it is a NullableCoder > ---

[jira] [Reopened] (BEAM-38) Avoid repeated DoFn deserialization

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-38?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-38: - > Avoid repeated DoFn deserialization > --- > > Key: BEAM

[jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-37?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-37: Labels: backward-incompatible (was: ) > Run DoFnWithContext without conversion to vanilla DoFn > -

[jira] [Updated] (BEAM-38) Reuse DoFns across multiple bundles rather than deserializing per-bundle

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-38?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-38: Issue Type: Improvement (was: New Feature) > Reuse DoFns across multiple bundles rather than deseriali

[jira] [Updated] (BEAM-81) --update PipelineOption is in the wrong interface

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-81?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-81: Labels: backward-incompatible (was: ) > --update PipelineOption is in the wrong interface > --

[jira] [Closed] (BEAM-38) Reuse DoFns across multiple bundles rather than deserializing per-bundle

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-38?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-38. --- Resolution: Fixed > Reuse DoFns across multiple bundles rather than deserializing per-bundle > --

[jira] [Closed] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-37?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-37. --- Resolution: Duplicate Assignee: Kenneth Knowles (was: Ben Chambers) Fix Version/s: Not ap

[jira] [Updated] (BEAM-438) Rename one of PTransform.apply and PInput.apply

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-438: - Labels: backward-incompatible (was: ) > Rename one of PTransform.apply and PInput.apply > -

[jira] [Updated] (BEAM-370) Remove the .named() methods from PTransforms and sub-classes

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-370: - Issue Type: Improvement (was: Bug) > Remove the .named() methods from PTransforms and sub-classes >

[jira] [Commented] (BEAM-769) Spark translation tests failing with NullPointerException

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592641#comment-15592641 ] Daniel Halperin commented on BEAM-769: -- Looks like it has not been resolved yet. There

[jira] [Updated] (BEAM-462) Replace MonitoringUtil.PrintHandler with a handler that utilizes a Java logger

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-462: - Labels: backward-incompatible (was: ) > Replace MonitoringUtil.PrintHandler with a handler that uti

[jira] [Updated] (BEAM-447) Stop referring to types with Bound/Unbound

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-447: - Labels: backward-incompatible (was: ) > Stop referring to types with Bound/Unbound > --

[jira] [Closed] (BEAM-396) Make Coder.NonDeterministicException inherit from Exception

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-396. Resolution: Fixed > Make Coder.NonDeterministicException inherit from Exception >

[jira] [Closed] (BEAM-215) Implement Create as a BoundedSource

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-215. Resolution: Fixed > Implement Create as a BoundedSource > --- > >

[jira] [Updated] (BEAM-465) Convert OutgoingMessageCoder to an AtomicCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-465: - Summary: Convert OutgoingMessageCoder to an AtomicCoder (was: OutgoingMessageCoder should be an Ato

[jira] [Updated] (BEAM-465) OutgoingMessageCoder should be an AtomicCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-465: - Issue Type: Improvement (was: Bug) > OutgoingMessageCoder should be an AtomicCoder > --

[jira] [Closed] (BEAM-457) Upgrade Avro to version 1.8.1

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-457. > Upgrade Avro to version 1.8.1 > - > > Key: BEAM-457 >

[jira] [Closed] (BEAM-465) OutgoingMessageCoder should be an AtomicCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-465. > OutgoingMessageCoder should be an AtomicCoder > - > >

[jira] [Reopened] (BEAM-465) OutgoingMessageCoder should be an AtomicCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-465: -- > OutgoingMessageCoder should be an AtomicCoder > - > >

[jira] [Closed] (BEAM-462) Replace MonitoringUtil.PrintHandler with a handler that utilizes a Java logger

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-462. > Replace MonitoringUtil.PrintHandler with a handler that utilizes a Java logger > ---

[jira] [Closed] (BEAM-465) Convert OutgoingMessageCoder to an AtomicCoder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-465. Resolution: Fixed > Convert OutgoingMessageCoder to an AtomicCoder > -

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-243: - Issue Type: Improvement (was: Task) > Remove DirectPipelineRunner and keep only the InProcessPipeli

[jira] [Closed] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-354. > Modify DatastoreIO to use Datastore v1beta3 API > --- > >

[jira] [Closed] (BEAM-317) Implement PAssert without using Side Inputs

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-317. > Implement PAssert without using Side Inputs > --- > >

[jira] [Closed] (BEAM-256) Add lifecycle event verifiers for Beam pipelines.

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-256. > Add lifecycle event verifiers for Beam pipelines. > - >

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-243. > Remove DirectPipelineRunner and keep only the InProcessPipelineRunner >

[jira] [Closed] (BEAM-285) Make MinLongFn and MaxLongFn mimic SumLongFn and use BinaryCombineLongFn

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-285. > Make MinLongFn and MaxLongFn mimic SumLongFn and use BinaryCombineLongFn > -

[jira] [Updated] (BEAM-34) Change default output timestamp for combined values to end of window

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-34?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-34: Issue Type: Improvement (was: New Feature) > Change default output timestamp for combined values to en

[jira] [Closed] (BEAM-34) Change default output timestamp for combined values to end of window

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-34?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-34. --- > Change default output timestamp for combined values to end of window >

[jira] [Updated] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-217: - Labels: backward-incompatible (was: ) > BoundedSource.splitAtFraction should be splitAfterFraction

[jira] [Closed] (BEAM-786) Make BoundedReadFromUnboundedSource available as a public utility

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-786. Resolution: Fixed Fix Version/s: 0.3.0-incubating > Make BoundedReadFromUnboundedSource availab

[jira] [Closed] (BEAM-468) NullableCoder should not ask valueCoder isRegisterByteSizeObserverCheap when value is null

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-468. > NullableCoder should not ask valueCoder isRegisterByteSizeObserverCheap when > value is null >

[jira] [Closed] (BEAM-271) Option to configure remote Dataflow windmill service endpoint

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-271. > Option to configure remote Dataflow windmill service endpoint >

[jira] [Closed] (BEAM-267) Enable Chekstyle check in Spark runner

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-267. > Enable Chekstyle check in Spark runner > -- > > Key:

[jira] [Closed] (BEAM-392) Update flink runner to use flink version 1.0.3

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-392. > Update flink runner to use flink version 1.0.3 > -- > >

[jira] [Closed] (BEAM-117) Implement the API for Static Display Metadata

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-117. > Implement the API for Static Display Metadata > - > >

[jira] [Closed] (BEAM-376) Correct Python pip install target

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-376. > Correct Python pip install target > - > > Key: BEAM-376

[jira] [Closed] (BEAM-289) Examples Use TypeDescriptors

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-289. > Examples Use TypeDescriptors > > > Key: BEAM-289 >

[jira] [Closed] (BEAM-104) Capability matrix for Beam website

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-104. > Capability matrix for Beam website > -- > > Key: BEAM-10

[jira] [Closed] (BEAM-20) Create build jobs on Jenkins

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-20?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-20. --- > Create build jobs on Jenkins > > > Key: BEAM-20 >

[jira] [Closed] (BEAM-131) Write to jdbc/database

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-131. > Write to jdbc/database > --- > > Key: BEAM-131 > UR

[jira] [Closed] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-196. > Pipeline options must be available Context in DoFn.startBundle > ---

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-314. > Support zip compression in TextIO > - > > Key: BEAM-314

[jira] [Closed] (BEAM-220) KafkaIO test is flaky

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-220. > KafkaIO test is flaky > - > > Key: BEAM-220 > URL: h

[jira] [Closed] (BEAM-336) examples-java README is not up-to-date

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-336. > examples-java README is not up-to-date > -- > > Key:

[jira] [Closed] (BEAM-136) PipelineOptionsFactory should detect all runners

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-136. > PipelineOptionsFactory should detect all runners > > >

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-22. --- > DirectPipelineRunner: support for unbounded collections > -

[jira] [Closed] (BEAM-434) Limit the number of output files a beam-examples execution writes

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-434. > Limit the number of output files a beam-examples execution writes >

[jira] [Closed] (BEAM-321) Hash encoded keys in Flink batch mode

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-321. > Hash encoded keys in Flink batch mode > - > > Key: B

[jira] [Closed] (BEAM-390) Update spark runner to use spark version 1.6.2

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-390. > Update spark runner to use spark version 1.6.2 > -- > >

[jira] [Closed] (BEAM-295) Flink Create Functions call Collector.close()

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-295. > Flink Create Functions call Collector.close() > - > >

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-345. > When WindowFn not specified in Window.into(...), NullPointerException >

[jira] [Closed] (BEAM-235) Remove streaming flag

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-235. > Remove streaming flag > - > > Key: BEAM-235 > URL: h

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-323. > The InProcessPipelineRunner uses user objects for State and Timer lookups >

[jira] [Closed] (BEAM-186) The streaming WindowedWordCount example is broken on Dataflow

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-186. > The streaming WindowedWordCount example is broken on Dataflow >

[jira] [Closed] (BEAM-52) KafkaIO - unbounded source & sink

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-52. --- > KafkaIO - unbounded source & sink > - > > Key: BEAM-52 >

[jira] [Closed] (BEAM-282) RunnableOnService tests broken by BigQuery test

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-282. > RunnableOnService tests broken by BigQuery test > --- > >

[jira] [Closed] (BEAM-98) Travis coverage broken due to too much logging

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-98?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-98. --- > Travis coverage broken due to too much logging > -- > >

[jira] [Closed] (BEAM-95) Compress DoFn's / SerializableCoder / ... when serializing objects

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-95?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-95. --- > Compress DoFn's / SerializableCoder / ... when serializing objects > --

[jira] [Closed] (BEAM-379) DisplayDataEvaluator does not support source transforms of the form PTransform

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-379. > DisplayDataEvaluator does not support source transforms of the form > PTransform >

[jira] [Closed] (BEAM-151) Create Dataflow Runner Package

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-151. > Create Dataflow Runner Package > -- > > Key: BEAM-151 >

[jira] [Closed] (BEAM-103) Make UnboundedSourceWrapper parallel

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-103. > Make UnboundedSourceWrapper parallel > > > Key: BEA

[jira] [Closed] (BEAM-167) TextIO can't read concatenated gzip files

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-167. > TextIO can't read concatenated gzip files > - > >

[jira] [Closed] (BEAM-269) Create BigDecimal Coder

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-269. > Create BigDecimal Coder > --- > > Key: BEAM-269 > UR

[jira] [Closed] (BEAM-484) Datastore Source should support Dynamic Splitting

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-484. > Datastore Source should support Dynamic Splitting > - >

[jira] [Closed] (BEAM-207) Flink test flake in ReadSourceStreamingITCase

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-207. > Flink test flake in ReadSourceStreamingITCase > - > >

[jira] [Closed] (BEAM-1) Import code on git

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-1. -- > Import code on git > -- > > Key: BEAM-1 > URL: https://issues.

[jira] [Closed] (BEAM-53) PubSubIO: reimplement in Java

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-53?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-53. --- > PubSubIO: reimplement in Java > - > > Key: BEAM-53 >

[jira] [Closed] (BEAM-254) Add maven-rat-plugin execution

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-254. > Add maven-rat-plugin execution > -- > > Key: BEAM-254 >

[jira] [Closed] (BEAM-316) Support file scheme in TextIO

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-316. > Support file scheme in TextIO > - > > Key: BEAM-316 >

[jira] [Closed] (BEAM-132) Release process for Beam artifacts to Maven

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-132. > Release process for Beam artifacts to Maven > --- > >

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

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-372. > CoderProperties: Test that the coder doesn't consume more bytes than it > produces > --

[jira] [Closed] (BEAM-225) Create Class for Common TypeDescriptors

2016-10-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-225. > Create Class for Common TypeDescriptors > --- > > Ke

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