beam-commits mailing list archives: December 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 · 29 · 30 · 31 · 32 · 33 · 34 · Next »Thread · Author · Date
k...@apache.org [01/13] incubator-beam git commit: Disable tests for timers in ParDo for Apex runner Thu, 08 Dec, 18:09
k...@apache.org [02/13] incubator-beam git commit: Add JUnit category UsesTimersInParDo Thu, 08 Dec, 18:09
k...@apache.org [03/13] incubator-beam git commit: Add basic test for timers in ParDoTest Thu, 08 Dec, 18:09
k...@apache.org [04/13] incubator-beam git commit: Reject timers for ParDo in DirectRunner Thu, 08 Dec, 18:09
k...@apache.org [05/13] incubator-beam git commit: Reject timers for ParDo in ApexRunner Thu, 08 Dec, 18:09
k...@apache.org [06/13] incubator-beam git commit: Disable tests for timers in ParDo for Flink runner Thu, 08 Dec, 18:09
k...@apache.org [07/13] incubator-beam git commit: Disables tests for timers in ParDo for Spark runner Thu, 08 Dec, 18:09
k...@apache.org [08/13] incubator-beam git commit: Disable tests for timers in ParDo for Dataflow runner Thu, 08 Dec, 18:09
k...@apache.org [09/13] incubator-beam git commit: No longer reject timers in ParDo Thu, 08 Dec, 18:09
k...@apache.org [10/13] incubator-beam git commit: Reject timers for ParDo in SparkRunner Thu, 08 Dec, 18:09
k...@apache.org [11/13] incubator-beam git commit: Disable tests for timers in ParDo for direct runner Thu, 08 Dec, 18:09
k...@apache.org [12/13] incubator-beam git commit: Reject timers for ParDo in FlinkRunner Thu, 08 Dec, 18:09
k...@apache.org [13/13] incubator-beam git commit: This closes #1550 Thu, 08 Dec, 18:09
k...@apache.org [1/2] incubator-beam git commit: [BEAM-1111] Reject timers for ParDo in SparkRunner streaming evaluators Thu, 08 Dec, 19:54
k...@apache.org [2/2] incubator-beam git commit: This closes #1553 Thu, 08 Dec, 19:54
k...@apache.org [1/2] incubator-beam git commit: Fix exclusion of UsesTimersInParDo for FlinkRunner streaming tests Thu, 08 Dec, 20:46
k...@apache.org [2/2] incubator-beam git commit: This closes #1555 Thu, 08 Dec, 20:46
k...@apache.org [1/2] incubator-beam git commit: [BEAM-978] Support bulk get file size in GcsUtil. Thu, 08 Dec, 23:48
k...@apache.org [2/2] incubator-beam git commit: This closes #1359 Thu, 08 Dec, 23:48
k...@apache.org [1/2] incubator-beam git commit: Fix LateDataDroppingDoFnRunner to not increment the counter on reiteration. Fri, 09 Dec, 22:47
k...@apache.org [2/2] incubator-beam git commit: This closes #1564 Fri, 09 Dec, 22:47
k...@apache.org [1/3] incubator-beam git commit: [BEAM-1133] Add maxNumRecords per micro-batch for Spark runner options. Mon, 12 Dec, 19:38
k...@apache.org [2/3] incubator-beam git commit: [BEAM-1130] SparkRunner ResumeFromCheckpointStreamingTest Failing. Mon, 12 Dec, 19:38
k...@apache.org [3/3] incubator-beam git commit: This closes #1579 Mon, 12 Dec, 19:38
k...@apache.org [1/4] incubator-beam git commit: Factor out ShardedFile from FileChecksumMatcher Mon, 12 Dec, 23:34
k...@apache.org [2/4] incubator-beam git commit: Add IntervalWindow coder to the standard registry Mon, 12 Dec, 23:34
k...@apache.org [3/4] incubator-beam git commit: Revise WindowedWordCount for runner and execution mode portability Mon, 12 Dec, 23:34
k...@apache.org [4/4] incubator-beam git commit: This closes #1536 Mon, 12 Dec, 23:34
k...@apache.org [1/3] incubator-beam git commit: Revert 91cc606 "This closes #1586": Kryo + UBRFBS Tue, 13 Dec, 20:45
k...@apache.org [2/3] incubator-beam git commit: Fix version of Kryo in examples/java jenkins-precommit profile Tue, 13 Dec, 20:45
k...@apache.org [3/3] incubator-beam git commit: This closes #1597 Tue, 13 Dec, 20:45
k...@apache.org [1/3] incubator-beam git commit: Move PerKeyCombineFnRunner to runners-core Tue, 13 Dec, 21:38
k...@apache.org [2/3] incubator-beam git commit: Update Dataflow worker to beam-master-20161212 Tue, 13 Dec, 21:38
k...@apache.org [3/3] incubator-beam git commit: This closes #1541 Tue, 13 Dec, 21:38
k...@apache.org [1/2] incubator-beam git commit: This closes #1601 Tue, 13 Dec, 23:06
k...@apache.org [2/2] incubator-beam git commit: [BEAM-1149] Explode windows when fn uses side inputs Tue, 13 Dec, 23:06
k...@apache.org [1/2] incubator-beam git commit: [BEAM-1149] Explode windows when fn uses side inputs Tue, 13 Dec, 23:48
k...@apache.org [2/2] incubator-beam git commit: This closes #1602 Tue, 13 Dec, 23:48
k...@apache.org [1/2] incubator-beam git commit: Re-exclude UsesStatefulParDo tests for Dataflow Wed, 14 Dec, 00:12
k...@apache.org [2/2] incubator-beam git commit: This closes #1605 Wed, 14 Dec, 00:12
k...@apache.org [1/2] incubator-beam git commit: Revert "Allow stateful DoFn in DataflowRunner" Wed, 14 Dec, 00:51
k...@apache.org [2/2] incubator-beam git commit: This closes #1606 Wed, 14 Dec, 00:51
k...@apache.org [1/3] incubator-beam git commit: Revert "Allow stateful DoFn in DataflowRunner" Wed, 14 Dec, 01:48
k...@apache.org [2/3] incubator-beam git commit: Re-exclude UsesStatefulParDo tests for Dataflow Wed, 14 Dec, 01:48
k...@apache.org [3/3] incubator-beam git commit: This closes #1607 Wed, 14 Dec, 01:48
k...@apache.org [1/3] incubator-beam git commit: [BEAM-757] Use DoFnRunner in the implementation of DoFn via FlatMapFunction. Wed, 14 Dec, 03:04
k...@apache.org [2/3] incubator-beam git commit: [BEAM-807] Replace OldDoFn with DoFn. Wed, 14 Dec, 03:04
k...@apache.org [3/3] incubator-beam git commit: This closes #1578 Wed, 14 Dec, 03:04
k...@apache.org [1/2] incubator-beam git commit: Add Jenkins postcommit for RunnableOnService in Apex runner Wed, 14 Dec, 03:27
k...@apache.org [2/2] incubator-beam git commit: This closes #1598 Wed, 14 Dec, 03:27
k...@apache.org [1/2] incubator-beam git commit: SimpleDoFnRunner observes window if SideInputReader is nonempty Wed, 14 Dec, 19:44
k...@apache.org [2/2] incubator-beam git commit: This closes #1616 Wed, 14 Dec, 19:44
k...@apache.org [1/2] incubator-beam git commit: Fix NPE in StatefulParDoEvaluatorFactoryTest mocking Wed, 14 Dec, 21:20
k...@apache.org [2/2] incubator-beam git commit: This closes #1618 Wed, 14 Dec, 21:20
k...@apache.org [1/3] incubator-beam git commit: SimpleDoFnRunner observes window if SideInputReader is nonempty Wed, 14 Dec, 22:34
k...@apache.org [2/3] incubator-beam git commit: Fix NPE in StatefulParDoEvaluatorFactoryTest mocking Wed, 14 Dec, 22:34
k...@apache.org [3/3] incubator-beam git commit: This closes #1619 Wed, 14 Dec, 22:34
k...@apache.org [1/2] incubator-beam git commit: Fix mvn command args in Apex postcommit Jenkins job Thu, 15 Dec, 18:35
k...@apache.org [2/2] incubator-beam git commit: This closes #1626 Thu, 15 Dec, 18:35
k...@apache.org [1/2] incubator-beam git commit: [BEAM-1154] Get side input from proper window in ReduceFn Thu, 15 Dec, 19:41
k...@apache.org [2/2] incubator-beam git commit: This closes #1620 Thu, 15 Dec, 19:41
k...@apache.org [1/2] incubator-beam git commit: [BEAM-1154] Get side input from proper window in ReduceFn Thu, 15 Dec, 19:43
k...@apache.org [2/2] incubator-beam git commit: This closes #1630 Thu, 15 Dec, 19:43
k...@apache.org [01/10] incubator-beam git commit: Converts all easy OldDoFns to DoFn Thu, 15 Dec, 22:29
k...@apache.org [02/10] incubator-beam git commit: Pushes uses of OldDoFn deeper inside Flink runner Thu, 15 Dec, 22:29
k...@apache.org [03/10] incubator-beam git commit: Remove ParDo.of(OldDoFn) from Apex runner Thu, 15 Dec, 22:29
k...@apache.org [04/10] incubator-beam git commit: Removes code for wrapping DoFn as an OldDoFn Thu, 15 Dec, 22:29
k...@apache.org [05/10] incubator-beam git commit: Removes OldDoFn from ParDo Thu, 15 Dec, 22:29
k...@apache.org [06/10] incubator-beam git commit: Removes unused code from NoOpOldDoFn Thu, 15 Dec, 22:29
k...@apache.org [07/10] incubator-beam git commit: Removes ArgumentProvider.windowingInternals Thu, 15 Dec, 22:29
k...@apache.org [08/10] incubator-beam git commit: Moves DoFnAdapters to runners-core Thu, 15 Dec, 22:29
k...@apache.org [09/10] incubator-beam git commit: Renames ParDo.getNewFn to getFn Thu, 15 Dec, 22:29
k...@apache.org [10/10] incubator-beam git commit: This closes #1565 Thu, 15 Dec, 22:29
k...@apache.org [1/2] incubator-beam git commit: Remove deprecated methods of InMemoryTimerInternals Fri, 16 Dec, 03:01
k...@apache.org [2/2] incubator-beam git commit: This closes #1635 Fri, 16 Dec, 03:01
k...@apache.org [1/6] incubator-beam git commit: Upgrade Gearpump version Fri, 16 Dec, 21:18
k...@apache.org [2/6] incubator-beam git commit: Add Window.Bound translator Fri, 16 Dec, 21:18
k...@apache.org [3/6] incubator-beam git commit: Skip window assignment when windows don't change Fri, 16 Dec, 21:18
k...@apache.org [4/6] incubator-beam git commit: Remove print to stdout Fri, 16 Dec, 21:18
k...@apache.org [5/6] incubator-beam git commit: Fix NoOpAggregatorFactory Fri, 16 Dec, 21:18
k...@apache.org [6/6] incubator-beam git commit: This closes #1623: [BEAM-1086] Upgrade to latest Gearpump snapshot Fri, 16 Dec, 21:18
k...@apache.org [1/3] incubator-beam git commit: Delete deprecated TimerCallback Fri, 16 Dec, 21:46
k...@apache.org [2/3] incubator-beam git commit: Move InMemoryTimerInternals to runners-core Fri, 16 Dec, 21:46
k...@apache.org [3/3] incubator-beam git commit: This closes #1643: [BEAM-362] Move InMemoryTimerInternals to runners-core Fri, 16 Dec, 21:46
k...@apache.org [1/3] incubator-beam git commit: Update Dataflow worker to beam-master-20161216 Fri, 16 Dec, 22:13
k...@apache.org [2/3] incubator-beam git commit: Move ActiveWindowSet and implementations to runners-core Fri, 16 Dec, 22:13
k...@apache.org [3/3] incubator-beam git commit: This closes #1592 Fri, 16 Dec, 22:13
k...@apache.org [1/5] incubator-beam git commit: Revert "Move InMemoryTimerInternals to runners-core" Sat, 17 Dec, 03:45
k...@apache.org [2/5] incubator-beam git commit: Revert "Moves DoFnAdapters to runners-core" Sat, 17 Dec, 03:45
k...@apache.org [3/5] incubator-beam git commit: Revert "Removes code for wrapping DoFn as an OldDoFn" Sat, 17 Dec, 03:45
k...@apache.org [4/5] incubator-beam git commit: Revert "Removes ArgumentProvider.windowingInternals" Sat, 17 Dec, 03:45
k...@apache.org [5/5] incubator-beam git commit: This closes #1648: Undeletes DoFnInvokers.of(OldDoFn) Sat, 17 Dec, 03:45
k...@apache.org [1/2] incubator-beam git commit: [BEAM-853] Force streaming execution on batch pipelines for testing. Expose the adapted source. Sat, 17 Dec, 06:16
k...@apache.org [2/2] incubator-beam git commit: This closes #1614: Spark runner: Force streaming execution on batch pipelines for testing Sat, 17 Dec, 06:16
k...@apache.org [1/5] incubator-beam git commit: Make TimerSpec and StateSpec fields accessible Sat, 17 Dec, 21:11
k...@apache.org [2/5] incubator-beam git commit: Test that SimpleDoFnRunner wraps exceptions in startBundle and finishBundle Sat, 17 Dec, 21:11
k...@apache.org [3/5] incubator-beam git commit: Add timer support to DoFnRunner(s) Sat, 17 Dec, 21:11
k...@apache.org [4/5] incubator-beam git commit: Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest Sat, 17 Dec, 21:11
k...@apache.org [5/5] incubator-beam git commit: This closes #1612: [BEAM-27] Support timer setting and receiving in SimpleDoFnRunner Sat, 17 Dec, 21:11
k...@apache.org [1/3] incubator-beam git commit: [BEAM-85, BEAM-298] Make TestPipeline a JUnit Rule checking proper usage Sat, 17 Dec, 22:24
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 · 29 · 30 · 31 · 32 · 33 · 34 · Next »Thread · Author · Date
Box list
Jul 2019256
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