beam-commits mailing list archives: June 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 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · Next »Thread · Author · Date
k...@apache.org [08/50] [abbrv] beam git commit: Remove support for NativeSinks from the Python DirectRunner Mon, 12 Jun, 16:55
k...@apache.org [09/50] [abbrv] beam git commit: This closes #3321 Mon, 12 Jun, 16:55
k...@apache.org [10/50] [abbrv] beam git commit: Make BytesCoder to be a known type Mon, 12 Jun, 16:55
k...@apache.org [11/50] [abbrv] beam git commit: [BEAM-1226] Make BytesCoder to be a known type Mon, 12 Jun, 16:55
k...@apache.org [12/50] [abbrv] beam git commit: Closes #3317 Mon, 12 Jun, 16:55
k...@apache.org [13/50] [abbrv] beam git commit: Add coder info to pubsub io Mon, 12 Jun, 16:55
k...@apache.org [14/50] [abbrv] beam git commit: This closes #3303 Mon, 12 Jun, 16:55
k...@apache.org [15/50] [abbrv] beam git commit: Expand all PValues to component PCollections always Mon, 12 Jun, 16:55
k...@apache.org [16/50] [abbrv] beam git commit: Expand all PValues to component PCollections always Mon, 12 Jun, 16:55
k...@apache.org [17/50] [abbrv] beam git commit: Avoid flakiness in data channel for empty streams. Mon, 12 Jun, 16:55
k...@apache.org [18/50] [abbrv] beam git commit: Avoid flakiness in data channel for empty streams. Mon, 12 Jun, 16:55
k...@apache.org [19/50] [abbrv] beam git commit: Refine Python DirectRunner watermark advancement behavior Mon, 12 Jun, 16:55
k...@apache.org [20/50] [abbrv] beam git commit: This closes #3322 Mon, 12 Jun, 16:55
k...@apache.org [21/50] [abbrv] beam git commit: Raise entity limit per RPC to 9MB. Mon, 12 Jun, 16:55
k...@apache.org [22/50] [abbrv] beam git commit: This closes #3302 Mon, 12 Jun, 16:55
k...@apache.org [23/50] [abbrv] beam git commit: DirectRunner override matchers using Runner API Mon, 12 Jun, 16:55
k...@apache.org [24/50] [abbrv] beam git commit: Add Runner API oriented PTransformMatchers for DirectRunner overrides Mon, 12 Jun, 16:55
k...@apache.org [25/50] [abbrv] beam git commit: This closes #3239: [BEAM-2371] Port DirectRunner override matchers to language-agnostic construction APIs Mon, 12 Jun, 16:55
k...@apache.org [26/50] [abbrv] beam git commit: Use inner module for non-public coders. Mon, 12 Jun, 16:55
k...@apache.org [27/50] [abbrv] beam git commit: Closes #3325 Mon, 12 Jun, 16:55
k...@apache.org [28/50] [abbrv] beam git commit: Implements HCatalogIO Mon, 12 Jun, 16:55
k...@apache.org [29/50] [abbrv] beam git commit: This closes #3220: Implements HCatalogIO Mon, 12 Jun, 16:55
k...@apache.org [30/50] [abbrv] beam git commit: Slight debuggability improvements in BigtableIO Mon, 12 Jun, 16:55
k...@apache.org [31/50] [abbrv] beam git commit: This closes #3331: Slight debuggability improvements in BigtableIO Mon, 12 Jun, 16:55
k...@apache.org [32/50] [abbrv] beam git commit: Move Runner API protos to portability/runners/api Mon, 12 Jun, 16:55
k...@apache.org [33/50] [abbrv] beam git commit: This closes #3315 Mon, 12 Jun, 16:55
k...@apache.org [34/50] [abbrv] beam git commit: [BEAM-2410] Remove TransportClient from ElasticSearchIO to decouple IO and ES server versions Mon, 12 Jun, 16:55
k...@apache.org [35/50] [abbrv] beam git commit: [BEAM-2410] This closes #3328 Mon, 12 Jun, 16:55
k...@apache.org [36/50] [abbrv] beam git commit: Fix compile error occurs in some JDKs Mon, 12 Jun, 16:55
k...@apache.org [37/50] [abbrv] beam git commit: This closes #3320 Mon, 12 Jun, 16:55
k...@apache.org [38/50] [abbrv] beam git commit: Use beam.Map rather than beam.ParDo for PubSub encoding. Mon, 12 Jun, 16:55
k...@apache.org [39/50] [abbrv] beam git commit: Closes #3332 Mon, 12 Jun, 16:55
k...@apache.org [40/50] [abbrv] beam git commit: This closes #3329 Mon, 12 Jun, 16:55
k...@apache.org [41/50] [abbrv] beam git commit: Visit a Transform Hierarchy in Topological Order Mon, 12 Jun, 16:55
k...@apache.org [42/50] [abbrv] beam git commit: Roll-forward Include Additional PTransform inputs in Transform Nodes Mon, 12 Jun, 16:55
k...@apache.org [43/50] [abbrv] beam git commit: This closes #3337: Include Additional PTransform Inputs in Transform Nodes Mon, 12 Jun, 16:55
k...@apache.org [44/50] [abbrv] beam git commit: Port ViewOverrideFactory to SDK-agnostic APIs Mon, 12 Jun, 16:55
k...@apache.org [45/50] [abbrv] beam git commit: Port DirectGroupByKey to SDK-agnostic APIs Mon, 12 Jun, 16:56
k...@apache.org [46/50] [abbrv] beam git commit: Port DirectRunner WriteFiles override to SDK-agnostic APIs Mon, 12 Jun, 16:56
k...@apache.org [47/50] [abbrv] beam git commit: Port DirectRunner TestStream override to SDK-agnostic APIs Mon, 12 Jun, 16:56
k...@apache.org [48/50] [abbrv] beam git commit: This closes #3338: [BEAM-2371] Port some DirectRunner overrides to SDK-agnostic APIs Mon, 12 Jun, 16:56
k...@apache.org [49/50] [abbrv] beam git commit: Fix side input handling in DoFnFunction Mon, 12 Jun, 16:56
k...@apache.org [50/50] [abbrv] beam git commit: This closes #3292: Merge master into gearpump-runner Mon, 12 Jun, 16:56
k...@apache.org [1/2] beam git commit: Check for Deferral on Non-additional inputs Tue, 13 Jun, 03:21
k...@apache.org [2/2] beam git commit: This closes #3347: Check for Deferral on Non-additional inputs Tue, 13 Jun, 03:21
k...@apache.org [1/2] beam git commit: Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override Thu, 15 Jun, 23:52
k...@apache.org [2/2] beam git commit: This closes #3352: Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override Thu, 15 Jun, 23:52
k...@apache.org [1/2] beam git commit: Remove notifications from JDK versions test. Tue, 20 Jun, 19:39
k...@apache.org [2/2] beam git commit: This closes #3403: Remove notifications from JDK versions test. Tue, 20 Jun, 19:39
k...@apache.org [1/2] beam git commit: Turn notifications for broken Windows test off. Wed, 21 Jun, 17:11
k...@apache.org [2/2] beam git commit: This closes #3413: Turn notifications for broken Windows test off. Wed, 21 Jun, 17:11
k...@apache.org [1/2] beam git commit: DataflowRunner: Reject SetState and MapState Thu, 22 Jun, 21:04
k...@apache.org [2/2] beam git commit: This closes #3420: DataflowRunner: Reject SetState and MapState Thu, 22 Jun, 21:04
k...@apache.org [1/9] beam git commit: Add tests for corner cases of processing time timers Thu, 22 Jun, 23:03
k...@apache.org [2/9] beam git commit: Add test reproducing BEAM-2505, ignored Thu, 22 Jun, 23:03
k...@apache.org [3/9] beam git commit: ReduceFnTester can advance clocks without firing timers Thu, 22 Jun, 23:03
k...@apache.org [4/9] beam git commit: Add window matcher for pane info Thu, 22 Jun, 23:03
k...@apache.org [5/9] beam git commit: ReduceFnTester assertion for windows that have data buffered Thu, 22 Jun, 23:03
k...@apache.org [6/9] beam git commit: Do not GC windows based on processing time timer! Thu, 22 Jun, 23:03
k...@apache.org [7/9] beam git commit: Tidy LateDataDroppingDoFnRunner Thu, 22 Jun, 23:03
k...@apache.org [8/9] beam git commit: Drop late data in ReduceFnTester Thu, 22 Jun, 23:04
k...@apache.org [9/9] beam git commit: This closes #3425: Fix processing time timer handling in ReduceFnRunner Thu, 22 Jun, 23:04
k...@apache.org [01/50] beam git commit: Return a valid Coder for any subtype of Mutation on HBaseCoderProviderRegistrar Fri, 23 Jun, 03:04
k...@apache.org [02/50] beam git commit: This closes #3407 Fri, 23 Jun, 03:04
k...@apache.org [03/50] beam git commit: [BEAM-2481] Update commons-lang3 dependency to version 3.6 Fri, 23 Jun, 03:04
k...@apache.org [04/50] beam git commit: [BEAM-2481] This closes #3401 Fri, 23 Jun, 03:04
k...@apache.org [05/50] beam git commit: Use state / timer API for DirectRunner timer firings Fri, 23 Jun, 03:04
k...@apache.org [06/50] beam git commit: This closes #3405 Fri, 23 Jun, 03:04
k...@apache.org [07/50] beam git commit: Turn notifications for broken Windows test off. Fri, 23 Jun, 03:04
k...@apache.org [08/50] beam git commit: This closes #3413: Turn notifications for broken Windows test off. Fri, 23 Jun, 03:04
k...@apache.org [09/50] beam git commit: Fix minor issues on HCatalogIO Fri, 23 Jun, 03:04
k...@apache.org [10/50] beam git commit: This closes #3412 Fri, 23 Jun, 03:04
k...@apache.org [11/50] beam git commit: Allow production of unprocessed bundles, introduce TestStream evaluator in DirectRunner Fri, 23 Jun, 03:04
k...@apache.org [12/50] beam git commit: This closes #3409 Fri, 23 Jun, 03:04
k...@apache.org [13/50] beam git commit: Remove GroupedShuffleRangeTracker which is unused in the SDK Fri, 23 Jun, 03:04
k...@apache.org [14/50] beam git commit: This closes #3414 Fri, 23 Jun, 03:04
k...@apache.org [15/50] beam git commit: ReduceFnRunner.onTrigger: skip storeCurrentPaneInfo() if trigger isFinished. Fri, 23 Jun, 03:04
k...@apache.org [16/50] beam git commit: This closes #3235 Fri, 23 Jun, 03:04
k...@apache.org [17/50] beam git commit: [BEAM-2495] Add Python test dependency six>=1.9 Fri, 23 Jun, 03:04
k...@apache.org [18/50] beam git commit: This closes #3416 Fri, 23 Jun, 03:04
k...@apache.org [19/50] beam git commit: Add example for Bigquery streaming sink Fri, 23 Jun, 03:04
k...@apache.org [20/50] beam git commit: This closes #3399 Fri, 23 Jun, 03:04
k...@apache.org [21/50] beam git commit: [BEAM-2359] Fix watermark broadcasting to executors in Spark runner Fri, 23 Jun, 03:04
k...@apache.org [22/50] beam git commit: Move Spark runner streaming tests to post commit. Fri, 23 Jun, 03:04
k...@apache.org [23/50] beam git commit: This closes #3343 Fri, 23 Jun, 03:04
k...@apache.org [24/50] beam git commit: [BEAM-1585] Fix the beam plugins installation Fri, 23 Jun, 03:04
k...@apache.org [25/50] beam git commit: This closes #3421 Fri, 23 Jun, 03:04
k...@apache.org [26/50] beam git commit: Java Dataflow runner harness compatibility. Fri, 23 Jun, 03:04
k...@apache.org [27/50] beam git commit: Closes #3418 Fri, 23 Jun, 03:04
k...@apache.org [28/50] beam git commit: Clean up test_stream_test and remove stray print statement Fri, 23 Jun, 03:04
k...@apache.org [29/50] beam git commit: This closes #3423 Fri, 23 Jun, 03:04
k...@apache.org [30/50] beam git commit: [BEAM-2439] Dynamic sizing of Datastore write RPCs Fri, 23 Jun, 03:04
k...@apache.org [31/50] beam git commit: [BEAM-2439] Dynamic sizing of Datastore write RPCs Fri, 23 Jun, 03:04
k...@apache.org [32/50] beam git commit: DataflowRunner: Reject SetState and MapState Fri, 23 Jun, 03:04
k...@apache.org [33/50] beam git commit: This closes #3420: DataflowRunner: Reject SetState and MapState Fri, 23 Jun, 03:04
k...@apache.org [34/50] beam git commit: ReduceFnTester can advance clocks without firing timers Fri, 23 Jun, 03:05
k...@apache.org [35/50] beam git commit: ReduceFnTester assertion for windows that have data buffered Fri, 23 Jun, 03:05
k...@apache.org [36/50] beam git commit: Drop late data in ReduceFnTester Fri, 23 Jun, 03:05
k...@apache.org [37/50] beam git commit: Do not GC windows based on processing time timer! Fri, 23 Jun, 03:05
k...@apache.org [38/50] beam git commit: Add window matcher for pane info Fri, 23 Jun, 03:05
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 · Next »Thread · Author · Date
Box list
Sep 2020274
Aug 2020345
Jul 2020398
Jun 2020328
May 2020369
Apr 2020435
Mar 20203566
Feb 2020812
Jan 2020365
Dec 2019281
Nov 2019299
Oct 2019545
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