| 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 |