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
p..@apache.org [1/3] beam git commit: Flink runner: specify checkpointTimeout through PipelineOptions. Sun, 04 Jun, 08:19
p..@apache.org [2/3] beam git commit: Flink runner: specify CheckpointingMode through PipelineOptions. Sun, 04 Jun, 08:19
p..@apache.org [3/3] beam git commit: This closes #3245 Sun, 04 Jun, 08:19
p..@apache.org [1/2] beam git commit: Flink runner: support MapState in FlinkStateInternals. Tue, 06 Jun, 15:20
p..@apache.org [2/2] beam git commit: This closes #3289 Tue, 06 Jun, 15:20
p..@apache.org [1/3] beam git commit: Flink runner: refactor the translator into two phases: rewriting and translating. Tue, 20 Jun, 21:13
p..@apache.org [2/3] beam git commit: FlinkRunner: remove the unused ReflectiveOneToOneOverrideFactory. Tue, 20 Jun, 21:13
p..@apache.org [3/3] beam git commit: This closes #3275 Tue, 20 Jun, 21:13
p..@apache.org [1/2] beam git commit: ReduceFnRunner.onTrigger: skip storeCurrentPaneInfo() if trigger isFinished. Wed, 21 Jun, 21:57
p..@apache.org [2/2] beam git commit: This closes #3235 Wed, 21 Jun, 21:57
p..@apache.org [1/3] beam git commit: ReduceFnRunner.onTrigger: add short circuit for empty pane, and move inputWM and pane after the short circuit. Thu, 29 Jun, 06:04
p..@apache.org [2/3] beam git commit: WindowingStrategy: add OnTimeBehavior to control whether to emit empty ON_TIME pane. Thu, 29 Jun, 06:04
p..@apache.org [3/3] beam git commit: This closes #3446 Thu, 29 Jun, 06:04
peihe [GitHub] beam pull request #3275: Flink runner: refactor the translator into two phas... Thu, 01 Jun, 07:33
peihe [GitHub] beam pull request #3276: Flink runner: support per transform parallelism thr... Thu, 01 Jun, 07:47
peihe [GitHub] beam pull request #3289: Flink runner: support MapState in FlinkStateInterna... Sun, 04 Jun, 09:05
peihe [GitHub] beam pull request #3446: [BEAM-210] WindowingStrategy: add OnTimeBehavior to... Tue, 27 Jun, 03:14
peihe [GitHub] beam pull request #2823: Add JStormPipelineTranslator, TransformTranslator a... Wed, 28 Jun, 08:36
rangadi [GitHub] beam pull request #3461: [BEAM-2534] Handle offset gaps in Kafka messages. Wed, 28 Jun, 19:34
reuvenlax [GitHub] beam pull request #3293: [BEAM-2406] Fix NullPointerException when writing a... Mon, 05 Jun, 05:20
reuvenlax [GitHub] beam pull request #3356: [BEAM-92] Allow value-dependent files in FileBasedS... Wed, 14 Jun, 04:05
rfevang [GitHub] beam pull request #3367: [BEAM-1282] Support @FinishBundle output in DoFnTes... Thu, 15 Jun, 13:10
robertwb [GitHub] beam pull request #3308: Fix imports in sdk_worker. Tue, 06 Jun, 22:15
robertwb [GitHub] beam pull request #3324: Avoid flakiness in data channel for empty streams. Thu, 08 Jun, 06:02
robertwb [GitHub] beam pull request #3325: Use inner module for non-public coders. Thu, 08 Jun, 06:35
robertwb [GitHub] beam pull request #3332: Use beam.Map rather than beam.ParDo for PubSub enco... Thu, 08 Jun, 22:03
robertwb [GitHub] beam pull request #3339: Actually test the fn_api_runner. Fri, 09 Jun, 23:48
robertwb [GitHub] beam pull request #3361: [BEAM-115] Port fn_api_runner to be able to use run... Wed, 14 Jun, 22:04
robertwb [GitHub] beam pull request #3418: Java Dataflow runner harness compatibility. Thu, 22 Jun, 01:11
robertwb [GitHub] beam pull request #3424: Cleanup old uses of Fn API protos. Thu, 22 Jun, 19:48
robertwb [GitHub] beam pull request #3433: Avoid pickling the entire pipeline per-transform. Fri, 23 Jun, 22:02
robertwb [GitHub] beam pull request #3449: Use input name as output name for Fn API sink. Tue, 27 Jun, 07:10
robertwb [GitHub] beam pull request #3449: Use input name as output name for Fn API sink. Tue, 27 Jun, 16:59
robertwb [GitHub] beam pull request #3466: Visit composite nodes when checking for picklabilit... Wed, 28 Jun, 23:35
rober...@apache.org [1/5] beam git commit: Unify Java and Python WindowingStrategy representations. Fri, 02 Jun, 16:17
rober...@apache.org [2/5] beam git commit: Ignore all proto generated files. Fri, 02 Jun, 16:17
rober...@apache.org [3/5] beam git commit: Increase dataflow worker version. Fri, 02 Jun, 16:17
rober...@apache.org [4/5] beam git commit: Closes #3222 Fri, 02 Jun, 16:17
rober...@apache.org [5/5] beam git commit: Add known window serialization for Java. Fri, 02 Jun, 16:17
rober...@apache.org [1/2] beam git commit: Closes #3317 Thu, 08 Jun, 05:55
rober...@apache.org [2/2] beam git commit: Add coder info to pubsub io Thu, 08 Jun, 05:55
rober...@apache.org [1/2] beam git commit: Closes #3325 Thu, 08 Jun, 20:58
rober...@apache.org [2/2] beam git commit: Use inner module for non-public coders. Thu, 08 Jun, 20:58
rober...@apache.org [1/2] beam git commit: Closes #3332 Fri, 09 Jun, 20:01
rober...@apache.org [2/2] beam git commit: Use beam.Map rather than beam.ParDo for PubSub encoding. Fri, 09 Jun, 20:01
rober...@apache.org [1/2] beam git commit: Closes #3339 Tue, 13 Jun, 15:57
rober...@apache.org [2/2] beam git commit: Actually test the fn_api_runner. Tue, 13 Jun, 15:57
rober...@apache.org [1/2] beam git commit: Move Runner API protos to portability/api Tue, 13 Jun, 23:25
rober...@apache.org [2/2] beam git commit: Closes #3354 Tue, 13 Jun, 23:25
rober...@apache.org [1/2] beam git commit: Closes #3359 Thu, 15 Jun, 01:19
rober...@apache.org [2/2] beam git commit: [BEAM-1585] Add beam plugins as pipeline options Thu, 15 Jun, 01:19
rober...@apache.org [1/2] beam git commit: Populate PBegin input when decoding from Runner API Fri, 16 Jun, 20:54
rober...@apache.org [2/2] beam git commit: Closes #3373 Fri, 16 Jun, 20:54
rober...@apache.org [1/2] beam git commit: Closes #3385 Mon, 19 Jun, 18:01
rober...@apache.org [2/2] beam git commit: Add dry run option to DataflowRunner Mon, 19 Jun, 18:01
rober...@apache.org [1/2] beam git commit: Port fn_api_runner to be able to use runner protos. Tue, 20 Jun, 20:47
rober...@apache.org [2/2] beam git commit: Closes #3361 Tue, 20 Jun, 20:47
rober...@apache.org [1/2] beam git commit: None should be a valid return element Wed, 21 Jun, 03:34
rober...@apache.org [2/2] beam git commit: Closes #3408 Wed, 21 Jun, 03:34
rober...@apache.org [1/2] beam git commit: Closes #3418 Thu, 22 Jun, 19:34
rober...@apache.org [2/2] beam git commit: Java Dataflow runner harness compatibility. Thu, 22 Jun, 19:34
rober...@apache.org [1/3] beam git commit: Closes #3424 Fri, 23 Jun, 00:07
rober...@apache.org [2/3] beam git commit: Remove unused (and untested) initial splittling logic. Fri, 23 Jun, 00:07
rober...@apache.org [3/3] beam git commit: Remove fn api bundle descriptor translation. Fri, 23 Jun, 00:07
rober...@apache.org [1/2] beam git commit: Avoid pickling the entire pipeline per-transform. Fri, 23 Jun, 23:40
rober...@apache.org [2/2] beam git commit: Closes #3433 Fri, 23 Jun, 23:40
rober...@apache.org [1/2] beam git commit: Closes #3466 Thu, 29 Jun, 00:58
rober...@apache.org [2/2] beam git commit: Visit composite nodes when checking for picklability. Thu, 29 Jun, 00:58
sb2nov [GitHub] beam pull request #3273: [BEAM-1585] Add ability to attach a bootstrap scrip... Thu, 01 Jun, 00:59
sb2nov [GitHub] beam pull request #3288: [BEAM-2405] Write to BQ using the streaming API Fri, 02 Jun, 23:16
sb2nov [GitHub] beam pull request #3300: Fix the staging directory path in copying from GCS Tue, 06 Jun, 00:20
sb2nov [GitHub] beam pull request #3304: Whitelist find for tox environments Tue, 06 Jun, 19:01
sb2nov [GitHub] beam pull request #3306: [BEAM-2405] Override to sink interface in batch dat... Tue, 06 Jun, 21:53
sb2nov [GitHub] beam pull request #3359: [BEAM-1585] Add beam plugins as pipeline options Wed, 14 Jun, 21:30
sb2nov [GitHub] beam pull request #3273: [BEAM-1585] Add ability to attach a bootstrap scrip... Wed, 14 Jun, 21:31
sb2nov [GitHub] beam pull request #3408: None should be a valid return element Tue, 20 Jun, 23:42
sb2nov [GitHub] beam pull request #3421: [BEAM-1585] Fix the beam plugins installation Thu, 22 Jun, 07:06
sb2nov [GitHub] beam pull request #3428: [BEAM-2497] Fix the reading of concat gzip files Fri, 23 Jun, 00:05
sb2nov [GitHub] beam-site pull request #261: [BEAM-2437] Input path should be flexible in qu... Mon, 26 Jun, 18:01
sb2nov [GitHub] beam pull request #3441: [BEAM-2271] Add more files to mvn clean Mon, 26 Jun, 21:07
sberyozkin [GitHub] beam pull request #3378: [BEAM-2328] Add TikaIO component Fri, 16 Jun, 12:39
seshadri-cr [GitHub] beam pull request #3158: [BEAM-1158]HCatalog integration test for HadoopInpu... Thu, 01 Jun, 18:42
seshadri-cr [GitHub] beam-site pull request #258: [BEAM-2471]EMR DynamoDB example using HadoopIpu... Fri, 23 Jun, 16:47
ssisk [GitHub] beam pull request #3382: [BEAM-2458] Move HashingFn from test -> main Fri, 16 Jun, 21:46
ssisk [GitHub] beam pull request #3382: [BEAM-2458] Move HashingFn from test -> main Mon, 19 Jun, 16:42
ssisk [GitHub] beam pull request #3464: [BEAM-2533] Upgrade beam bigtable client dependency... Wed, 28 Jun, 22:42
ssisk [GitHub] beam pull request #3465: [BEAM-2537] GCP IO ITs now all use --project option Wed, 28 Jun, 22:44
ssisk [GitHub] beam pull request #3484: [BEAM-2545] Upgrade bigtable client to 1.0.0-pre1 Fri, 30 Jun, 22:50
takidau [GitHub] beam pull request #3376: [BEAM-2454] Remove unused BeamPipelineCreator class Fri, 16 Jun, 01:28
takidau [GitHub] beam pull request #3384: [BEAM-2459] Remove UnsupportedOperationVisitor, whi... Fri, 16 Jun, 23:22
takidau [GitHub] beam pull request #3384: [BEAM-2459] Remove UnsupportedOperationVisitor, whi... Sat, 17 Jun, 03:17
taki...@apache.org [1/2] beam git commit: Add ROUND function on DSL_SQL branch. Tue, 13 Jun, 18:51
taki...@apache.org [2/2] beam git commit: [BEAM-2383] This closes #3326 Tue, 13 Jun, 18:51
taki...@apache.org [1/2] beam git commit: Add NOT operator on DSL_SQL branch (plus some refactoring) Wed, 14 Jun, 16:56
taki...@apache.org [2/2] beam git commit: [BEAM-2356] This closes #3218 Wed, 14 Jun, 16:56
taki...@apache.org [1/2] beam git commit: [BEAM-2444] BeamSql: use java standard exception Thu, 15 Jun, 21:22
taki...@apache.org [2/2] beam git commit: [BEAM-2444] This closes #3365 Thu, 15 Jun, 21:22
taki...@apache.org [1/2] beam git commit: [BEAM-2442] BeamSql surface api test. Fri, 16 Jun, 00:43
taki...@apache.org [2/2] beam git commit: [BEAM-2442] This closes #3357 Fri, 16 Jun, 00:43
taki...@apache.org [1/2] beam git commit: [BEAM-2440] BeamSql: reduce visibility Fri, 16 Jun, 01:49
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
Feb 2020169
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