beam-commits mailing list archives: May 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 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · Next »Thread · Author · Date
Jason Kuster (JIRA) [jira] [Created] (BEAM-2273) mvn clean doesn't fully clean up archetypes. Thu, 11 May, 23:53
Jason Kuster (JIRA) [jira] [Created] (BEAM-2344) Re-rename fat jar in archetypes Tue, 23 May, 00:52
Jason Kuster (JIRA) [jira] [Created] (BEAM-2345) Version configuration of plugins / dependencies in root pom.xml is inconsistent Tue, 23 May, 01:38
Jean-Christophe Rodrigue (JIRA) [jira] [Created] (BEAM-2332) beam.io.BigQuerySink Python SDK does not support WRITE_TRUNCATE write disposition when specifying table with partition decorator Fri, 19 May, 18:45
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner Tue, 02 May, 02:51
Jingsong Lee (JIRA) [jira] [Updated] (BEAM-1641) Support synchronized processing time in Flink runner Tue, 02 May, 05:25
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-1035) Support for new State API in SparkRunner Tue, 02 May, 08:17
Jingsong Lee (JIRA) [jira] [Assigned] (BEAM-1612) Support real Bundle in Flink runner Tue, 02 May, 13:35
Jingsong Lee (JIRA) [jira] [Assigned] (BEAM-1483) Support SetState in Flink runner Tue, 02 May, 13:35
Jingsong Lee (JIRA) [jira] [Assigned] (BEAM-1476) Support MapState in Flink runner Tue, 02 May, 13:35
Jingsong Lee (JIRA) [jira] [Assigned] (BEAM-1498) Use Flink-native side outputs Tue, 02 May, 13:35
Jingsong Lee (JIRA) [jira] [Assigned] (BEAM-1587) Use StringBuilder to stringKey of StateNamespace instead of String.format Tue, 02 May, 13:37
Jingsong Lee (JIRA) [jira] [Assigned] (BEAM-1588) Reuse StateNamespace.stringKey in Flink States Tue, 02 May, 13:38
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner Thu, 04 May, 11:56
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-2140) Fix SplittableDoFn ValidatesRunner tests in FlinkRunner Tue, 09 May, 05:08
Jingsong Lee (JIRA) [jira] [Commented] (BEAM-2140) Fix SplittableDoFn ValidatesRunner tests in FlinkRunner Tue, 09 May, 16:43
Jingsong Lee (JIRA) [jira] [Created] (BEAM-2248) KafkaIO support to use start read time to set start offset Wed, 10 May, 11:45
Jingsong Lee (JIRA) [jira] [Closed] (BEAM-2248) KafkaIO support to use start read time to set start offset Wed, 31 May, 01:55
Jingsong Lee (JIRA) [jira] [Created] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode Wed, 31 May, 08:50
JingsongLi [GitHub] beam pull request #2853: [BEAM-1035][BEAM-1115] Support for new State and Ti... Wed, 03 May, 05:24
JingsongLi [GitHub] beam pull request #2856: [BEAM-1941] Add Source Watermark Metrics Wed, 03 May, 08:04
JingsongLi [GitHub] beam pull request #2853: [BEAM-1035][BEAM-1115] Support for new State and Ti... Fri, 05 May, 17:07
JingsongLi [GitHub] beam pull request #2917: [BEAM-2175] [BEAM-1115] Support for new State and T... Fri, 05 May, 17:19
JingsongLi [GitHub] beam pull request #3044: [BEAM-2248] KafkaIO support to use start read time ... Wed, 10 May, 11:55
Josh Di Fabio (JIRA) [jira] [Created] (BEAM-2229) GcsFileSystem can create invalid Metadata Tue, 09 May, 13:33
Josh Di Fabio (JIRA) [jira] [Updated] (BEAM-2229) GcsFileSystem attempts to create invalid Metadata Tue, 09 May, 13:35
Josh Forman-Gornall (JIRA) [jira] [Commented] (BEAM-1946) Add IO module for restful api Thu, 04 May, 18:32
Joshua Fox (JIRA) [jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches Fri, 05 May, 11:31
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2128) PostCommit Java_MavenInstall broken Mon, 01 May, 00:09
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-2049) Remove KeyedCombineFn Mon, 01 May, 02:27
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-2120) DataflowPipelineJob processes all log messages with each waitUntilFinish Mon, 01 May, 04:26
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-1970) Cannot run UserScore on Flink runner due to AvroCoder classload issues Mon, 01 May, 16:49
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-2021) Fix Java's Coder class hierarchy Mon, 01 May, 17:43
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2021) Fix Java's Coder class hierarchy Mon, 01 May, 17:43
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception Mon, 01 May, 18:18
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-720) Run WindowedWordCount Integration Test in Flink Mon, 01 May, 18:31
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-2120) DataflowPipelineJob processes all log messages with each waitUntilFinish Mon, 01 May, 18:58
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-831) ParDo Chaining Mon, 01 May, 19:23
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-831) ParDo Chaining Mon, 01 May, 19:23
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-1327) Replace OutputTimeFn with enum Mon, 01 May, 23:03
Kenneth Knowles (JIRA) [jira] [Comment Edited] (BEAM-1327) Replace OutputTimeFn with enum Mon, 01 May, 23:10
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-2136) AvroCoderTest.testTwoClassLoaders fails on beam_PostCommit_Java_ValidatesRunner_Dataflow Tue, 02 May, 02:49
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2136) AvroCoderTest.testTwoClassLoaders fails on beam_PostCommit_Java_ValidatesRunner_Dataflow Tue, 02 May, 02:50
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-2136) AvroCoderTest.testTwoClassLoaders fails on beam_PostCommit_Java_ValidatesRunner_Dataflow Tue, 02 May, 04:53
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-1641) Support synchronized processing time in Flink runner Tue, 02 May, 16:04
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-1336) A StateSpec that doesn't care about the key shouldn't be forced to declare it as type Object Tue, 02 May, 19:00
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-1641) Implement real synchronized processing time in Flink runner Tue, 02 May, 19:02
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-1641) Implement real synchronized processing time in Flink runner Tue, 02 May, 19:02
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-1641) Implement real synchronized processing time in Flink runner Tue, 02 May, 19:03
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-818) Remove Pipeline.getPipelineOptions Tue, 02 May, 20:24
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-818) ValueProvider for tempLocation, runner, etc, that is unavailable to transforms during construction Tue, 02 May, 20:25
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-40) Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate) Tue, 02 May, 20:32
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-40) Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate) Tue, 02 May, 20:32
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-40) Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate) Tue, 02 May, 20:32
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-1327) Replace OutputTimeFn with enum Tue, 02 May, 20:32
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-1327) Replace OutputTimeFn with enum Tue, 02 May, 20:34
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-885) Move PipelineOptions from Pipeline.create() to Pipeline.run() Tue, 02 May, 22:29
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-885) Move PipelineOptions from Pipeline.create() to Pipeline.run() Tue, 02 May, 22:29
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-2128) PostCommit Java_MavenInstall broken Wed, 03 May, 02:17
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-1641) Implement real synchronized processing time in Flink runner Wed, 03 May, 02:18
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-1641) Implement real synchronized processing time in Flink runner Wed, 03 May, 02:18
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-170) Session windows should not be identified by their bounds Wed, 03 May, 02:28
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-170) Session windows should not be identified by their bounds Wed, 03 May, 02:28
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 02:29
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 02:29
Kenneth Knowles (JIRA) [jira] [Comment Edited] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 02:29
Kenneth Knowles (JIRA) [jira] [Created] (BEAM-2144) Do not publish javadoc for Java SDK's util directory Wed, 03 May, 03:03
Kenneth Knowles (JIRA) [jira] [Created] (BEAM-2145) Do not publish javadoc for Java SDK's transforms.reflect directory Wed, 03 May, 03:04
Kenneth Knowles (JIRA) [jira] [Reopened] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 03:17
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 03:19
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 03:19
Kenneth Knowles (JIRA) [jira] [Comment Edited] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 03:21
Kenneth Knowles (JIRA) [jira] [Reopened] (BEAM-885) Move PipelineOptions from Pipeline.create() to Pipeline.run() Wed, 03 May, 03:21
Kenneth Knowles (JIRA) [jira] [Comment Edited] (BEAM-828) Remove PipelineOptions from construction time in BigQueryIO Wed, 03 May, 03:22
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2136) AvroCoderTest.testTwoClassLoaders fails on beam_PostCommit_Java_ValidatesRunner_Dataflow Wed, 03 May, 10:23
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-1030) DoFnSignatures should validate StateSpec against key type Wed, 03 May, 10:24
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-1401) Sinks in Beam should supported windowed unbounded PCollections Wed, 03 May, 10:25
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-1401) Sinks in Beam should supported windowed unbounded PCollections Wed, 03 May, 10:26
Kenneth Knowles (JIRA) [jira] [Created] (BEAM-2146) Continuously run ValidatesRunner suite on Dataflow forcing streaming mode Wed, 03 May, 10:27
Kenneth Knowles (JIRA) [jira] [Created] (BEAM-2147) Re-enable UsesTimersInParDo tests for DataflowRunner Wed, 03 May, 10:30
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2136) AvroCoderTest.testTwoClassLoaders fails on beam_PostCommit_Java_ValidatesRunner_Dataflow Wed, 03 May, 15:09
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-2143) (Mis)Running Dataflow Wordcount gives non-helpful errors Wed, 03 May, 16:37
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-2143) (Mis)Running Dataflow Wordcount gives non-helpful errors Wed, 03 May, 16:37
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner Wed, 03 May, 16:54
Kenneth Knowles (JIRA) [jira] [Comment Edited] (BEAM-1612) Support real Bundle in Flink runner Wed, 03 May, 16:55
Kenneth Knowles (JIRA) [jira] [Created] (BEAM-2155) Investigate problem creating Map PCollection view on Dataflow Wed, 03 May, 17:25
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2053) Add HDFS file provider to wordcount examples Wed, 03 May, 17:40
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-2053) Add HDFS file provider to wordcount examples Wed, 03 May, 17:40
Kenneth Knowles (JIRA) [jira] [Assigned] (BEAM-2113) Apex Runner is not able to submit any job to YARN Wed, 03 May, 17:45
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2145) Do not publish javadoc for Java SDK's transforms.reflect directory Wed, 03 May, 18:15
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested Wed, 03 May, 20:32
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested Wed, 03 May, 20:46
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested Wed, 03 May, 20:48
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested Wed, 03 May, 20:48
Kenneth Knowles (JIRA) [jira] [Updated] (BEAM-2166) Remove Coder.Context from the public API Thu, 04 May, 02:05
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2166) Remove Coder.Context from the public API Thu, 04 May, 02:06
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2145) Do not publish javadoc for Java SDK's transforms.reflect directory Thu, 04 May, 18:30
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2144) Do not publish javadoc for Java SDK's util directory Thu, 04 May, 18:31
Kenneth Knowles (JIRA) [jira] [Commented] (BEAM-2004) Verify PAssert execution in TestApexRunner Thu, 04 May, 18:35
Kenneth Knowles (JIRA) [jira] [Resolved] (BEAM-2004) Verify PAssert execution in TestApexRunner Thu, 04 May, 18:36
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 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · Next »Thread · Author · Date
Box list
Dec 201983
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