| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-77) Reorganize Directory structure |
Sat, 25 Jun, 17:02 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-249) Combine.GroupedValues re-wraps combineFn from Combine.PerKey and loses identity for DisplayData |
Sat, 25 Jun, 17:02 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-291) PDone type translation fails |
Sat, 25 Jun, 17:03 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-216) Create Storm Runner |
Sat, 25 Jun, 17:04 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-183) Update package name for DisplayData types |
Sat, 25 Jun, 17:04 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-236) Implement Windowing in batch execution |
Sat, 25 Jun, 17:04 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-139) Print mode (batch/streaming) during translation |
Sat, 25 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-227) Log sdk version in worker-startup logs |
Sat, 25 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-185) XmlSink output file pattern missing "." in extension |
Sat, 25 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-232) Update AvroIO JavaDoc to Mention Registering Coder |
Sat, 25 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Sat, 25 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-129) Support pubsub IO |
Sat, 25 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-180) Add English labels for registered display data |
Sat, 25 Jun, 17:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging |
Sat, 25 Jun, 17:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-226) Upload JARs to Maven Central |
Sat, 25 Jun, 17:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-112) Using non-IntervalWindows seems to fail |
Sat, 25 Jun, 17:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-224) Two assert fails with merging windows and closable triggers |
Sat, 25 Jun, 17:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-179) NullPointerException in AfterEach.shouldFire after restart with changed trigger |
Sat, 25 Jun, 17:07 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-164) Dynamic splitting for unbounded sources |
Sat, 25 Jun, 17:07 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-125) PubSubIO.Read should be implemented by an UnboundedSource |
Sat, 25 Jun, 17:07 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO) |
Sat, 25 Jun, 17:07 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-120) Integrate DisplayData into DirectPipelineRunner |
Sat, 25 Jun, 17:07 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-99) Travis: Execute Maven "verify" phase |
Sat, 25 Jun, 17:08 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-36) TimestampedValueInMultipleWindows should use a more compact set representation |
Sat, 25 Jun, 17:08 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-12) Apply GroupByKey transforms on PCollection of normal type other than KV |
Sat, 25 Jun, 17:08 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-128) The transform BigQueryIO.Read is currently not supported. |
Sat, 25 Jun, 17:09 |
| Daniel Halperin (JIRA) |
[jira] [Resolved] (BEAM-128) The transform BigQueryIO.Read is currently not supported. |
Sat, 25 Jun, 17:09 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-154) Provide Maven BOM |
Sat, 25 Jun, 17:10 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-48) BigQueryIO.Read reimplemented as BoundedSource |
Sat, 25 Jun, 17:10 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-272) Flink Runner depends on Dataflow Runner |
Sat, 25 Jun, 17:10 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-168) IntervalBoundedExponentialBackOff change broke Beam-on-Dataflow |
Sat, 25 Jun, 17:10 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-204) truncateStackTrace fails with empty stack trace |
Sat, 25 Jun, 17:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-231) Remove ClassForDisplay infrastructure class. |
Sat, 25 Jun, 17:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-222) TestCounterSource does not implement checkpointing contract |
Sat, 25 Jun, 17:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-199) Improve fluent interface for manipulating DisplayData.Items |
Sat, 25 Jun, 17:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-247) CombineFn's only definable/usable inside sdk.transforms package |
Sat, 25 Jun, 17:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-173) Publish DisplayData for PipelineOptions |
Sat, 25 Jun, 17:12 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-189) The Spark runner uses valueInEmptyWindow which causes values to be dropped |
Sat, 25 Jun, 17:12 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-118) Add DisplayData to SDK |
Sat, 25 Jun, 17:13 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-133) Test flakiness in the Spark runner |
Sat, 25 Jun, 17:16 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-143) Add test for UnboundedSourceWrapper |
Sat, 25 Jun, 17:16 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-133) Test flakiness in the Spark runner |
Sat, 25 Jun, 17:16 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-213) Fix README to use refactored package names and use AutoService for Registrar |
Sat, 25 Jun, 17:17 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-149) IntelliJ: Java 8 tests configuration |
Sat, 25 Jun, 17:17 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-203) Travis Build is Broken |
Sat, 25 Jun, 17:17 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-178) stdout vs logging in DataflowPipelineRunner? |
Sat, 25 Jun, 17:17 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-208) Flaky test: org.apache.beam.runners.flink.streaming.GroupByNullKeyTest.testJob |
Sat, 25 Jun, 17:17 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-78) Rename Dataflow to Beam |
Sat, 25 Jun, 17:18 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-78) Rename Dataflow to Beam |
Sat, 25 Jun, 17:18 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-206) FileBasedSink does serial renames |
Sat, 25 Jun, 17:19 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-374) Enable dependency-plugin and failOnWarning at global level |
Sat, 25 Jun, 17:19 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-366) Support Display Data on Composite Transforms |
Sat, 25 Jun, 17:19 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-374) Enable dependency-plugin and failOnWarning at global level |
Sat, 25 Jun, 17:19 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-366) Support Display Data on Composite Transforms |
Sat, 25 Jun, 17:20 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-159) Support fixed number of shards in sinks |
Sat, 25 Jun, 20:00 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-159) Support fixed number of shards in sinks |
Sat, 25 Jun, 20:00 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-355) Update to Bigtable version 0.3.0 |
Sat, 25 Jun, 20:02 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-350) beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky |
Sat, 25 Jun, 20:02 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-364) Integration Tests for Bigtable Read and Write |
Sat, 25 Jun, 20:02 |
| Daniel Halperin (JIRA) |
[jira] [Resolved] (BEAM-350) beam_PostCommit_RunnableOnService_GoogleCloudDataflow flaky |
Sat, 25 Jun, 20:02 |
| Daniel Halperin (JIRA) |
[jira] [Assigned] (BEAM-365) TextIO withoutSharding causes Flink to throw IllegalStateException |
Sat, 25 Jun, 20:03 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-377) BigQueryIO should validate a table or query to read from |
Sun, 26 Jun, 06:11 |
| Daniel Halperin (JIRA) |
[jira] [Resolved] (BEAM-377) BigQueryIO should validate a table or query to read from |
Sun, 26 Jun, 06:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-159) Support fixed number of shards in sinks |
Sun, 26 Jun, 07:37 |
| Daniel Halperin (JIRA) |
[jira] [Created] (BEAM-381) OffsetBasedReader should construct sources before updating the range tracker |
Tue, 28 Jun, 01:44 |
| Daniel Halperin (JIRA) |
[jira] [Created] (BEAM-382) Audit BoundedReaders for BEAM-381 |
Tue, 28 Jun, 02:20 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces |
Tue, 28 Jun, 06:40 |
| Daniel Halperin (JIRA) |
[jira] [Assigned] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces |
Tue, 28 Jun, 06:45 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces |
Tue, 28 Jun, 06:45 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-310) Exercise splitIntoBundles/generateInitialSplits in the Direct Runner |
Tue, 28 Jun, 16:34 |
| Daniel Halperin (JIRA) |
[jira] [Created] (BEAM-383) BigQueryIO: update sink to shard into multiple write jobs |
Tue, 28 Jun, 19:12 |
| Daniel Halperin (JIRA) |
[jira] [Resolved] (BEAM-363) CompressedSource splits when it shouldn't |
Tue, 28 Jun, 23:55 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-363) CompressedSource splits when it shouldn't |
Tue, 28 Jun, 23:56 |
| Daniel Halperin (JIRA) |
[jira] [Resolved] (BEAM-159) Support fixed number of shards in sinks |
Wed, 29 Jun, 00:16 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-365) TextIO withoutSharding causes Flink to throw IllegalStateException |
Wed, 29 Jun, 00:17 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-365) TextIO withoutSharding causes Flink to throw IllegalStateException |
Wed, 29 Jun, 00:18 |
| Daniel Halperin (JIRA) |
[jira] [Created] (BEAM-388) Update Beam Incubation Status page on main Apache site |
Wed, 29 Jun, 21:17 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-388) Update Beam Incubation Status page on main Apache site |
Wed, 29 Jun, 21:17 |
| Daniel Halperin (JIRA) |
[jira] [Comment Edited] (BEAM-388) Update Beam Incubation Status page on main Apache site |
Wed, 29 Jun, 21:18 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-386) Dataflow runner to support Read.Bounded in streaming mode. |
Thu, 30 Jun, 05:47 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-387) Remove internal file and fix gcsio code path |
Thu, 30 Jun, 05:50 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-394) AvroCoder is Serializable with non-serializable fields |
Thu, 30 Jun, 17:05 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-355) Update to Bigtable version 0.3.0 |
Thu, 30 Jun, 20:08 |
| Daniel Halperin (JIRA) |
[jira] [Created] (BEAM-404) PubsubIO should have a mode that supports maintaining message attributes. |
Thu, 30 Jun, 20:45 |
| Daniel Mills (JIRA) |
[jira] [Created] (BEAM-343) DisplayData error in AfterWatermark |
Wed, 15 Jun, 16:24 |
| Daniel Mills (JIRA) |
[jira] [Created] (BEAM-359) AvroCoder should be able to handle anonymous classes as schemas |
Mon, 20 Jun, 18:22 |
| Daniel Mills (JIRA) |
[jira] [Created] (BEAM-361) Batch Pub/Sub sink does not set idLabel |
Mon, 20 Jun, 19:57 |
| Daniel Mills (JIRA) |
[jira] [Created] (BEAM-384) Streaming BigQueryIO should support user-provided IDs |
Tue, 28 Jun, 20:07 |
| Daniel Mills (JIRA) |
[jira] [Created] (BEAM-400) Direct/InProcess runner should use Pubsub publish time timestamp if timestampLabel is not set |
Thu, 30 Jun, 19:44 |
| Davor Bonaci (JIRA) |
[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink |
Mon, 06 Jun, 16:28 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API |
Thu, 16 Jun, 21:03 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API |
Thu, 16 Jun, 21:03 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API |
Thu, 16 Jun, 21:04 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API |
Thu, 16 Jun, 21:04 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-279) Make sure we unit test bounded sessions |
Fri, 17 Jun, 18:02 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-288) Improve javadoc for UnboundedSource |
Fri, 17 Jun, 18:03 |
| Davor Bonaci (JIRA) |
[jira] [Closed] (BEAM-319) Attach src distribution artifact to be take by deploy |
Fri, 17 Jun, 23:00 |
| Davor Bonaci (JIRA) |
[jira] [Closed] (BEAM-287) Add new beam groupIds |
Fri, 17 Jun, 23:01 |
| Davor Bonaci (JIRA) |
[jira] [Updated] (BEAM-363) CompressedSource splits when it shouldn't |
Mon, 20 Jun, 22:43 |
| Davor Bonaci (JIRA) |
[jira] [Closed] (BEAM-262) Native Runners | Direct Compiler |
Mon, 20 Jun, 22:58 |