beam-commits mailing list archives: February 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 · 30 · Next »Thread · Author · Date
staslev [GitHub] beam pull request #1695: [BEAM-1215] Added an in memory Graphite server that... Tue, 28 Feb, 08:18
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1215) Assert over metrics sent to Graphite Tue, 28 Feb, 08:18
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-1517) Garbage collect user state in Flink Runner Tue, 28 Feb, 08:32
Robert Metzger (JIRA) [jira] [Commented] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list Tue, 28 Feb, 08:50
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1383 Tue, 28 Feb, 09:24
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-1116) Support for new Timer API in Flink runner Tue, 28 Feb, 10:05
aljos...@apache.org [1/2] beam git commit: [BEAM-1036] Support for new State API in Flink Batch Runner Tue, 28 Feb, 10:11
aljos...@apache.org [2/2] beam git commit: This closes #2114 Tue, 28 Feb, 10:11
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1036) Support for new State API in FlinkRunner Tue, 28 Feb, 10:11
asfgit [GitHub] beam pull request #2114: [BEAM-1036] Support for new State API in Flink Batc... Tue, 28 Feb, 10:11
Aljoscha Krettek (JIRA) [jira] [Closed] (BEAM-1036) Support for new State API in FlinkRunner Tue, 28 Feb, 10:12
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1384 Tue, 28 Feb, 10:39
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-1116) Support for new Timer API in Flink runner Tue, 28 Feb, 10:41
JingsongLi [GitHub] beam pull request #2126: [BEAM-1116] Support for new Timer API in Flink Batc... Tue, 28 Feb, 11:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1116) Support for new Timer API in Flink runner Tue, 28 Feb, 11:01
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results Tue, 28 Feb, 11:20
JingsongLi [GitHub] beam pull request #2127: [BEAM-1517] Garbage collect user state in Flink Run... Tue, 28 Feb, 11:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1517) Garbage collect user state in Flink Runner Tue, 28 Feb, 11:51
tom-haines [GitHub] beam pull request #2110: [BEAM-1558] add cloudera repository for flink runne... Tue, 28 Feb, 12:15
Tom Haines (JIRA) [jira] [Closed] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list Tue, 28 Feb, 12:15
Tom Haines (JIRA) [jira] [Commented] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list Tue, 28 Feb, 12:15
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list Tue, 28 Feb, 12:15
Amit Sela (JIRA) [jira] [Commented] (BEAM-1556) Spark executors need to register IO factories Tue, 28 Feb, 13:09
Apache Jenkins Server Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Dataflow #2427 Tue, 28 Feb, 13:28
peay (JIRA) [jira] [Created] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 13:58
Apache Jenkins Server Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1082 Tue, 28 Feb, 14:07
aljos...@apache.org [1/2] beam git commit: [BEAM-1116] Support for new Timer API in Flink Batch runner Tue, 28 Feb, 14:30
aljos...@apache.org [2/2] beam git commit: This closes #2126 Tue, 28 Feb, 14:30
asfgit [GitHub] beam pull request #2126: [BEAM-1116] Support for new Timer API in Flink Batc... Tue, 28 Feb, 14:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1116) Support for new Timer API in Flink runner Tue, 28 Feb, 14:30
Aljoscha Krettek (JIRA) [jira] [Closed] (BEAM-1116) Support for new Timer API in Flink runner Tue, 28 Feb, 14:31
Apache Jenkins Server Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1083 Tue, 28 Feb, 14:47
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1386 Tue, 28 Feb, 15:56
vikkyrk [GitHub] beam pull request #2128: Update output stream cython declaration Tue, 28 Feb, 16:00
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1387 Tue, 28 Feb, 17:11
Davor Bonaci (JIRA) [jira] [Commented] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 17:15
Davor Bonaci (JIRA) [jira] [Comment Edited] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 17:15
peay (JIRA) [jira] [Commented] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 17:17
Ted Yu (JIRA) [jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes() Tue, 28 Feb, 17:18
tg...@apache.org [1/2] beam git commit: Correct Apex translation of Single-input Flatten Tue, 28 Feb, 17:20
tg...@apache.org [2/2] beam git commit: This closes #2125 Tue, 28 Feb, 17:20
asfgit [GitHub] beam pull request #2125: [BEAM-1571] fix FlattenPCollectionList with single ... Tue, 28 Feb, 17:20
Aljoscha Krettek (JIRA) [jira] [Updated] (BEAM-1517) Garbage collect user state in Flink Runner Tue, 28 Feb, 17:21
Aljoscha Krettek (JIRA) [jira] [Updated] (BEAM-1517) Garbage collect user state in Flink Runner Tue, 28 Feb, 17:21
Aljoscha Krettek (JIRA) [jira] [Updated] (BEAM-1517) Garbage collect user state in Flink Runner Tue, 28 Feb, 17:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1571) Flatten on a single input PCollection should have a test associated with it Tue, 28 Feb, 17:21
Davor Bonaci (JIRA) [jira] [Commented] (BEAM-1556) Spark executors need to register IO factories Tue, 28 Feb, 17:28
Amit Sela (JIRA) [jira] [Commented] (BEAM-1556) Spark executors need to register IO factories Tue, 28 Feb, 17:32
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2774 Tue, 28 Feb, 18:03
al...@apache.org [1/2] beam git commit: Emit a warning when no SDK is provided. We set sdk_location to empty only in unit tests. Tue, 28 Feb, 18:04
al...@apache.org [2/2] beam git commit: This closes #2104 Tue, 28 Feb, 18:04
Neelesh Srinivas Salian (JIRA) [jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner Tue, 28 Feb, 18:04
Ted Yu (JIRA) [jira] [Created] (BEAM-1574) MongoDbIOTest fails due to inability to download mongodb tar ball Tue, 28 Feb, 18:28
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1388 Tue, 28 Feb, 18:37
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2775 Tue, 28 Feb, 18:42
asfgit [GitHub] beam pull request #2104: Emit a warning when no SDK is provided. We set sdk_... Tue, 28 Feb, 18:52
dhalperi [GitHub] beam pull request #2129: Upgrade Dataflow worker Tue, 28 Feb, 19:19
peay (JIRA) [jira] [Commented] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 19:24
peay (JIRA) [jira] [Comment Edited] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 19:25
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2776 Tue, 28 Feb, 19:32
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-1517) Garbage collect user state in Flink Runner Tue, 28 Feb, 19:36
Pablo Estrada (JIRA) [jira] [Assigned] (BEAM-1575) Add ValidatesRunner test to PipelineTest.test_metrics_in_source Tue, 28 Feb, 19:46
Pablo Estrada (JIRA) [jira] [Created] (BEAM-1575) Add ValidatesRunner test to PipelineTest.test_metrics_in_source Tue, 28 Feb, 19:46
Pablo Estrada (JIRA) [jira] [Assigned] (BEAM-1555) Python post commits failing Tue, 28 Feb, 19:46
Pablo Estrada (JIRA) [jira] [Assigned] (BEAM-1555) Python post commits failing Tue, 28 Feb, 19:46
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1389 Tue, 28 Feb, 20:07
peay (JIRA) [jira] [Comment Edited] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers Tue, 28 Feb, 21:20
dhalp...@apache.org [1/2] beam git commit: Upgrade dataflow worker Tue, 28 Feb, 21:50
dhalp...@apache.org [2/2] beam git commit: This closes #2129 Tue, 28 Feb, 21:50
asfgit [GitHub] beam pull request #2129: Upgrade Dataflow worker Tue, 28 Feb, 21:50
Apache Jenkins Server Build failed in Jenkins: beam_PostCommit_Python_Verify #1390 Tue, 28 Feb, 22:15
Apache Jenkins Server Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2777 Tue, 28 Feb, 22:28
amits...@apache.org [01/23] beam git commit: Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner. Tue, 28 Feb, 22:35
amits...@apache.org [02/23] beam git commit: Better name for batch implementation of GroupAlsoByWindow. Tue, 28 Feb, 22:35
amits...@apache.org [03/23] beam git commit: Handle test failures in "graceful stop peroid". Tue, 28 Feb, 22:35
amits...@apache.org [04/23] beam git commit: Use TestSparkRunner in tests. Tue, 28 Feb, 22:35
amits...@apache.org [05/23] beam git commit: Refactor translators according to new GroupAlsoByWindow implemenation for the Spark runnner. Tue, 28 Feb, 22:35
amits...@apache.org [06/23] beam git commit: Utils for SparkGroupAlsoByWindowViaWindowSet. Tue, 28 Feb, 22:35
amits...@apache.org [07/23] beam git commit: Remove streaming tests that were needed before supporting the model. Tue, 28 Feb, 22:35
amits...@apache.org [08/23] beam git commit: Test triggers, panes and watermarks via CreateStream. Tue, 28 Feb, 22:35
amits...@apache.org [09/23] beam git commit: Fix streaming translation of Flatten and Window, make CreateStream eager. Tue, 28 Feb, 22:35
amits...@apache.org [10/23] beam git commit: Serialize state stream with coders for shuffle and checkpointing. Tue, 28 Feb, 22:35
amits...@apache.org [11/23] beam git commit: Add multi stream and flattened stream tests. Tue, 28 Feb, 22:35
amits...@apache.org [12/23] beam git commit: Make TimestampTransform Serializable. Tue, 28 Feb, 22:35
amits...@apache.org [13/23] beam git commit: Fix runnable-on-service profile in the Spark runner. Tue, 28 Feb, 22:35
amits...@apache.org [14/23] beam git commit: Batch executions should block without timeout. Tue, 28 Feb, 22:35
amits...@apache.org [15/23] beam git commit: Tests that can should run with TestSparkRunner. Tue, 28 Feb, 22:35
amits...@apache.org [16/23] beam git commit: Batch doesn't use checkpoint dir so nothing to clean. Tue, 28 Feb, 22:35
amits...@apache.org [17/23] beam git commit: Build trigger state machine from Runner API Trigger proto directly Tue, 28 Feb, 22:35
amits...@apache.org [18/23] beam git commit: Use a PipelineRule for test pipelines. Tue, 28 Feb, 22:35
amits...@apache.org [19/23] beam git commit: Move LateDataUtils and UnsupportedSideInputReader to runners-core. Tue, 28 Feb, 22:35
amits...@apache.org [20/23] beam git commit: Make CreateStream a TimestampedValue Source. Tue, 28 Feb, 22:35
amits...@apache.org [21/23] beam git commit: Spark GABWVOB to use UnsupportedSideInputReader. Tue, 28 Feb, 22:35
amits...@apache.org [22/23] beam git commit: Streaming tests, especially the ones using checkpoints, need a time buffer to finish. Tue, 28 Feb, 22:35
amits...@apache.org [23/23] beam git commit: This closes #2050 Tue, 28 Feb, 22:35
asfgit [GitHub] beam pull request #2050: [BEAM-920] Support triggers, panes and watermarks. Tue, 28 Feb, 22:35
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-920) Support triggers, panes and watermarks. Tue, 28 Feb, 22:35
Amit Sela (JIRA) [jira] [Resolved] (BEAM-920) Support triggers, panes and watermarks. Tue, 28 Feb, 22:39
rober...@apache.org [1/2] beam git commit: Closes #2124 Tue, 28 Feb, 22:40
rober...@apache.org [2/2] beam git commit: Make side inputs a map, rather than embedding the name in the message. Tue, 28 Feb, 22:40
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 · Next »Thread · Author · Date
Box list
Sep 2019212
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