[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: - Summary: Support fixed number of shards in sinks (was: Support fixed number of shards in custom

[jira] [Updated] (BEAM-330) Maven exec warning message on Dataflow WordCount Example

[ https://issues.apache.org/jira/browse/BEAM-330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-330: - Fix Version/s: 0.2.0-incubating > Maven exec warning message on Dataflow WordCount Example >

[jira] [Updated] (BEAM-331) WindowedWordCount.AddTimestampFn has nondeterministic timestamp bounds

[ https://issues.apache.org/jira/browse/BEAM-331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-331: - Fix Version/s: 0.2.0-incubating > WindowedWordCount.AddTimestampFn has nondeterministic timestamp

[jira] [Assigned] (BEAM-365) TextIO withoutSharding causes Flink to throw IllegalStateException

[ https://issues.apache.org/jira/browse/BEAM-365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-365: Assignee: Daniel Halperin > TextIO withoutSharding causes Flink to throw

[jira] [Closed] (BEAM-377) BigQueryIO should validate a table or query to read from

[ https://issues.apache.org/jira/browse/BEAM-377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-377. > BigQueryIO should validate a table or query to read from >

[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: - Component/s: (was: beam-model) > Support fixed number of shards in sinks >

[jira] [Resolved] (BEAM-45) Unbounded source for Google Cloud Bigtable

[ https://issues.apache.org/jira/browse/BEAM-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-45. - Resolution: Later > Unbounded source for Google Cloud Bigtable >

[jira] [Updated] (BEAM-46) Unbounded sink for Google Cloud Bigtable

[ https://issues.apache.org/jira/browse/BEAM-46?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-46: Assignee: Ian Zhou > Unbounded sink for Google Cloud Bigtable >

[jira] [Commented] (BEAM-221) ProtoIO

[ https://issues.apache.org/jira/browse/BEAM-221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15349050#comment-15349050 ] Daniel Halperin commented on BEAM-221: -- One idea was to simply wrap AvroIO in a Composite PTransform: *

[jira] [Commented] (BEAM-45) Unbounded source for Google Cloud Bigtable

[ https://issues.apache.org/jira/browse/BEAM-45?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15349002#comment-15349002 ] Daniel Halperin commented on BEAM-45: - It turns out that Cloud Bigtable does not have the necessary API

[jira] [Updated] (BEAM-45) Unbounded source for Google Cloud Bigtable

[ https://issues.apache.org/jira/browse/BEAM-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-45: Affects Version/s: Not applicable > Unbounded source for Google Cloud Bigtable >

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

[ https://issues.apache.org/jira/browse/BEAM-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-146: - Fix Version/s: 0.2.0-incubating > WindowFn.AssignContext leaks implementation details about

[jira] [Updated] (BEAM-45) Unbounded source for Google Cloud Bigtable

[ https://issues.apache.org/jira/browse/BEAM-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-45: Fix Version/s: Not applicable > Unbounded source for Google Cloud Bigtable >

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

[ https://issues.apache.org/jira/browse/BEAM-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-146: - Summary: WindowFn.AssignContext leaks implementation details about compressed WindowedValue

[jira] [Updated] (BEAM-118) Add DisplayData to SDK

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

[jira] [Created] (BEAM-47) UnboundedSource should support dynamic work rebalancing

Daniel Halperin created BEAM-47: --- Summary: UnboundedSource should support dynamic work rebalancing Key: BEAM-47 URL: https://issues.apache.org/jira/browse/BEAM-47 Project: Beam Issue Type: New

[jira] [Created] (BEAM-46) Unbounded sink for Google Cloud Bigtable

Daniel Halperin created BEAM-46: --- Summary: Unbounded sink for Google Cloud Bigtable Key: BEAM-46 URL: https://issues.apache.org/jira/browse/BEAM-46 Project: Beam Issue Type: New Feature

[jira] [Created] (BEAM-54) PubSubIO: add validation of topic/subscription

Daniel Halperin created BEAM-54: --- Summary: PubSubIO: add validation of topic/subscription Key: BEAM-54 URL: https://issues.apache.org/jira/browse/BEAM-54 Project: Beam Issue Type: New Feature

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

[ https://issues.apache.org/jira/browse/BEAM-55?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-55: Assignee: (was: Davor Bonaci) > Allow users to compress FileBasedSink output files >

[jira] [Commented] (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:comment-tabpanel=15146657#comment-15146657 ] Daniel Halperin commented on BEAM-12: - Hi, I'm assuming that `ExtractFn` is some sort of function that

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

[ https://issues.apache.org/jira/browse/BEAM-53?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15174266#comment-15174266 ] Daniel Halperin commented on BEAM-53: - This BEAM issue subsumes

[jira] [Created] (BEAM-85) DataflowAssert (BeamAssert ;) needs sanity check that it's used correctly

Daniel Halperin created BEAM-85: --- Summary: DataflowAssert (BeamAssert ;) needs sanity check that it's used correctly Key: BEAM-85 URL: https://issues.apache.org/jira/browse/BEAM-85 Project: Beam

[jira] [Commented] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1513#comment-1513 ] Daniel Halperin commented on BEAM-91: - This is the BEAM version of

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

[ https://issues.apache.org/jira/browse/BEAM-53?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-53: Assignee: Mark Shields > PubSubIO: reimplement in Java > - > >

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

[ https://issues.apache.org/jira/browse/BEAM-159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15218769#comment-15218769 ] Daniel Halperin commented on BEAM-159: -- https://issues.apache.org/jira/browse/BEAM-68 > Support fixed

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

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

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15219353#comment-15219353 ] Daniel Halperin commented on BEAM-68: - Eugene: I disagree with the premise that even the group by key

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15219376#comment-15219376 ] Daniel Halperin commented on BEAM-68: - Okay, I think I'm partially wrong. KV ->

[jira] [Comment Edited] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15219353#comment-15219353 ] Daniel Halperin edited comment on BEAM-68 at 3/31/16 5:08 AM: -- Eugene: I

[jira] [Created] (BEAM-178) stdout vs logging in DataflowPipelineRunner?

Daniel Halperin created BEAM-178: Summary: stdout vs logging in DataflowPipelineRunner? Key: BEAM-178 URL: https://issues.apache.org/jira/browse/BEAM-178 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-174) BigQueryIO.Read should give good error message for views and federated tables

Daniel Halperin created BEAM-174: Summary: BigQueryIO.Read should give good error message for views and federated tables Key: BEAM-174 URL: https://issues.apache.org/jira/browse/BEAM-174 Project:

[jira] [Assigned] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

[ https://issues.apache.org/jira/browse/BEAM-188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-188: Assignee: Daniel Halperin (was: Kenneth Knowles) > Merging WindowFn + GBK + Write =>

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

Daniel Halperin created BEAM-136: Summary: PipelineOptionsFactory should detect all runners Key: BEAM-136 URL: https://issues.apache.org/jira/browse/BEAM-136 Project: Beam Issue Type:

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

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205025#comment-15205025 ] Daniel Halperin edited comment on BEAM-131 at 3/21/16 8:19 PM: --- [and of course

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

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205025#comment-15205025 ] Daniel Halperin commented on BEAM-131: -- [and of course if the JDBC connector is only single-threaded it

[jira] [Created] (BEAM-148) Jenkins build failure on start project

Daniel Halperin created BEAM-148: Summary: Jenkins build failure on start project Key: BEAM-148 URL: https://issues.apache.org/jira/browse/BEAM-148 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204600#comment-15204600 ] Daniel Halperin commented on BEAM-138: -- https://issues.apache.org/jira/browse/BEAM-59 covers the

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204605#comment-15204605 ] Daniel Halperin commented on BEAM-138: -- JB, want to mark this as a dupe of BEAM-59? > Extend TextIO to

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

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204636#comment-15204636 ] Daniel Halperin commented on BEAM-131: -- This may be a silly question, but why is this in the

[jira] [Resolved] (BEAM-125) PubSubIO.Read should be implemented by an UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-125. -- Resolution: Duplicate I went ahead and assigned that one to you. Feel free to change the

[jira] [Commented] (BEAM-148) Jenkins build failure on start project

[ https://issues.apache.org/jira/browse/BEAM-148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15209808#comment-15209808 ] Daniel Halperin commented on BEAM-148: -- And pointing out that the test that failed on Jenkins and in

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

[ https://issues.apache.org/jira/browse/BEAM-136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15212154#comment-15212154 ] Daniel Halperin commented on BEAM-136: -- [~lcwik] can probably answer that question >

[jira] [Updated] (BEAM-85) DataflowAssert (BeamAssert ;) needs sanity check that it's used correctly

[ https://issues.apache.org/jira/browse/BEAM-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-85: Description: It is important that assert is applied to pipeline before the pipeline is run, otherwise

[jira] [Created] (BEAM-86) CountingSource should expose PTransform<PInput, PCollection> rather than sources directly

Daniel Halperin created BEAM-86: --- Summary: CountingSource should expose PTransform rather than sources directly Key: BEAM-86 URL: https://issues.apache.org/jira/browse/BEAM-86

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

[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178173#comment-15178173 ] Daniel Halperin commented on BEAM-92: - Abstractly, this is very easy to accomplish when the Sink is

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

[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-92: Component/s: beam-model > Data-dependent sinks > > > Key: BEAM-92

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

Daniel Halperin created BEAM-164: Summary: Dynamic splitting for unbounded sources Key: BEAM-164 URL: https://issues.apache.org/jira/browse/BEAM-164 Project: Beam Issue Type: Bug

[jira] [Closed] (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 closed BEAM-164. > Dynamic splitting for unbounded sources > --- > >

[jira] [Resolved] (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 resolved BEAM-164. -- Resolution: Duplicate > Dynamic splitting for unbounded sources >

[jira] [Commented] (BEAM-47) UnboundedSource should support dynamic work rebalancing

[ https://issues.apache.org/jira/browse/BEAM-47?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221977#comment-15221977 ] Daniel Halperin commented on BEAM-47: - (SplittableDoFn could make this obsolete) > UnboundedSource

[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: - Summary: IntervalBoundedExponentialBackOff change broke Beam-on-Dataflow (was:

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

[ https://issues.apache.org/jira/browse/BEAM-167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225122#comment-15225122 ] Daniel Halperin commented on BEAM-167: -- Thanks Eugene! > TextIO can't read concatenated gzip files >

[jira] [Created] (BEAM-157) CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken

Daniel Halperin created BEAM-157: Summary: CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken Key: BEAM-157 URL: https://issues.apache.org/jira/browse/BEAM-157 Project: Beam

[jira] [Created] (BEAM-223) KafkaIO: don't use SerializableCoder

Daniel Halperin created BEAM-223: Summary: KafkaIO: don't use SerializableCoder Key: BEAM-223 URL: https://issues.apache.org/jira/browse/BEAM-223 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-221) ProtoIO

Daniel Halperin created BEAM-221: Summary: ProtoIO Key: BEAM-221 URL: https://issues.apache.org/jira/browse/BEAM-221 Project: Beam Issue Type: Bug Components: sdk-java-gcp

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

Daniel Halperin created BEAM-220: Summary: KafkaIO test is flaky Key: BEAM-220 URL: https://issues.apache.org/jira/browse/BEAM-220 Project: Beam Issue Type: Bug Components:

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

[ https://issues.apache.org/jira/browse/BEAM-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-220: - Description: A test of checkpointing had an assertion failure:

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

[ https://issues.apache.org/jira/browse/BEAM-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-220. -- Resolution: Fixed We believe this issue is fixed by the changes in the linked PR. > KafkaIO test

[jira] [Updated] (BEAM-209) PCollection-to-batched-gcs-files PTransform

[ https://issues.apache.org/jira/browse/BEAM-209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-209: - Assignee: (was: Daniel Halperin) > PCollection-to-batched-gcs-files PTransform >

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

[ https://issues.apache.org/jira/browse/BEAM-168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258369#comment-15258369 ] Daniel Halperin commented on BEAM-168: -- Like to keep this open until I can remove the deprecated code.

[jira] [Commented] (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:comment-tabpanel=15297042#comment-15297042 ] Daniel Halperin commented on BEAM-304: -- I lied! What actually happened is that Kafka *released* 0.10,

[jira] [Comment Edited] (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:comment-tabpanel=15297042#comment-15297042 ] Daniel Halperin edited comment on BEAM-304 at 5/23/16 8:40 PM: --- I lied! What

[jira] [Resolved] (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 resolved BEAM-304. -- Resolution: Fixed > Build break: maven is picking up Kafka snapshots >

[jira] [Commented] (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:comment-tabpanel=15297014#comment-15297014 ] Daniel Halperin commented on BEAM-304: -- +[~rangadi] +[~jbonofre] +[~davor] JB, is grabbing snapshots

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

Daniel Halperin created BEAM-304: Summary: Build break: maven is picking up Kafka snapshots Key: BEAM-304 URL: https://issues.apache.org/jira/browse/BEAM-304 Project: Beam Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/BEAM-292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15287622#comment-15287622 ] Daniel Halperin commented on BEAM-292: -- +1 > TextIO.Write.to Empty Files > ---

[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: - Assignee: (was: Davor Bonaci) > TextIO.Write.to Empty Files > --- > >

[jira] [Updated] (BEAM-284) Add AWS S3 support to FileBasedSink

[ https://issues.apache.org/jira/browse/BEAM-284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-284: - Assignee: Roland Harangozo > Add AWS S3 support to FileBasedSink >

[jira] [Assigned] (BEAM-284) Add AWS S3 support to FileBasedSink

[ https://issues.apache.org/jira/browse/BEAM-284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-284: Assignee: Daniel Halperin (was: Davor Bonaci) > Add AWS S3 support to FileBasedSink >

[jira] [Updated] (BEAM-284) Add AWS S3 support to FileBasedSink

[ https://issues.apache.org/jira/browse/BEAM-284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-284: - Assignee: (was: Daniel Halperin) > Add AWS S3 support to FileBasedSink >

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

[ https://issues.apache.org/jira/browse/BEAM-206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282851#comment-15282851 ] Daniel Halperin commented on BEAM-206: -- Hi Roland, I'm a big jerk, but apparently I forgot to assign

[jira] [Assigned] (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 reassigned BEAM-206: Assignee: Daniel Halperin > FileBasedSink does serial renames >

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

Daniel Halperin created BEAM-282: Summary: RunnableOnService tests broken by BigQuery test Key: BEAM-282 URL: https://issues.apache.org/jira/browse/BEAM-282 Project: Beam Issue Type: Bug

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

Daniel Halperin created BEAM-255: Summary: Understand and improve performance of Write/FileBasedSink Key: BEAM-255 URL: https://issues.apache.org/jira/browse/BEAM-255 Project: Beam Issue

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

[ https://issues.apache.org/jira/browse/BEAM-50?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-50. - Resolution: Fixed > BigQueryIO.Write: reimplement in Java > - >

[jira] [Commented] (BEAM-209) PCollection-to-batched-gcs-files PTransform

[ https://issues.apache.org/jira/browse/BEAM-209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248125#comment-15248125 ] Daniel Halperin commented on BEAM-209: -- * Link to Nexmark code you're referring? * Can you say more

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

[ https://issues.apache.org/jira/browse/BEAM-207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-207: - Summary: Flink test flake in ReadSourceStreamingITCase (was: Flink test flake in

[jira] [Created] (BEAM-207) Flink test flake in ReadStreamingSourceITCase

Daniel Halperin created BEAM-207: Summary: Flink test flake in ReadStreamingSourceITCase Key: BEAM-207 URL: https://issues.apache.org/jira/browse/BEAM-207 Project: Beam Issue Type: Bug

[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: - Description: Ever since the default runner was changed to the InProcessRunner, Travis fails on

[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: - Description: Ever since the default runner was changed to the InProcessRunner, Travis fails on

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

Daniel Halperin created BEAM-203: Summary: Travis Build is Broken Key: BEAM-203 URL: https://issues.apache.org/jira/browse/BEAM-203 Project: Beam Issue Type: Bug Components:

[jira] [Closed] (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 closed BEAM-203. Resolution: Fixed Assignee: Daniel Halperin (was: Thomas Groh) > Travis Build is Broken >

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

[ https://issues.apache.org/jira/browse/BEAM-50?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-50: Assignee: Pei He (was: Daniel Halperin) > BigQueryIO.Write: reimplement in Java >

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

[ https://issues.apache.org/jira/browse/BEAM-50?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-50: --- Assignee: Daniel Halperin > BigQueryIO.Write: reimplement in Java >

[jira] [Closed] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

[ https://issues.apache.org/jira/browse/BEAM-188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-188. Resolution: Fixed > Merging WindowFn + GBK + Write => InvalidWindows throws >

[jira] [Created] (BEAM-206) GcsIOChannelFactory does serial renames

Daniel Halperin created BEAM-206: Summary: GcsIOChannelFactory does serial renames Key: BEAM-206 URL: https://issues.apache.org/jira/browse/BEAM-206 Project: Beam Issue Type: Bug

[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: - Summary: FileBasedSink does serial renames (was: GcsIOChannelFactory does serial renames) >

[jira] [Created] (BEAM-487) Add disclaimer to GitHub README.md

Daniel Halperin created BEAM-487: Summary: Add disclaimer to GitHub README.md Key: BEAM-487 URL: https://issues.apache.org/jira/browse/BEAM-487 Project: Beam Issue Type: Task

[jira] [Resolved] (BEAM-380) Remove Spark runner dependency on beam-examlpes-java

[ https://issues.apache.org/jira/browse/BEAM-380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-380. -- Resolution: Fixed Fix Version/s: 0.2.0-incubating > Remove Spark runner dependency on

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

[ https://issues.apache.org/jira/browse/BEAM-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-454: - Assignee: (was: Daniel Halperin) > Validate Pubsub Topic exists when reading >

[jira] [Updated] (BEAM-458) Support for Flink Metrics

[ https://issues.apache.org/jira/browse/BEAM-458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-458: - Assignee: (was: Frances Perry) > Support for Flink Metrics > -- > >

[jira] [Updated] (BEAM-474) Tests which evaluate DisplayData but don't run a pipeline should be marked @NeedsRunner not @RunnableOnService

[ https://issues.apache.org/jira/browse/BEAM-474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-474: - Assignee: (was: Daniel Halperin) > Tests which evaluate DisplayData but don't run a pipeline

[jira] [Created] (BEAM-488) Remove KEYS file

Daniel Halperin created BEAM-488: Summary: Remove KEYS file Key: BEAM-488 URL: https://issues.apache.org/jira/browse/BEAM-488 Project: Beam Issue Type: Task Components:

[jira] [Updated] (BEAM-451) When producing bundled jars, service files are not concatenated

[ https://issues.apache.org/jira/browse/BEAM-451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-451: - Labels: newbie starter (was: ) > When producing bundled jars, service files are not concatenated >

[jira] [Created] (BEAM-451) When producing bundled jars, service files are not concatenated

Daniel Halperin created BEAM-451: Summary: When producing bundled jars, service files are not concatenated Key: BEAM-451 URL: https://issues.apache.org/jira/browse/BEAM-451 Project: Beam

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

[ https://issues.apache.org/jira/browse/BEAM-316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-316. -- Resolution: Fixed Fix Version/s: 0.2.0-incubating > Support file scheme in TextIO >

[jira] [Closed] (BEAM-487) Add disclaimer to GitHub README.md

[ https://issues.apache.org/jira/browse/BEAM-487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-487. Assignee: Daniel Halperin (was: Jean-Baptiste Onofré) > Add disclaimer to GitHub README.md >

[jira] [Closed] (BEAM-488) Remove KEYS file

[ https://issues.apache.org/jira/browse/BEAM-488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-488. Assignee: Daniel Halperin (was: Jean-Baptiste Onofré) > Remove KEYS file > > >

[jira] [Closed] (BEAM-486) Cleanup NOTICE file

[ https://issues.apache.org/jira/browse/BEAM-486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-486. Assignee: Daniel Halperin (was: Jean-Baptiste Onofré) > Cleanup NOTICE file > --- >

[jira] [Updated] (BEAM-322) Compare encoded keys in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-322: - Affects Version/s: 0.2.0-incubating > Compare encoded keys in streaming mode >

<    1   2   3   4   5   6   7   8   9   >