[jira] [Closed] (BEAM-403) Support staging SDK packages from PyPI for remote execution

2016-06-30 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-403. Resolution: Fixed Assignee: Silviu Calinoiu (was: Davor Bonaci) Fix Version/s:

[jira] [Comment Edited] (BEAM-388) Update Beam Incubation Status page on main Apache site

2016-06-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355793#comment-15355793 ] Daniel Halperin edited comment on BEAM-388 at 6/29/16 9:17 PM: --- fyi [~davor]

[jira] [Created] (BEAM-388) Update Beam Incubation Status page on main Apache site

2016-06-29 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-388: Summary: Update Beam Incubation Status page on main Apache site Key: BEAM-388 URL: https://issues.apache.org/jira/browse/BEAM-388 Project: Beam Issue Type:

[jira] [Commented] (BEAM-388) Update Beam Incubation Status page on main Apache site

2016-06-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355793#comment-15355793 ] Daniel Halperin commented on BEAM-388: -- fyi [~davorbonaci] > Update Beam Incubation Status page on

[jira] [Closed] (BEAM-387) Remove internal file and fix gcsio code path

2016-06-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-387. Resolution: Fixed Fix Version/s: 0.2.0-incubating > Remove internal file and fix gcsio code

[jira] [Created] (BEAM-422) AvroSource hits various IOException when using Snappy codec

2016-07-02 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-422: Summary: AvroSource hits various IOException when using Snappy codec Key: BEAM-422 URL: https://issues.apache.org/jira/browse/BEAM-422 Project: Beam Issue

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

2016-07-02 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-354: - Affects Version/s: 0.2.0-incubating > Modify DatastoreIO to use Datastore v1beta3 API >

[jira] [Created] (BEAM-363) CompressedSource splits when it shouldn't

2016-06-20 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-363: Summary: CompressedSource splits when it shouldn't Key: BEAM-363 URL: https://issues.apache.org/jira/browse/BEAM-363 Project: Beam Issue Type: Bug

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

2016-06-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-280. Resolution: Fixed > TestPipeline should be constructible without a runner >

[jira] [Commented] (BEAM-371) Backport HDFS IO enhancements from Scio

2016-07-01 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15359939#comment-15359939 ] Daniel Halperin commented on BEAM-371: -- Thanks for the contribution, Neville! > Backport HDFS IO

[jira] [Closed] (BEAM-371) Backport HDFS IO enhancements from Scio

2016-07-01 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-371. Resolution: Fixed Fix Version/s: 0.2.0-incubating > Backport HDFS IO enhancements from Scio >

[jira] [Created] (BEAM-558) DataflowRunner does not support setup/teardown

2016-08-15 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-558: Summary: DataflowRunner does not support setup/teardown Key: BEAM-558 URL: https://issues.apache.org/jira/browse/BEAM-558 Project: Beam Issue Type: Bug

[jira] [Comment Edited] (BEAM-469) NullableCoder should encode using the context given and not always use the nested context

2016-08-16 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15422979#comment-15422979 ] Daniel Halperin edited comment on BEAM-469 at 8/16/16 4:24 PM: --- I think there

[jira] [Commented] (BEAM-153) Support timeout in runner API

2016-08-15 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15422039#comment-15422039 ] Daniel Halperin commented on BEAM-153: -- Pei, this seems pretty well covered by some of your recent job

[jira] [Closed] (BEAM-459) Add BigInteger to TypeDescriptors

2016-08-15 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-459. Resolution: Fixed Fix Version/s: 0.2.0-incubating > Add BigInteger to TypeDescriptors >

[jira] [Updated] (BEAM-286) Reorganize flink runner directories

2016-08-19 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-286: - Fix Version/s: (was: 0.2.0-incubating) > Reorganize flink runner directories >

[jira] [Updated] (BEAM-463) BoundedHeapCoder should be a StandardCoder and not a CustomCoder

2016-08-19 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-463: - Fix Version/s: (was: 0.2.0-incubating) > BoundedHeapCoder should be a StandardCoder and not a

[jira] [Updated] (BEAM-146) WindowFn.AssignContext leaks implementation details about compressed WindowedValue representation

2016-08-19 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-146: - Issue Type: Improvement (was: Bug) > WindowFn.AssignContext leaks implementation details about

[jira] [Updated] (BEAM-142) BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters

2016-08-19 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-142: - Issue Type: Improvement (was: Bug) > BigQueryIO: don't unnecessarily initialize an ExecutorService

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

