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
Amit Sela (JIRA) [jira] [Updated] (BEAM-769) Spark streaming tests fail on "nothing processed" if runtime env. is slow because timeout is hit before processing is done. Thu, 20 Oct, 19:13
Apache Jenkins Server Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1591 Thu, 20 Oct, 19:23
Apache Jenkins Server Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1591 Thu, 20 Oct, 19:23
Apache Jenkins Server Jenkins build is still unstable: beam_PostCommit_MavenVerify #1591 Thu, 20 Oct, 19:24
Apache Jenkins Server Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1381 Thu, 20 Oct, 19:51
k...@apache.org [1/4] incubator-beam git commit: Translate ReshuffleTrigger to ReshuffleTriggerStateMachine Thu, 20 Oct, 19:51
k...@apache.org [2/4] incubator-beam git commit: Delete TriggerRunner Thu, 20 Oct, 19:51
k...@apache.org [3/4] incubator-beam git commit: Port ReduceFnRunner to TriggerStateMachine Thu, 20 Oct, 19:51
k...@apache.org [4/4] incubator-beam git commit: This closes #1138 Thu, 20 Oct, 19:51
asfgit [GitHub] incubator-beam pull request #1138: [BEAM-742] Port ReduceFnRunner to Trigger... Thu, 20 Oct, 19:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST Thu, 20 Oct, 19:52
Apache Jenkins Server Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1592 Thu, 20 Oct, 19:56
Apache Jenkins Server Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1592 Thu, 20 Oct, 19:56
Apache Jenkins Server Jenkins build is still unstable: beam_PostCommit_MavenVerify #1592 Thu, 20 Oct, 19:59
Kenneth Knowles (JIRA) [jira] [Created] (BEAM-788) Execute ReduceFn directly, not via OldDoFn wrapper Thu, 20 Oct, 20:01
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-175) Don't leak garbage collection timers in GlobalWindow Thu, 20 Oct, 20:17
k...@apache.org [1/2] incubator-beam git commit: Add analysis of Timer parameters to DoFn.ProcessElement Thu, 20 Oct, 20:32
k...@apache.org [2/2] incubator-beam git commit: This closes #1136 Thu, 20 Oct, 20:32
asfgit [GitHub] incubator-beam pull request #1136: [BEAM-27] Add analysis of Timer parameter... Thu, 20 Oct, 20:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers Thu, 20 Oct, 20:32
swegner [GitHub] incubator-beam pull request #1149: Remove autovalue.shaded imports Thu, 20 Oct, 20:33
Apache Jenkins Server Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1593 Thu, 20 Oct, 20:41
Apache Jenkins Server Jenkins build is back to stable : beam_PostCommit_MavenVerify #1593 Thu, 20 Oct, 20:42
Mark Liu (JIRA) [jira] [Resolved] (BEAM-605) Create BigQuery Verifier Thu, 20 Oct, 20:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-215) Implement Create as a BoundedSource Thu, 20 Oct, 20:54
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-465) OutgoingMessageCoder should be an AtomicCoder Thu, 20 Oct, 20:55
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-462) Replace MonitoringUtil.PrintHandler with a handler that utilizes a Java logger Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-465) Convert OutgoingMessageCoder to an AtomicCoder Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-465) Convert OutgoingMessageCoder to an AtomicCoder Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-465) OutgoingMessageCoder should be an AtomicCoder Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-457) Upgrade Avro to version 1.8.1 Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Reopened] (BEAM-465) OutgoingMessageCoder should be an AtomicCoder Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-317) Implement PAssert without using Side Inputs Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-285) Make MinLongFn and MaxLongFn mimic SumLongFn and use BinaryCombineLongFn Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-256) Add lifecycle event verifiers for Beam pipelines. Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner Thu, 20 Oct, 20:56
Daniel Halperin (JIRA) [jira] [Updated] (BEAM-34) Change default output timestamp for combined values to end of window Thu, 20 Oct, 20:57
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-34) Change default output timestamp for combined values to end of window Thu, 20 Oct, 20:57
swegner [GitHub] incubator-beam pull request #1150: Add checkstyle RedundantModifier check an... Thu, 20 Oct, 20:58
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-786) Make BoundedReadFromUnboundedSource available as a public utility Thu, 20 Oct, 21:01
lc...@apache.org [1/2] incubator-beam git commit: Remove autovalue.shaded imports Thu, 20 Oct, 21:04
lc...@apache.org [2/2] incubator-beam git commit: Remove autovalue.shaded imports Thu, 20 Oct, 21:04
asfgit [GitHub] incubator-beam pull request #1149: Remove autovalue.shaded imports Thu, 20 Oct, 21:04
Apache Jenkins Server Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1382 Thu, 20 Oct, 21:06
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking Thu, 20 Oct, 21:17
Frances Perry (JIRA) [jira] [Resolved] (BEAM-602) make feature branches more discoverable Thu, 20 Oct, 21:44
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-341) ReduceFnRunner allows GC time overflow Thu, 20 Oct, 21:47
Daniel Halperin (JIRA) [jira] [Closed] (BEAM-392) Update flink runner to use flink version 1.0.3 Thu, 20 Oct, 21:47
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
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
Jul 2019236
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