beam-commits mailing list archives: October 2016

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · Next »Thread · Author · Date
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-270) Support Timestamps/Windows in Flink Batch Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-182) SourceTestUtils.assertSplitAtFractionExhaustive should do a bounded number of trials Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-94) CountingInput should be able to limit the rate at which output is produced Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-267) Enable Chekstyle check in Spark runner Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-292) TextIO.Write.to Empty Files Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-157) CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-53) PubSubIO: reimplement in Java Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-186) The streaming WindowedWordCount example is broken on Dataflow Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-82) Transitive dependencies in Beam pom.xml have conflicts that could result in old versions if reordered Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-295) Flink Create Functions call Collector.close() Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-336) examples-java README is not up-to-date Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-484) Datastore Source should support Dynamic Splitting Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-159) Support fixed number of shards in sinks Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-146) WindowFn.AssignContext leaks implementation details about compressed WindowedValue representation Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-20) Create build jobs on Jenkins Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-379) DisplayDataEvaluator does not support source transforms of the form PTransform<PBegin, ?> Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-142) BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-95) Compress DoFn's / SerializableCoder / ... when serializing objects Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-345) When WindowFn not specified in Window.into(...), NullPointerException Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-148) Jenkins build failure on start project Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-220) KafkaIO test is flaky Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-282) RunnableOnService tests broken by BigQuery test Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-363) CompressedSource splits when it shouldn't Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-83) Beam SDK has some difficulties upon import to Eclipse as maven project Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-207) Flink test flake in ReadSourceStreamingITCase Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-257) fix ConcurrentModificationException in KafkaIO Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-130) Checkpointing of custom sources and sinks Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-155) Support asserting the contents of windows and panes in PAssert Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-434) Limit the number of output files a beam-examples execution writes Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-304) Build break: maven is picking up Kafka snapshots Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-117) Implement the API for Static Display Metadata Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-132) Release process for Beam artifacts to Maven Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-127) Support for Unbounded sinks in Streaming Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-151) Create Dataflow Runner Package Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-254) Add maven-rat-plugin execution Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-167) TextIO can't read concatenated gzip files Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-5) Import Flink Runner code Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-380) Remove Spark runner dependency on beam-examlpes-java Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-314) Support zip compression in TextIO Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-376) Correct Python pip install target Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-289) Examples Use TypeDescriptors Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-235) Remove streaming flag Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-390) Update spark runner to use spark version 1.6.2 Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-131) Write to jdbc/database Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-1) Import code on git Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-136) PipelineOptionsFactory should detect all runners Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-104) Capability matrix for Beam website Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-357) Build doesn't pass on windows Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-321) Hash encoded keys in Flink batch mode Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-258) Execute selected RunnableOnService tests with Flink runner Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-225) Create Class for Common TypeDescriptors Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-338) Fix licensing and usage of gutenberg files in Spark test Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-422) AvroSource hits various IOException when using Snappy codec Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-269) Create BigDecimal Coder Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-372) CoderProperties: Test that the coder doesn't consume more bytes than it produces Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-271) Option to configure remote Dataflow windmill service endpoint Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-22) DirectPipelineRunner: support for unbounded collections Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-103) Make UnboundedSourceWrapper parallel Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-356) Custom commands not executed on pip install for user workflow package Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-52) KafkaIO - unbounded source & sink Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-468) NullableCoder should not ask valueCoder isRegisterByteSizeObserverCheap when value is null Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-171) JAXBCoder ignores Context and inappropriately consumes input Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-316) Support file scheme in TextIO Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-114) Assemble and provide a source distribution Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-98) Travis coverage broken due to too much logging Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-498) Make DoFnWithContext the new DoFn Thu, 20 Oct, 22:37
Daniel Halperin (JIRA) [jira] [Created] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements Mon, 24 Oct, 16:15
Daniel Halperin (JIRA) [jira] [Commented] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements Mon, 24 Oct, 17:10
Daniel Halperin (JIRA) [jira] [Comment Edited] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements Mon, 24 Oct, 17:11
Daniel Halperin (JIRA) [jira] [Commented] (BEAM-806) Maven Release Plugin Does Not Set Archetype Versions Mon, 24 Oct, 18:16
Daniel Halperin (JIRA) [jira] [Commented] (BEAM-806) Maven Release Plugin Does Not Set Archetype Versions Mon, 24 Oct, 18:27
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-641) Need to test the generated archetypes projects Mon, 24 Oct, 19:25
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-641) Need to test the generated archetypes projects Mon, 24 Oct, 19:25
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-641) Need to test the generated archetypes projects Mon, 24 Oct, 19:25
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-641) Need to test the generated archetypes projects Mon, 24 Oct, 19:25
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-810) Beam's uses of archetypes are problematic Mon, 24 Oct, 19:29
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-810) Beam's uses of archetypes are problematic Mon, 24 Oct, 19:29
Daniel Halperin (JIRA) [jira] [Created] (BEAM-810) Beam's uses of archetypes are problematic Mon, 24 Oct, 19:29
Daniel Halperin (JIRA) [jira] [Commented] (BEAM-806) Maven Release Plugin Does Not Set Archetype Versions Mon, 24 Oct, 19:32
Daniel Halperin (JIRA) [jira] [Created] (BEAM-812) Shade guava in beam-sdks-java-io-google-cloud-platform Mon, 24 Oct, 22:11
Daniel Halperin (JIRA) [jira] [Created] (BEAM-814) Improve performance when staging files Tue, 25 Oct, 03:16
Daniel Halperin (JIRA) [jira] [Resolved] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements Tue, 25 Oct, 22:14
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-805) DirectRunner occasionally flakes on uncodeable elements Tue, 25 Oct, 22:14
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel() Wed, 26 Oct, 21:46
Daniel Halperin (JIRA) [jira] [Created] (BEAM-859) Fix building with eclipse Fri, 28 Oct, 15:59
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-847) Make DelegatingAggregator creation nonblocking Fri, 28 Oct, 17:06
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-847) Make DelegatingAggregator creation nonblocking Fri, 28 Oct, 17:06
Daniel Halperin (JIRA) [jira] [Commented] (BEAM-860) Move Apache RAT license check out of release profile Mon, 31 Oct, 16:05
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-398) Fix locking in JAXBCoder Mon, 31 Oct, 16:15
Daniel Halperin (JIRA) [jira] [Commented] (BEAM-626) AvroCoder not deserializing correctly in Kryo Mon, 31 Oct, 18:11
Davor Bonaci (JIRA) [jira] [Resolved] (BEAM-540) Dataflow streaming jobs running on windmill do not need data disks Wed, 05 Oct, 22:06
Davor Bonaci (JIRA) [jira] [Updated] (BEAM-540) Dataflow streaming jobs running on windmill do not need data disks Wed, 05 Oct, 22:06
Davor Bonaci (JIRA) [jira] [Assigned] (BEAM-115) Beam Runner API Thu, 27 Oct, 16:06
Davor Bonaci (JIRA) [jira] [Resolved] (BEAM-749) Syntax highlight on website Thu, 27 Oct, 16:17
Davor Bonaci (JIRA) [jira] [Created] (BEAM-863) WordCount on Windows: java.nio.file.InvalidPathException Fri, 28 Oct, 20:56
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-702) Simple pattern for per-bundle and per-DoFn Closeable resources Mon, 03 Oct, 18:46
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-702) Simple pattern for per-bundle and per-DoFn Closeable resources Mon, 03 Oct, 18:47
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · Next »Thread · Author · Date
Box list
Oct 2019231
Sep 2019348
Aug 2019351
Jul 2019387
Jun 2019332
May 2019464
Apr 2019336
Mar 2019259
Feb 2019367
Jan 2019518
Dec 2018368
Nov 2018448
Oct 20184197
Sep 20184689
Aug 20184453
Jul 20184320
Jun 20186163
May 20185547
Apr 20185962
Mar 20184479
Feb 20181955
Jan 20182670
Dec 20171428
Nov 20172364
Oct 20171972
Sep 20172095
Aug 20172291
Jul 20172998
Jun 20172879
May 20175577
Apr 20175171
Mar 20174068
Feb 20172908
Jan 20171848
Dec 20163374
Nov 20162900
Oct 20162712
Sep 20161298
Aug 20161500
Jul 20161550
Jun 20161725
May 20161092
Apr 20161731
Mar 20161158
Feb 2016294