2016-08-23 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-206. Resolution: Fixed Fix Version/s: 0.3.0-incubating > FileBasedSink does serial renames >

[jira] [Closed] (BEAM-548) Combine$PerKeyWithHotKeyFanout should propagate Display Data

2016-09-02 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-548. Resolution: Fixed Fix Version/s: 0.3.0-incubating > Combine$PerKeyWithHotKeyFanout should

[jira] [Updated] (BEAM-620) DataflowPipelineJob IllegalArgumentException from time underflow

2016-09-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-620: - Description: {code} Exception in thread "main" java.lang.IllegalArgumentException:

[jira] [Created] (BEAM-620) DataflowPipelineJob IllegalArgumentException from time underflow

2016-09-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-620: Summary: DataflowPipelineJob IllegalArgumentException from time underflow Key: BEAM-620 URL: https://issues.apache.org/jira/browse/BEAM-620 Project: Beam

[jira] [Updated] (BEAM-558) DataflowRunner does not support setup/teardown

2016-08-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-558: - Issue Type: New Feature (was: Bug) > DataflowRunner does not support setup/teardown >

[jira] [Updated] (BEAM-558) DataflowRunner should support setup/teardown

2016-08-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-558: - Summary: DataflowRunner should support setup/teardown (was: DataflowRunner does not support

[jira] [Resolved] (BEAM-558) DataflowRunner does not support setup/teardown

2016-08-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-558. -- Resolution: Fixed Fix Version/s: 0.3.0-incubating > DataflowRunner does not support

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

2016-08-30 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-92: Assignee: Vikas Kedigehalli > Data-dependent sinks > > > Key:

[jira] [Resolved] (BEAM-587) Update KafkaIO to take advantage of Dofn Setup/Teardown

2016-08-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-587. -- Resolution: Fixed Fix Version/s: 0.3.0-incubating > Update KafkaIO to take advantage of

[jira] [Resolved] (BEAM-620) DataflowPipelineJob IllegalArgumentException from time underflow

2016-09-08 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-620. -- Resolution: Fixed Fix Version/s: Not applicable > DataflowPipelineJob

[jira] [Created] (BEAM-630) DataflowRunnableOnService test suite is broken

2016-09-13 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-630: Summary: DataflowRunnableOnService test suite is broken Key: BEAM-630 URL: https://issues.apache.org/jira/browse/BEAM-630 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-626) AvroCoder not deserializing correctly in Kryo

2016-09-12 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15484681#comment-15484681 ] Daniel Halperin commented on BEAM-626: -- Does Kryo not have a fallback to simply use Java serialization?

[jira] [Closed] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-09-13 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-598. Resolution: Fixed Fix Version/s: Not applicable > GearpumpRunner depends on SNAPSHOT jar that

[jira] [Updated] (BEAM-559) DoFnTester should handle Setup / TearDown

2016-09-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-559: - Assignee: Eugene Kirpichov (was: Thomas Groh) > DoFnTester should handle Setup / TearDown >

[jira] [Commented] (BEAM-688) Repeated 'mvn install' fails on beam-sdks-java-maven-archetypes-starter with undeclared dependency error

2016-09-28 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530100#comment-15530100 ] Daniel Halperin commented on BEAM-688: -- Something related to the {{ignoreNonCompile}} setting being

[jira] [Updated] (BEAM-690) Backoff in the DirectRunner Monitor if no work is Available

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-690: - Assignee: (was: Thomas Groh) > Backoff in the DirectRunner Monitor if no work is Available >

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

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-586: - Assignee: (was: Thomas Groh) > CombineFns with no inputs should produce no outputs when used as

[jira] [Updated] (BEAM-632) Dataflow runner does not correctly flatten duplicate inputs

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-632: - Assignee: (was: Thomas Groh) > Dataflow runner does not correctly flatten duplicate inputs >

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

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1550#comment-1550 ] Daniel Halperin commented on BEAM-621: -- I doubt we could get good type information out of such a mode,

[jira] [Resolved] (BEAM-435) DirectRunner GBK -- task per key?

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-435. -- Resolution: Fixed Fix Version/s: 0.2.0-incubating > DirectRunner GBK -- task per key? >

[jira] [Updated] (BEAM-435) DirectRunner GBK -- task per key?

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-435: - Fix Version/s: (was: 0.2.0-incubating) Not applicable > DirectRunner GBK --

[jira] [Updated] (BEAM-632) Dataflow runner does not correctly flatten duplicate inputs

2016-09-29 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-632: - Summary: Dataflow runner does not correctly flatten duplicate inputs (was:

[jira] [Updated] (BEAM-626) AvroCoder not deserializing correctly in Kryo

2016-10-05 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-626: - Assignee: Aviem Zur (was: Davor Bonaci) > AvroCoder not deserializing correctly in Kryo >

[jira] [Updated] (BEAM-730) Remove Reshuffle transform in favor of Redistribute.byKey()

2016-10-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-730: - Assignee: Eugene Kirpichov > Remove Reshuffle transform in favor of Redistribute.byKey() >

[jira] [Commented] (BEAM-730) Remove Reshuffle transform in favor of Redistribute.byKey()

2016-10-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1847#comment-1847 ] Daniel Halperin commented on BEAM-730: -- Counterpoint: Redistribute byKey is closely related, as it

[jira] [Commented] (BEAM-59) IOChannelFactory rethinking/redesign

2016-10-06 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15552303#comment-15552303 ] Daniel Halperin commented on BEAM-59: - I think there are two separable tasks. 1. Completely rethink the

[jira] [Closed] (BEAM-631) upgrade surefire plugin to 2.19.1

2016-09-14 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-631. Resolution: Fixed Fix Version/s: Not applicable > upgrade surefire plugin to 2.19.1 >

[jira] [Created] (BEAM-632) FlattenWithMultipleInputs broke GoogleCloudDataflow_RunnableOnService tests

2016-09-14 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-632: Summary: FlattenWithMultipleInputs broke GoogleCloudDataflow_RunnableOnService tests Key: BEAM-632 URL: https://issues.apache.org/jira/browse/BEAM-632 Project: Beam

[jira] [Created] (BEAM-639) BigtableIO.Read: expose withStartKey/withEndKey

2016-09-19 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-639: Summary: BigtableIO.Read: expose withStartKey/withEndKey Key: BEAM-639 URL: https://issues.apache.org/jira/browse/BEAM-639 Project: Beam Issue Type:

[jira] [Updated] (BEAM-663) AvroSource should update progress within blocks

2016-09-21 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-663: - Component/s: sdk-py > AvroSource should update progress within blocks >

[jira] [Updated] (BEAM-663) AvroSource should update progress within blocks

2016-09-21 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-663: - Issue Type: Improvement (was: Bug) > AvroSource should update progress within blocks >

[jira] [Commented] (BEAM-670) BigQuery TableRow inserter incorrectly handles nextBackOff millis

2016-09-22 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514377#comment-15514377 ] Daniel Halperin commented on BEAM-670: -- In other words, I believe the check is good, but I might be

[jira] [Commented] (BEAM-670) BigQuery TableRow inserter incorrectly handles nextBackOff millis

2016-09-22 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514375#comment-15514375 ] Daniel Halperin commented on BEAM-670: -- The bug is actually at L618. We're calling nextBackoffMillis

[jira] [Updated] (BEAM-639) BigtableIO.Read: support for user specified row range

2016-09-19 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-639: - Summary: BigtableIO.Read: support for user specified row range (was: BigtableIO.Read: expose

[jira] [Closed] (BEAM-639) BigtableIO.Read: support for user specified row range

2016-09-19 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-639. Resolution: Fixed Fix Version/s: 0.3.0-incubating > BigtableIO.Read: support for user

[jira] [Created] (BEAM-587) Update KafkaIO to take advantage of Dofn Setup/Teardown

2016-08-25 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-587: Summary: Update KafkaIO to take advantage of Dofn Setup/Teardown Key: BEAM-587 URL: https://issues.apache.org/jira/browse/BEAM-587 Project: Beam Issue Type:

[jira] [Created] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-598: Summary: GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted Key: BEAM-598 URL: https://issues.apache.org/jira/browse/BEAM-598 Project:

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440358#comment-15440358 ] Daniel Halperin commented on BEAM-598: -- Hmm. The test suite still failed after I made this change, even

[jira] [Updated] (BEAM-559) DoFnTester should handle Setup / TearDown

2016-08-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-559: - Assignee: Thomas Groh (was: Daniel Halperin) > DoFnTester should handle Setup / TearDown >

[jira] [Closed] (BEAM-255) Understand and improve performance of Write/FileBasedSink

2016-08-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-255. Resolution: Fixed Fix Version/s: Not applicable > Understand and improve performance of

[jira] [Commented] (BEAM-582) Allow usage of the new GCP service account JSON key

2016-08-24 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15435574#comment-15435574 ] Daniel Halperin commented on BEAM-582: -- Hi Alex, Can you please provide more detail on this change? I

[jira] [Commented] (BEAM-582) Allow usage of the new GCP service account JSON key

2016-08-24 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15435674#comment-15435674 ] Daniel Halperin commented on BEAM-582: -- Thanks! > Allow usage of the new GCP service account JSON key

[jira] [Comment Edited] (BEAM-55) Allow users to compress FileBasedSink output files

2016-09-28 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-55?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531314#comment-15531314 ] Daniel Halperin edited comment on BEAM-55 at 9/29/16 12:09 AM: --- Hi Florian,

[jira] [Commented] (BEAM-55) Allow users to compress FileBasedSink output files

2016-09-28 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-55?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531314#comment-15531314 ] Daniel Halperin commented on BEAM-55: - Hi Florian, AvroIO should support compression via Avro codec's.

[jira] [Created] (BEAM-684) De-Dataflow Beam

2016-09-26 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-684: Summary: De-Dataflow Beam Key: BEAM-684 URL: https://issues.apache.org/jira/browse/BEAM-684 Project: Beam Issue Type: Improvement Components:

[jira] [Updated] (BEAM-684) De-Dataflow Beam

2016-09-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-684: - Priority: Minor (was: Major) > De-Dataflow Beam > > > Key:

[jira] [Resolved] (BEAM-670) BigQuery TableRow inserter incorrectly handles nextBackOff millis

2016-09-27 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-670. -- Resolution: Fixed Fix Version/s: Not applicable > BigQuery TableRow inserter incorrectly

[jira] [Commented] (BEAM-55) Allow users to compress FileBasedSink output files

2016-09-28 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-55?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531312#comment-15531312 ] Daniel Halperin commented on BEAM-55: - Note that there is a good reason this was not originally

[jira] [Resolved] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements

2016-10-25 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-805. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > DirectRunner occasionally flakes on

[jira] [Updated] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements

2016-10-25 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-805: - Affects Version/s: (was: Not applicable) 0.3.0-incubating > DirectRunner

[jira] [Created] (BEAM-859) Fix building with eclipse

2016-10-28 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-859: Summary: Fix building with eclipse Key: BEAM-859 URL: https://issues.apache.org/jira/browse/BEAM-859 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-847) Make DelegatingAggregator creation nonblocking

2016-10-28 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-847: - Summary: Make DelegatingAggregator creation nonblocking (was: DelelgatingAggregator uses

[jira] [Updated] (BEAM-847) Make DelegatingAggregator creation nonblocking

2016-10-28 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-847: - Issue Type: Improvement (was: Bug) > Make DelegatingAggregator creation nonblocking >

[jira] [Resolved] (BEAM-729) Does sdks/java/io/google-cloud-platform/pom.xml need javadoc plugin?

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-729. -- Resolution: Fixed Fix Version/s: Not applicable > Does

[jira] [Commented] (BEAM-729) Does sdks/java/io/google-cloud-platform/pom.xml need javadoc plugin?

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645692#comment-15645692 ] Daniel Halperin commented on BEAM-729: -- Resolved: all modules now get Javadoc for free from parent

[jira] [Closed] (BEAM-929) Findbugs doesn't pass in Kinesis

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-929. Resolution: Fixed Fix Version/s: Not applicable > Findbugs doesn't pass in Kinesis >

[jira] [Closed] (BEAM-729) Does sdks/java/io/google-cloud-platform/pom.xml need javadoc plugin?

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-729. > Does sdks/java/io/google-cloud-platform/pom.xml need javadoc plugin? >

[jira] [Updated] (BEAM-933) Findbugs doesn't pass in Java Examples

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-933: - Component/s: (was: sdk-java-extensions) examples-java > Findbugs doesn't pass

[jira] [Updated] (BEAM-933) Findbugs doesn't pass in Java Examples

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-933: - Assignee: Davor Bonaci (was: Amit Sela) > Findbugs doesn't pass in Java Examples >

[jira] [Updated] (BEAM-934) Findbugs doesn't pass in Java8 Examples

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-934: - Description: {code} [INFO] --- findbugs-maven-plugin:3.0.1:check (default) @ beam-examples-java8

[jira] [Created] (BEAM-933) Findbugs doesn't pass in Java Examples

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-933: Summary: Findbugs doesn't pass in Java Examples Key: BEAM-933 URL: https://issues.apache.org/jira/browse/BEAM-933 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-932) Findbugs doesn't pass in Spark runner

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-932: - Description: {code} [INFO] --- findbugs-maven-plugin:3.0.1:check (default) @ beam-runners-spark ---

[jira] [Closed] (BEAM-704) KafkaIO should handle "latest offset" evenly, and persist it as part of the CheckpointMark.

2016-11-08 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-704. Resolution: Fixed Fix Version/s: 0.3.0-incubating > KafkaIO should handle "latest offset"

[jira] [Updated] (BEAM-496) Remove the notion of a Fake subscription from PubsubIO

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-496: - Assignee: (was: Daniel Halperin) > Remove the notion of a Fake subscription from PubsubIO >

[jira] [Updated] (BEAM-713) Migrate BigTableIO to use AutoValue to reduce boilerplate

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-713: - Assignee: (was: Daniel Halperin) > Migrate BigTableIO to use AutoValue to reduce boilerplate >

[jira] [Commented] (BEAM-939) New credentials code broke Dataflow runner

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646161#comment-15646161 ] Daniel Halperin commented on BEAM-939: -- So we need to in our tests and in our IO set the

[jira] [Created] (BEAM-939) New credentials code broke Dataflow runner

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-939: Summary: New credentials code broke Dataflow runner Key: BEAM-939 URL: https://issues.apache.org/jira/browse/BEAM-939 Project: Beam Issue Type: New Feature

[jira] [Updated] (BEAM-712) Migrate BigQueryIO to use AutoValue to reduce boilerplate

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-712: - Assignee: (was: Daniel Halperin) > Migrate BigQueryIO to use AutoValue to reduce boilerplate >

[jira] [Updated] (BEAM-281) IOChannelUtils.getFactory should throw an unchecked exception rather than IOException

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-281: - Assignee: Pei He (was: Daniel Halperin) > IOChannelUtils.getFactory should throw an unchecked

[jira] [Updated] (BEAM-925) Findbugs doesn't pass in Dataflow Runner

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-925: - Description: {code} [INFO] Format-string method String.format(String, Object[]) called with format

[jira] [Created] (BEAM-925) Findbugs doesn't pass in Dataflow Runner

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-925: Summary: Findbugs doesn't pass in Dataflow Runner Key: BEAM-925 URL: https://issues.apache.org/jira/browse/BEAM-925 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-926) Findbugs doesn't pass in Microbenchmarks

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-926: Summary: Findbugs doesn't pass in Microbenchmarks Key: BEAM-926 URL: https://issues.apache.org/jira/browse/BEAM-926 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-929) Findbugs doesn't pass in Kinesis

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-929: - Description: {code} [INFO] --- findbugs-maven-plugin:3.0.1:check (default) @

[jira] [Created] (BEAM-931) Findbugs doesn't pass in Flink runner

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-931: Summary: Findbugs doesn't pass in Flink runner Key: BEAM-931 URL: https://issues.apache.org/jira/browse/BEAM-931 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-927) Findbugs doesn't pass in JMS

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-927: Summary: Findbugs doesn't pass in JMS Key: BEAM-927 URL: https://issues.apache.org/jira/browse/BEAM-927 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-928) Findbugs doesn't pass in Kafka

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-928: - Description: {code} [INFO] Inconsistent synchronization of

[jira] [Updated] (BEAM-928) Findbugs doesn't pass in Kafka

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-928: - Assignee: Raghu Angadi (was: Jean-Baptiste Onofré) > Findbugs doesn't pass in Kafka >

[jira] [Created] (BEAM-928) Findbugs doesn't pass in Kafka

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-928: Summary: Findbugs doesn't pass in Kafka Key: BEAM-928 URL: https://issues.apache.org/jira/browse/BEAM-928 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-930) Findbugs doesn't pass in MongoDB

2016-11-07 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-930: - Assignee: Jean-Baptiste Onofré (was: Daniel Halperin) > Findbugs doesn't pass in MongoDB >

[jira] [Created] (BEAM-922) runner-core does not pass under findbugs

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-922: Summary: runner-core does not pass under findbugs Key: BEAM-922 URL: https://issues.apache.org/jira/browse/BEAM-922 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-924) Findbugs doesn't pass in Direct Runner

2016-11-07 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-924: Summary: Findbugs doesn't pass in Direct Runner Key: BEAM-924 URL: https://issues.apache.org/jira/browse/BEAM-924 Project: Beam Issue Type: Bug

<    1   2   3   4   5   6   7   8   9   >