|
[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators |
|
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators |
Wed, 22 Mar, 22:01 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators |
Thu, 23 Mar, 17:29 |
| Eugene Kirpichov (JIRA) |
[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators |
Thu, 23 Mar, 22:14 |
| jkff |
[GitHub] beam pull request #2292: Log Dataflow job state on unsuccessful cancel |
Wed, 22 Mar, 22:40 |
| asfgit |
[GitHub] beam pull request #2292: Log Dataflow job state on unsuccessful cancel |
Thu, 23 Mar, 00:59 |
| melap |
[GitHub] beam pull request #2293: [BEAM-1778] First clean up pass of dataflow referen... |
Wed, 22 Mar, 22:51 |
| asfgit |
[GitHub] beam pull request #2293: [BEAM-1778] First clean up pass of dataflow referen... |
Thu, 23 Mar, 00:29 |
|
[jira] [Created] (BEAM-1783) Add Integration Tests for HBaseIO |
|
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-1783) Add Integration Tests for HBaseIO |
Wed, 22 Mar, 23:03 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2615 |
Wed, 22 Mar, 23:05 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2616 |
Thu, 23 Mar, 00:48 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2617 |
Thu, 23 Mar, 02:10 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2618 |
Thu, 23 Mar, 03:30 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2619 |
Thu, 23 Mar, 07:20 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2620 |
Thu, 23 Mar, 13:43 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2621 |
Thu, 23 Mar, 16:27 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2622 |
Thu, 23 Mar, 18:05 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2623 |
Thu, 23 Mar, 19:46 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2624 |
Thu, 23 Mar, 21:22 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2625 |
Thu, 23 Mar, 23:00 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2626 |
Fri, 24 Mar, 00:27 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2627 |
Fri, 24 Mar, 02:00 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2628 |
Fri, 24 Mar, 03:25 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2629 |
Fri, 24 Mar, 04:48 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2630 |
Fri, 24 Mar, 06:20 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2631 |
Fri, 24 Mar, 07:42 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2632 |
Fri, 24 Mar, 13:41 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2633 |
Fri, 24 Mar, 18:16 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2634 |
Fri, 24 Mar, 19:48 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2635 |
Fri, 24 Mar, 22:59 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2636 |
Sat, 25 Mar, 00:31 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2637 |
Sat, 25 Mar, 01:55 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2638 |
Sat, 25 Mar, 03:09 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2639 |
Sat, 25 Mar, 07:13 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2640 |
Sat, 25 Mar, 10:34 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2641 |
Sat, 25 Mar, 13:15 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2642 |
Sat, 25 Mar, 14:50 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2643 |
Sat, 25 Mar, 19:14 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2644 |
Sat, 25 Mar, 20:25 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2645 |
Sun, 26 Mar, 01:13 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2646 |
Sun, 26 Mar, 07:13 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2647 |
Sun, 26 Mar, 09:37 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2648 |
Sun, 26 Mar, 13:18 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2649 |
Sun, 26 Mar, 19:25 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2650 |
Mon, 27 Mar, 01:21 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2651 |
Mon, 27 Mar, 04:35 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2652 |
Mon, 27 Mar, 07:10 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2653 |
Mon, 27 Mar, 13:25 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2654 |
Mon, 27 Mar, 18:03 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2655 |
Mon, 27 Mar, 19:31 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2656 |
Mon, 27 Mar, 20:56 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2657 |
Mon, 27 Mar, 22:20 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2658 |
Mon, 27 Mar, 23:45 |
| jkff |
[GitHub] beam pull request #2294: Fixes two checkstyle violations |
Wed, 22 Mar, 23:08 |
| asfgit |
[GitHub] beam pull request #2294: Fixes two checkstyle violations |
Wed, 22 Mar, 23:13 |
| tg...@apache.org |
[1/2] beam git commit: Fix two checkstyle violations |
Wed, 22 Mar, 23:12 |
| tg...@apache.org |
[2/2] beam git commit: This closes #2294 |
Wed, 22 Mar, 23:12 |
| jkff |
[GitHub] beam pull request #2295: Avoid calling cancel multiple times in TestDataflow... |
Wed, 22 Mar, 23:42 |
| asfgit |
[GitHub] beam pull request #2295: [BEAM-1784] Makes DataflowPipelineJob.cancel() idem... |
Thu, 23 Mar, 20:48 |
| robertwb |
[GitHub] beam pull request #2296: [BEAM-115] Translate pipeline graph to and from Run... |
Thu, 23 Mar, 00:08 |
| asfgit |
[GitHub] beam pull request #2296: [BEAM-115] Translate pipeline graph to and from Run... |
Thu, 30 Mar, 15:23 |
| chamik...@apache.org |
[1/2] beam git commit: Updates BigQuery read transform to correctly process empty repeated fields. |
Thu, 23 Mar, 00:16 |
| chamik...@apache.org |
[2/2] beam git commit: This closes 2289 |
Thu, 23 Mar, 00:16 |
| al...@apache.org |
[1/2] beam git commit: [BEAM-1778] Clean up pass of dataflow/google references/URLs in Java SDK |
Thu, 23 Mar, 00:29 |
| al...@apache.org |
[2/2] beam git commit: This closes #2293 |
Thu, 23 Mar, 00:29 |
| al...@apache.org |
[1/2] beam git commit: [BEAM-1715] Fix Python WordCount on Dataflow Mismatch |
Thu, 23 Mar, 00:34 |
| al...@apache.org |
[2/2] beam git commit: This closes #2244 |
Thu, 23 Mar, 00:34 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1330 |
Thu, 23 Mar, 00:39 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1331 |
Thu, 23 Mar, 01:05 |
| Apache Jenkins Server |
Build failed in Jenkins: beam_PostCommit_Python_Verify #1585 |
Thu, 23 Mar, 00:43 |
| Apache Jenkins Server |
Build failed in Jenkins: beam_PostCommit_Python_Verify #1586 |
Thu, 23 Mar, 00:52 |
| Apache Jenkins Server |
Jenkins build is back to normal : beam_PostCommit_Python_Verify #1587 |
Thu, 23 Mar, 01:40 |
| j...@apache.org |
[1/2] beam git commit: Log job state on unsuccessful cancel |
Thu, 23 Mar, 00:58 |
| j...@apache.org |
[2/2] beam git commit: This closes #2292 |
Thu, 23 Mar, 00:58 |
| vikkyrk |
[GitHub] beam pull request #2297: [BEAM-1590]: Roll forward #2140 |
Thu, 23 Mar, 01:05 |
| asfgit |
[GitHub] beam pull request #2297: [BEAM-1590]: Roll forward #2140 |
Thu, 23 Mar, 01:51 |
| j...@apache.org |
[1/3] beam git commit: Port the DirectRunner to the Batch Surgery API |
Thu, 23 Mar, 01:13 |
| j...@apache.org |
[2/3] beam git commit: Provide methods for validating Surgery completion |
Thu, 23 Mar, 01:13 |
| j...@apache.org |
[3/3] beam git commit: This closes #2274 |
Thu, 23 Mar, 01:13 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1332 |
Thu, 23 Mar, 01:28 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1333 |
Thu, 23 Mar, 01:50 |
| dhalperi |
[GitHub] beam pull request #2298: [BEAM-1780] BigtableIO: better handling of bad spli... |
Thu, 23 Mar, 01:40 |
| asfgit |
[GitHub] beam pull request #2298: [BEAM-1780] BigtableIO: better handling of bad spli... |
Thu, 23 Mar, 17:33 |
| dhalp...@apache.org |
[1/2] beam git commit: Revert "Revert "DataflowRunner: experimental support for issuing FnAPI based jobs"" |
Thu, 23 Mar, 01:50 |
| dhalp...@apache.org |
[2/2] beam git commit: This closes #2297 |
Thu, 23 Mar, 01:50 |
|
[jira] [Created] (BEAM-1784) DataflowPipelineJob.cancel() should be idempotent |
|
| Eugene Kirpichov (JIRA) |
[jira] [Created] (BEAM-1784) DataflowPipelineJob.cancel() should be idempotent |
Thu, 23 Mar, 03:09 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1784) DataflowPipelineJob.cancel() should be idempotent |
Thu, 23 Mar, 20:49 |
| Eugene Kirpichov (JIRA) |
[jira] [Closed] (BEAM-1784) DataflowPipelineJob.cancel() should be idempotent |
Thu, 23 Mar, 21:39 |
| kennknowles |
[GitHub] beam pull request #2299: [BEAM-115] Make distinguished URNs public |
Thu, 23 Mar, 03:35 |
| asfgit |
[GitHub] beam pull request #2299: [BEAM-115] Make distinguished URNs public |
Thu, 23 Mar, 17:56 |
|
[jira] [Created] (BEAM-1785) Port game example in Beam repo to use InjectorUnboundedSource |
|
| Kenneth Knowles (JIRA) |
[jira] [Created] (BEAM-1785) Port game example in Beam repo to use InjectorUnboundedSource |
Thu, 23 Mar, 04:24 |
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-1785) Port game example in Beam repo to use InjectorUnboundedSource |
Thu, 23 Mar, 04:31 |
| JingsongLi |
[GitHub] beam pull request #2300: [BEAM-773] Implement Metrics support for Flink runn... |
Thu, 23 Mar, 04:33 |
|
[jira] [Resolved] (BEAM-1413) DoFn javadoc has @literal where it shouldn't |
|
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-1413) DoFn javadoc has @literal where it shouldn't |
Thu, 23 Mar, 04:47 |
|
[jira] [Resolved] (BEAM-865) Support set/delete of timer by ID in DirectRunner |
|
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-865) Support set/delete of timer by ID in DirectRunner |
Thu, 23 Mar, 04:48 |
|
[jira] [Resolved] (BEAM-1195) Give triggers a cross-language serialization schema |
|
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-1195) Give triggers a cross-language serialization schema |
Thu, 23 Mar, 04:48 |
|
[jira] [Commented] (BEAM-1113) Support for new Timer API in Dataflow runner |
|
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-1113) Support for new Timer API in Dataflow runner |
Thu, 23 Mar, 04:50 |
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-1113) Support for new Timer API in Dataflow runner |
Thu, 23 Mar, 04:50 |
|
[jira] [Resolved] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java |
|
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java |
Thu, 23 Mar, 04:51 |
|
[jira] [Resolved] (BEAM-1339) There's an easy trick for getting a type descriptor attached to a lambda that seems nicer than what we have |
|
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-1339) There's an easy trick for getting a type descriptor attached to a lambda that seems nicer than what we have |
Thu, 23 Mar, 04:51 |
|
[jira] [Commented] (BEAM-788) Execute ReduceFn directly, not via OldDoFn wrapper |
|
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-788) Execute ReduceFn directly, not via OldDoFn wrapper |
Thu, 23 Mar, 04:54 |
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-788) Execute ReduceFn directly, not via OldDoFn wrapper |
Thu, 23 Mar, 04:55 |
|
[jira] [Assigned] (BEAM-1261) State API should allow state to be managed in different windows |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-1261) State API should allow state to be managed in different windows |
Thu, 23 Mar, 04:56 |
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-1261) State API should allow state to be managed in different windows |
Thu, 23 Mar, 04:56 |
| Etienne Chauchot (JIRA) |
[jira] [Commented] (BEAM-1261) State API should allow state to be managed in different windows |
Thu, 30 Mar, 09:20 |
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-1261) State API should allow state to be managed in different windows |
Thu, 30 Mar, 19:48 |
| Ben Chambers (JIRA) |
[jira] [Commented] (BEAM-1261) State API should allow state to be managed in different windows |
Thu, 30 Mar, 20:20 |
|
[jira] [Resolved] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping |
|
| Kenneth Knowles (JIRA) |
[jira] [Resolved] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping |
Thu, 23 Mar, 04:57 |
|
[jira] [Updated] (BEAM-1119) Add a trigger that fires when the watermark passes timestamp |
|
| Kenneth Knowles (JIRA) |
[jira] [Updated] (BEAM-1119) Add a trigger that fires when the watermark passes timestamp |
Thu, 23 Mar, 04:58 |
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-1119) Add a trigger that fires when the watermark passes timestamp |
Thu, 23 Mar, 04:58 |
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-1119) Add a trigger that fires when the watermark passes timestamp |
Thu, 23 Mar, 04:59 |
|
[jira] [Assigned] (BEAM-260) WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-260) WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources |
Thu, 23 Mar, 05:01 |
|
[jira] [Assigned] (BEAM-644) Primitive to shift the watermark while assigning timestamps |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-644) Primitive to shift the watermark while assigning timestamps |
Thu, 23 Mar, 05:03 |
|
[jira] [Assigned] (BEAM-1172) Precommit integration tests should include some merging windows |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-1172) Precommit integration tests should include some merging windows |
Thu, 23 Mar, 05:03 |
|
[jira] [Assigned] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine |
Thu, 23 Mar, 05:04 |
|
[jira] [Assigned] (BEAM-1008) KeyedWorkItemCoder claims three coder arguments in getCoderArguments but only has two generic type variables |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-1008) KeyedWorkItemCoder claims three coder arguments in getCoderArguments but only has two generic type variables |
Thu, 23 Mar, 05:06 |
|
[jira] [Assigned] (BEAM-976) Update examples README.md to fix instructions to run pipelines |
|
| Kenneth Knowles (JIRA) |
[jira] [Assigned] (BEAM-976) Update examples README.md to fix instructions to run pipelines |
Thu, 23 Mar, 05:07 |
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-976) Update examples README.md to fix instructions to run pipelines |
Thu, 23 Mar, 05:07 |
| Vikas Kedigehalli (JIRA) |
[jira] [Commented] (BEAM-976) Update examples README.md to fix instructions to run pipelines |
Thu, 23 Mar, 05:21 |