beam-commits mailing list archives: September 2017

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 · Next »Thread · Author · Date
k...@apache.org [06/36] beam git commit: mr-runner: add JobPrototype and translate it to a MR job. Thu, 07 Sep, 18:39
k...@apache.org [07/36] beam git commit: core-java: InMemoryTimerInternals expose getTimers() for timer firings in mr-runner. Thu, 07 Sep, 18:39
k...@apache.org [08/36] beam git commit: mr-runner: support BoundedSource with BeamInputFormat. Thu, 07 Sep, 18:39
k...@apache.org [09/36] beam git commit: mr-runner: hack to get around that ViewAsXXX.expand() return wrong output PValue. Thu, 07 Sep, 18:39
k...@apache.org [10/36] beam git commit: mr-runner: support graph visualization with dotfiles. Thu, 07 Sep, 18:39
k...@apache.org [11/36] beam git commit: mr-runner: refactors and creates Graph data structures to handle general Beam pipelines. Thu, 07 Sep, 18:39
k...@apache.org [12/36] beam git commit: mr-runner: refactors and creates Graph data structures to handle general Beam pipelines. Thu, 07 Sep, 18:39
k...@apache.org [13/36] beam git commit: mr-runner: add JarClassInstanceFactory to run ValidatesRunner tests. Thu, 07 Sep, 18:39
k...@apache.org [14/36] beam git commit: mr-runner: support reduce side ParDos and WordCount. Thu, 07 Sep, 18:39
k...@apache.org [15/36] beam git commit: mr-runner: setup file paths for read and write sides of materialization. Thu, 07 Sep, 18:39
k...@apache.org [16/36] beam git commit: mr-runner: support side inputs by reading in all views contents. Thu, 07 Sep, 18:39
k...@apache.org [17/36] beam git commit: mr-runner: support PCollections materialization with multiple MR jobs. Thu, 07 Sep, 18:39
k...@apache.org [18/36] beam git commit: mr-runner: support multiple SourceOperations by composing and partitioning. Thu, 07 Sep, 18:39
k...@apache.org [19/36] beam git commit: [BEAM-2783] support metrics in MapReduceRunner. Thu, 07 Sep, 18:39
k...@apache.org [20/36] beam git commit: mr-runner: fix the bug that steps are attached multiple times in diamond shaped DAG. Thu, 07 Sep, 18:39
k...@apache.org [21/36] beam git commit: mr-runner: setMetricsSupported to run ValidatesRunner tests with TestPipeline. Thu, 07 Sep, 18:39
k...@apache.org [22/36] beam git commit: mr-runner: use the correct step name in ParDoTranslator, this fixes MetricsTest.testAttemptedCounterMetrics(). Thu, 07 Sep, 18:39
k...@apache.org [23/36] beam git commit: mr-runner: fix NPE in PipelineTest.testIdentityTransform(). Thu, 07 Sep, 18:39
k...@apache.org [24/36] beam git commit: mr-runner: remove the hard-coded GlobalWindow coder, and fixes WindowingTest. Thu, 07 Sep, 18:39
k...@apache.org [25/36] beam git commit: mr-runner: handle no files case in FileSideInputReader for empty views. Thu, 07 Sep, 18:39
k...@apache.org [26/36] beam git commit: mr-runner: use InMemoryStateInternals in ParDoOperation, this fixed ParDoTest that uses state. Thu, 07 Sep, 18:39
k...@apache.org [27/36] beam git commit: mr-runner: filter out unsupported features in ValidatesRunner tests. Thu, 07 Sep, 18:39
k...@apache.org [28/36] beam git commit: mr-runner: fail early in the runner when MapReduce job fails. Thu, 07 Sep, 18:39
k...@apache.org [29/36] beam git commit: mr-runner: ensure Operation only start/finish once for diamond shaped DAG, this fixes ParDoLifecycleTest. Thu, 07 Sep, 18:39
k...@apache.org [30/36] beam git commit: mr-runner: translate empty flatten into EmptySource, this fixes few empty FalttenTests. Thu, 07 Sep, 18:39
k...@apache.org [31/36] beam git commit: mr-runner: introduces duplicateFactor in FlattenOperation, this fixes testFlattenInputMultipleCopies(). Thu, 07 Sep, 18:39
k...@apache.org [32/36] beam git commit: mr-runner: Graph.getSteps() to return with topological order, this fixes few CombineTests. Thu, 07 Sep, 18:39
k...@apache.org [33/36] beam git commit: mr-runner: support SourceMetrics, this fixes MetricsTest.testBoundedSourceMetrics(). Thu, 07 Sep, 18:39
k...@apache.org [34/36] beam git commit: mr-runner: Removes WordCountTest, fixes checkstyle, findbugs, and addressed comments. Thu, 07 Sep, 18:39
k...@apache.org [35/36] beam git commit: mr-runner-hack: disable unrelated modules to shorten build time during development. Thu, 07 Sep, 18:39
k...@apache.org [36/36] beam git commit: This closes #3705: [BEAM-165] Initial implementation of the MapReduce runner Thu, 07 Sep, 18:39
k...@apache.org [1/2] beam git commit: Key StateTable off id, not full StateTag Mon, 11 Sep, 22:32
k...@apache.org [2/2] beam git commit: This closes #3818: [BEAM-2866] Key StateTable off ID Mon, 11 Sep, 22:32
k...@apache.org [1/3] beam git commit: Improve error message for bad DoFn URN in ParDoTranslation Tue, 12 Sep, 23:57
k...@apache.org [2/3] beam git commit: Key DoFnInstanceManager cache on AppliedPTransform Tue, 12 Sep, 23:57
k...@apache.org [3/3] beam git commit: This closes #3842: [BEAM-2516] Key DirectRunner DoFn cache off step rather than DoFn Tue, 12 Sep, 23:57
k...@apache.org [1/2] beam git commit: Add fast path to ParDoTranslation for known ParDo class Wed, 13 Sep, 02:09
k...@apache.org [2/2] beam git commit: This closes #3843: [BEAM-2516] Add fast path to ParDoTranslation for known ParDo class Wed, 13 Sep, 02:09
k...@apache.org [1/2] beam git commit: Key FlinkRunner streaming translation off URN Thu, 14 Sep, 18:36
k...@apache.org [2/2] beam git commit: This closes #3813: [BEAM-2795] Key FlinkRunner streaming translation off URN Thu, 14 Sep, 18:36
k...@apache.org [1/3] beam git commit: Move DoFnInfo to SDK util Tue, 19 Sep, 14:30
k...@apache.org [2/3] beam git commit: Update Dataflow container version to 20170918 Tue, 19 Sep, 14:30
k...@apache.org [3/3] beam git commit: This closes #3858: [BEAM-2884] Move DoFnInfo to SDK util Tue, 19 Sep, 14:30
k...@apache.org [1/4] beam git commit: Mark AuctionOrBidWindowCoder as consistentWithEquals Thu, 21 Sep, 22:49
k...@apache.org [2/4] beam git commit: Enforce correctness of consistentWithEquals and fix broken hashCode() method for AuctionOrBidWindowCoder Thu, 21 Sep, 22:49
k...@apache.org [3/4] beam git commit: Make AuctionOrBidWindowCoder use structuralValue instead of consistentWithEquals Thu, 21 Sep, 22:49
k...@apache.org [4/4] beam git commit: This closes #3844: Mark AuctionOrBidWindowCoder as consistentWithEquals Thu, 21 Sep, 22:49
k...@apache.org [1/5] beam git commit: Update Dataflow worker to 20170921 Fri, 22 Sep, 02:25
k...@apache.org [2/5] beam git commit: Send portable ParDo protos to Dataflow instead of just DoFnInfo Fri, 22 Sep, 02:25
k...@apache.org [3/5] beam git commit: DataflowRunner depends on, and shades, protobuf Fri, 22 Sep, 02:25
k...@apache.org [4/5] beam git commit: Shade generated Runner API classes in Dataflow runner Fri, 22 Sep, 02:25
k...@apache.org [5/5] beam git commit: This closes #3859: [BEAM-2884] Send portable protos for ParDo in DataflowRunner Fri, 22 Sep, 02:25
k...@apache.org [1/2] beam git commit: Revert "This closes #3859: [BEAM-2884] Send portable protos for ParDo in DataflowRunner" Fri, 22 Sep, 19:39
k...@apache.org [2/2] beam git commit: This closes #3887: Revert #3859: "Send portable protos for ParDo in DataflowRunner" Fri, 22 Sep, 19:39
k...@apache.org [1/2] beam git commit: Update Dataflow worker to 20170922-01 Sat, 23 Sep, 01:25
k...@apache.org [2/2] beam git commit: This closes #2889: [BEAM-2981] Update Dataflow worker version to attain ProtoCoder serialVersionUID fix Sat, 23 Sep, 01:25
k...@apache.org [1/3] beam git commit: Move Runners Core Fn Api classes into a package Fri, 29 Sep, 16:33
k...@apache.org [2/3] beam git commit: Move Runners Core Fn Api classes into a package Fri, 29 Sep, 16:33
k...@apache.org [3/3] beam git commit: This closes #3899: Move Runners Core Fn Api classes into a package Fri, 29 Sep, 16:33
k...@apache.org [1/5] beam git commit: Allow users to skip Java or Python branch via a comment. Also use try/catch blocks to stop non-blocking branches from stopping the build. Fri, 29 Sep, 16:54
k...@apache.org [2/5] beam git commit: Modify trigger phrase to require specifying which language. Fri, 29 Sep, 16:54
k...@apache.org [3/5] beam git commit: Introduce a more sustainable way to add new SDKs. Fri, 29 Sep, 16:54
k...@apache.org [4/5] beam git commit: Update variable references. Fri, 29 Sep, 16:54
k...@apache.org [5/5] beam git commit: This closes #3918: [BEAM-2596] Pipeline Job Choose Branch Fri, 29 Sep, 16:54
k...@apache.org [1/2] beam git commit: [BEAM-2997] Encapsulate enums within a message so that C++/Python have meaningful namespaces when importing. Fri, 29 Sep, 17:15
k...@apache.org [2/2] beam git commit: This closes #3913: [BEAM-2997] Encapsulate enums within a message so that C++/Python have meaningful namespaces when importing. Fri, 29 Sep, 17:15
k...@apache.org [1/2] beam git commit: Increase precommit timeout to 150 minutes Sat, 30 Sep, 16:24
k...@apache.org [2/2] beam git commit: This closes #3926: Increase precommit timeout to 150 minutes Sat, 30 Sep, 16:24
kennknowles [GitHub] beam pull request #3813: [BEAM-2795] Key FlinkRunner streaming translation o... Wed, 06 Sep, 04:47
kennknowles [GitHub] beam pull request #3818: [BEAM-2866] Key StateTable off ID Fri, 08 Sep, 02:49
kennknowles [GitHub] beam pull request #3842: [BEAM-2516] Key DirectRunner DoFn cache off step ra... Tue, 12 Sep, 18:50
kennknowles [GitHub] beam pull request #3843: [BEAM-2516] Add fast path to ParDoTranslation for k... Tue, 12 Sep, 23:26
kennknowles [GitHub] beam pull request #3858: [BEAM-2884] Move DoFnInfo to SDK util Sun, 17 Sep, 22:29
kennknowles [GitHub] beam pull request #3859: [BEAM-2884] Send portable protos for ParDo in Dataf... Sun, 17 Sep, 22:37
kennknowles [GitHub] beam pull request #3887: [BEAM-2884] Revert "This closes #3859: Send portabl... Fri, 22 Sep, 18:36
kennknowles [GitHub] beam pull request #3889: [BEAM-2981] Update Dataflow worker version to attai... Fri, 22 Sep, 21:12
kennknowles [GitHub] beam pull request #3920: Package util Fri, 29 Sep, 05:11
kennknowles [GitHub] beam pull request #3924: [BEAM-2576] Split Beam portability framework into c... Fri, 29 Sep, 22:05
kennknowles [GitHub] beam pull request #3926: Increase precommit timeout to 150 minutes Sat, 30 Sep, 16:17
lc...@apache.org [1/2] beam git commit: Add fn API progress reporting protos Thu, 07 Sep, 20:48
lc...@apache.org [2/2] beam git commit: [BEAM-2822] Add fn API progress reporting protos Thu, 07 Sep, 20:48
lc...@apache.org [1/3] beam git commit: Upgrade slf4j to version 1.7.25 Fri, 08 Sep, 15:58
lc...@apache.org [2/3] beam git commit: Upgrade snappy-java to version 1.1.4 Fri, 08 Sep, 15:58
lc...@apache.org [3/3] beam git commit: Update snappy-java and slf4j to the latest stable versions Fri, 08 Sep, 15:58
lc...@apache.org [1/2] beam git commit: Add ThrowingBiConsumer to the set of functional interfaces Fri, 08 Sep, 18:22
lc...@apache.org [2/2] beam git commit: Add ThrowingBiConsumer to the set of functional interfaces Fri, 08 Sep, 18:22
lc...@apache.org [1/2] beam git commit: [BEAM-2862] Add PTransform overrides specific to execution of StatefulDoFns over the Fn API using the DataflowRunner. Mon, 11 Sep, 22:00
lc...@apache.org [2/2] beam git commit: [BEAM-2862] Add PTransform overrides specific to execution of StatefulDoFns over the Fn API using the DataflowRunner. Mon, 11 Sep, 22:00
lc...@apache.org [1/3] beam git commit: Fall back to inputStream.read(byteBuffer) in case of off-heap byteBuffer use guava ByteStreams in place of manual byte skip in UTests Fri, 15 Sep, 15:08
lc...@apache.org [2/3] beam git commit: [BEAM-2790] Use byte[] instead of ByteBuffer to read from HadoopFilesystem Fri, 15 Sep, 15:08
lc...@apache.org [3/3] beam git commit: [BEAM-2790] Use byte[] instead of ByteBuffer to read from HadoopFilesystem Fri, 15 Sep, 15:08
lc...@apache.org [1/2] beam git commit: [BEAM-2956] Attempt to correctly report the Dataflow distribution in GCP related modules. Fri, 15 Sep, 20:53
lc...@apache.org [2/2] beam git commit: [BEAM-2956] Attempt to correctly report the Dataflow distribution in GCP related modules. Fri, 15 Sep, 20:53
lc...@apache.org [1/2] beam git commit: [BEAM-2961] Add missing OnTimeBehavior proto translation to WindowingStrategy translation Fri, 15 Sep, 23:35
lc...@apache.org [2/2] beam git commit: [BEAM-2961] WindowingStrategy proto translation does not translate OnTimeBehavior Fri, 15 Sep, 23:35
lc...@apache.org [1/2] beam git commit: [BEAM-2808] Improving error message in ParDo.validateWindowTypeForMethod. Fri, 15 Sep, 23:36
lc...@apache.org [2/2] beam git commit: [BEAM-2808] Improve error message when DoFn @ProcessElement has the wrong window type Fri, 15 Sep, 23:36
lc...@apache.org [1/2] beam git commit: [BEAM-2959] Fix proto enums to use "YYY_UNSPECIFIED" as the first declared enum. Wed, 27 Sep, 18:53
lc...@apache.org [2/2] beam git commit: [BEAM-2959] Fix proto enums to use "YYY_UNSPECIFIED" as the first declared enum. Wed, 27 Sep, 18:53
lc...@apache.org [1/2] beam git commit: [BEAM-2606] make WindowFnTestUtils use the value in addition to the timestamp of the elements Wed, 27 Sep, 23:44
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · Next »Thread · Author · Date
Box list
Sep 2019250
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