| jbono...@apache.org |
[1/2] incubator-beam git commit: [BEAM-1034] Clean up tmp area in tests |
Thu, 24 Nov, 07:43 |
| jbono...@apache.org |
[2/2] incubator-beam git commit: [BEAM-1034] This closes #1415 |
Thu, 24 Nov, 07:43 |
| jbono...@apache.org |
[1/2] incubator-beam git commit: [BEAM-959] Improve validation messages in JdbcIO |
Thu, 24 Nov, 09:32 |
| jbono...@apache.org |
[2/2] incubator-beam git commit: [BEAM-959] This closes #1374 |
Thu, 24 Nov, 09:32 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_MavenVerify #1895 |
Thu, 24 Nov, 10:03 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_MavenVerify #1896 |
Thu, 24 Nov, 12:29 |
| aljoscha |
[GitHub] incubator-beam pull request #1435: Replace WindowAssignment OldDoFn by FlatM... |
Thu, 24 Nov, 10:39 |
| asfgit |
[GitHub] incubator-beam pull request #1435: Replace WindowAssignment OldDoFn by FlatM... |
Thu, 24 Nov, 14:21 |
|
[jira] [Created] (BEAM-1048) Spark Runner streaming batch duration does not include duration of reading from source |
|
| Kobi Salant (JIRA) |
[jira] [Created] (BEAM-1048) Spark Runner streaming batch duration does not include duration of reading from source |
Thu, 24 Nov, 13:45 |
| Amit Sela (JIRA) |
[jira] [Updated] (BEAM-1048) Spark Runner streaming batch duration does not include duration of reading from source |
Thu, 24 Nov, 14:04 |
| Amit Sela (JIRA) |
[jira] [Commented] (BEAM-1048) Spark Runner streaming batch duration does not include duration of reading from source |
Thu, 24 Nov, 14:11 |
| aljos...@apache.org |
[1/2] incubator-beam git commit: Replace WindowAssignment OldDoFn by FlatMap in Flink Runner |
Thu, 24 Nov, 14:21 |
| aljos...@apache.org |
[2/2] incubator-beam git commit: This closes #1435 |
Thu, 24 Nov, 14:21 |
| minudika |
[GitHub] incubator-beam-site pull request #95: [BEAM-835] Added IntelliJ instructions... |
Fri, 25 Nov, 12:44 |
|
[GitHub] incubator-beam-site pull request #56: [Beam 835] Added IntelliJ instructions... |
|
| minudika |
[GitHub] incubator-beam-site pull request #56: [Beam 835] Added IntelliJ instructions... |
Fri, 25 Nov, 12:47 |
|
[jira] [Assigned] (BEAM-851) Identify streaming pipelines implicitly. |
|
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-851) Identify streaming pipelines implicitly. |
Fri, 25 Nov, 13:17 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-851) Identify streaming pipelines implicitly. |
Fri, 25 Nov, 14:01 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-851) Identify streaming pipelines implicitly. |
Sun, 27 Nov, 11:41 |
| Amit Sela (JIRA) |
[jira] [Resolved] (BEAM-851) Identify streaming pipelines implicitly. |
Sun, 27 Nov, 11:43 |
| iemejia |
[GitHub] incubator-beam pull request #1436: [BEAM-851] Identify if pipeline is in str... |
Fri, 25 Nov, 14:01 |
| asfgit |
[GitHub] incubator-beam pull request #1436: [BEAM-851] Identify if pipeline is in str... |
Sun, 27 Nov, 11:41 |
| k...@apache.org |
[1/2] incubator-beam git commit: This closes #1428 |
Sat, 26 Nov, 04:41 |
| k...@apache.org |
[2/2] incubator-beam git commit: [BEAM-800] add getFn to DoFnInvoker |
Sat, 26 Nov, 04:41 |
| amits...@apache.org |
[1/3] incubator-beam git commit: Remove unused WindowingInternals.writePCollectionViewData |
Sat, 26 Nov, 11:00 |
| amits...@apache.org |
[2/3] incubator-beam git commit: Remove unused body of StreamingPCollectionViewWriterFn |
Sat, 26 Nov, 11:00 |
| amits...@apache.org |
[3/3] incubator-beam git commit: [BEAM-498] Remove obsolete WindowingInternals#writePCollectionViewData This closes #1430 |
Sat, 26 Nov, 11:00 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_MavenVerify #1906 |
Sat, 26 Nov, 11:34 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_MavenVerify #1907 |
Sat, 26 Nov, 12:28 |
|
[jira] [Created] (BEAM-1049) Upgrade default spark version to 1.6.3 |
|
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-1049) Upgrade default spark version to 1.6.3 |
Sun, 27 Nov, 10:34 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1049) Upgrade default spark version to 1.6.3 |
Sun, 27 Nov, 10:41 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1049) Upgrade default spark version to 1.6.3 |
Sun, 27 Nov, 10:57 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1049) Upgrade default spark version to 1.6.3 |
Sun, 27 Nov, 17:53 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Resolved] (BEAM-1049) Upgrade default spark version to 1.6.3 |
Sun, 27 Nov, 17:54 |
| iemejia |
[GitHub] incubator-beam pull request #1437: [BEAM-1049] Update spark version to 1.6.3 |
Sun, 27 Nov, 10:57 |
| asfgit |
[GitHub] incubator-beam pull request #1437: [BEAM-1049] Update spark version to 1.6.3 |
Sun, 27 Nov, 17:53 |
| amits...@apache.org |
[1/2] incubator-beam git commit: [BEAM-851] Determine if the pipeline must be translated into streaming mode (if not set) |
Sun, 27 Nov, 11:41 |
| amits...@apache.org |
[2/2] incubator-beam git commit: This closes #1436 |
Sun, 27 Nov, 11:41 |
|
[jira] [Created] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails |
|
| Stas Levin (JIRA) |
[jira] [Created] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails |
Sun, 27 Nov, 12:06 |
| Stas Levin (JIRA) |
[jira] [Commented] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails |
Sun, 27 Nov, 12:21 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails |
Mon, 28 Nov, 09:14 |
| Amit Sela (JIRA) |
[jira] [Updated] (BEAM-1050) PipelineResult.State is not set to FAILED when a streaming job fails |
Mon, 28 Nov, 09:19 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1050) PipelineResult.State is not set to FAILED when a streaming job fails |
Wed, 30 Nov, 20:33 |
|
[jira] [Created] (BEAM-1051) Extend the TestSparkRunner with its own TransformTranslator containing test evaluators |
|
| Jean-Baptiste Onofré (JIRA) |
[jira] [Created] (BEAM-1051) Extend the TestSparkRunner with its own TransformTranslator containing test evaluators |
Sun, 27 Nov, 12:36 |
|
[jira] [Created] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
|
| Amit Sela (JIRA) |
[jira] [Created] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Sun, 27 Nov, 14:27 |
| Aviem Zur (JIRA) |
[jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Tue, 29 Nov, 07:33 |
| Aviem Zur (JIRA) |
[jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Tue, 29 Nov, 07:34 |
| Aviem Zur (JIRA) |
[jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Tue, 29 Nov, 07:34 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Tue, 29 Nov, 07:54 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Tue, 29 Nov, 10:10 |
| Amit Sela (JIRA) |
[jira] [Resolved] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. |
Tue, 29 Nov, 10:50 |
| jbono...@apache.org |
[1/2] incubator-beam git commit: [BEAM-1049] Update spark version to 1.6.3 |
Sun, 27 Nov, 17:53 |
| jbono...@apache.org |
[2/2] incubator-beam git commit: [BEAM-1049] This closes #1437 |
Sun, 27 Nov, 17:53 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_MavenVerify #1917 |
Mon, 28 Nov, 06:28 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_MavenVerify #1918 |
Mon, 28 Nov, 12:18 |
| staslev |
[GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat... |
Mon, 28 Nov, 09:14 |
| staslev |
[GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat... |
Wed, 30 Nov, 20:33 |
| jbono...@apache.org |
incubator-beam git commit: [BEAM-1049] This closes #1437 [Forced Update!] |
Mon, 28 Nov, 11:37 |
|
[jira] [Created] (BEAM-1053) ApexGroupByKeyOperator serialization issues |
|
| Sandeep Deshmukh (JIRA) |
[jira] [Created] (BEAM-1053) ApexGroupByKeyOperator serialization issues |
Mon, 28 Nov, 15:35 |
| Sandeep Deshmukh (JIRA) |
[jira] [Commented] (BEAM-1053) ApexGroupByKeyOperator serialization issues |
Mon, 28 Nov, 15:36 |
| echauchot |
[GitHub] incubator-beam pull request #1439: [BEAM-425] Add ElasticsearchIO |
Mon, 28 Nov, 17:17 |
|
[jira] [Commented] (BEAM-425) Add Elasticsearch IO |
|
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-425) Add Elasticsearch IO |
Mon, 28 Nov, 17:18 |
| tg...@apache.org |
[1/2] incubator-beam git commit: This closes #1424 |
Mon, 28 Nov, 18:06 |
| tg...@apache.org |
[2/2] incubator-beam git commit: Add input type to TransformResult |
Mon, 28 Nov, 18:06 |
|
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
|
| Kenneth Knowles (JIRA) |
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Mon, 28 Nov, 18:24 |
| Kenneth Knowles (JIRA) |
[jira] [Reopened] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Mon, 28 Nov, 18:24 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Mon, 28 Nov, 18:26 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Tue, 29 Nov, 19:12 |
| kennknowles |
[GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm... |
Mon, 28 Nov, 18:26 |
| asfgit |
[GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm... |
Tue, 29 Nov, 19:12 |
|
[jira] [Created] (BEAM-1054) Language specific IO docs |
|
| Melissa Pashniak (JIRA) |
[jira] [Created] (BEAM-1054) Language specific IO docs |
Mon, 28 Nov, 18:48 |
|
[jira] [Created] (BEAM-1055) Display Data keys on Python are inconsistent |
|
| Pablo Estrada (JIRA) |
[jira] [Created] (BEAM-1055) Display Data keys on Python are inconsistent |
Mon, 28 Nov, 19:03 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent |
Mon, 28 Nov, 21:08 |
| sammcveety |
[GitHub] incubator-beam pull request #1441: Fix double-close bug |
Mon, 28 Nov, 19:26 |
| asfgit |
[GitHub] incubator-beam pull request #1441: Fix double-close bug |
Tue, 29 Nov, 20:20 |
| tgroh |
[GitHub] incubator-beam pull request #1442: [BEAM-646] Add Replacement Methods to Tra... |
Mon, 28 Nov, 20:06 |
|
[jira] [Commented] (BEAM-646) Get runners out of the apply() |
|
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-646) Get runners out of the apply() |
Mon, 28 Nov, 20:06 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-646) Get runners out of the apply() |
Wed, 30 Nov, 21:53 |
| pabloem |
[GitHub] incubator-beam pull request #1443: [BEAM-1055] Display Data keys on Python a... |
Mon, 28 Nov, 21:08 |
| k...@apache.org |
[1/5] incubator-beam git commit: Remove overspecified type in ParDoEvaluator |
Mon, 28 Nov, 21:17 |
| k...@apache.org |
[2/5] incubator-beam git commit: Add simple tests for stateful ParDo |
Mon, 28 Nov, 21:17 |
| k...@apache.org |
[3/5] incubator-beam git commit: Add State parameter support to SimpleDoFnRunner |
Mon, 28 Nov, 21:17 |
| k...@apache.org |
[4/5] incubator-beam git commit: Add support for Stateful ParDo in the Direct runner |
Mon, 28 Nov, 21:17 |
| k...@apache.org |
[5/5] incubator-beam git commit: This closes #1399 |
Mon, 28 Nov, 21:17 |
|
[jira] [Updated] (BEAM-26) Model for validation of user state upon pipeline update |
|
| Kenneth Knowles (JIRA) |
[jira] [Updated] (BEAM-26) Model for validation of user state upon pipeline update |
Mon, 28 Nov, 21:18 |
|
[jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn |
|
| Kenneth Knowles (JIRA) |
[jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn |
Mon, 28 Nov, 21:19 |
|
[jira] [Updated] (BEAM-42) State for "Map" data, supporting efficient key lookup, etc. |
|
| Kenneth Knowles (JIRA) |
[jira] [Updated] (BEAM-42) State for "Map" data, supporting efficient key lookup, etc. |
Mon, 28 Nov, 21:19 |
|
[jira] [Updated] (BEAM-41) State for "Set" data, supporting efficient membership checks |
|
| Kenneth Knowles (JIRA) |
[jira] [Updated] (BEAM-41) State for "Set" data, supporting efficient membership checks |
Mon, 28 Nov, 21:20 |