Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1811

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1155) Spark runner aggregators only support a handfuls of combiners

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747772#comment-15747772 ] Amit Sela commented on BEAM-1155: - I think the effort should be towards the Metrics API. See BEAM-147. >

[jira] [Commented] (BEAM-1126) Expose UnboundedSource split backlog in number of events

2016-12-14 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747788#comment-15747788 ] Aviem Zur commented on BEAM-1126: - Yeah, that logic is sound. I'd be glad to help with that effort. Are

[jira] [Created] (BEAM-1156) Spark runner does not support side-inputs in multiple windows.

2016-12-14 Thread Amit Sela (JIRA)
Amit Sela created BEAM-1156: --- Summary: Spark runner does not support side-inputs in multiple windows. Key: BEAM-1156 URL: https://issues.apache.org/jira/browse/BEAM-1156 Project: Beam Issue Type:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1811

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Assigned] (BEAM-425) Create Elasticsearch IO

2016-12-14 Thread Etienne Chauchot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot reassigned BEAM-425: - Assignee: Etienne Chauchot (was: Jean-Baptiste Onofré) > Create Elasticsearch IO >

[jira] [Assigned] (BEAM-425) Create Elasticsearch IO

2016-12-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-425: - Assignee: Jean-Baptiste Onofré (was: Etienne Chauchot) > Create Elasticsearch IO

[jira] [Updated] (BEAM-425) Create Elasticsearch IO

2016-12-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-425: -- Assignee: Etienne Chauchot (was: Jean-Baptiste Onofré) > Create Elasticsearch IO >

[jira] [Created] (BEAM-1155) Spark runner aggregators only support a handfuls of combiners

2016-12-14 Thread Aviem Zur (JIRA)
Aviem Zur created BEAM-1155: --- Summary: Spark runner aggregators only support a handfuls of combiners Key: BEAM-1155 URL: https://issues.apache.org/jira/browse/BEAM-1155 Project: Beam Issue Type:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1812

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1144) Spark runner fails to deserialize MicrobatchSource in cluster mode

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15748328#comment-15748328 ] ASF GitHub Bot commented on BEAM-1144: -- GitHub user aviemzur opened a pull request:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #408

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #408

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators

2016-12-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15748240#comment-15748240 ] Aljoscha Krettek commented on BEAM-1148: Just out of curiosity, what are they going to be replaced

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2093

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1813

2016-12-14 Thread Apache Jenkins Server
See

[GitHub] incubator-beam pull request #1613: [BEAM-1144] Spark runner fails to deseria...

2016-12-14 Thread aviemzur
GitHub user aviemzur opened a pull request: https://github.com/apache/incubator-beam/pull/1613 [BEAM-1144] Spark runner fails to deserialize MicrobatchSource in cluster mode Be sure to do all of the following to help us incorporate your contribution quickly and easily:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1813

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Assigned] (BEAM-298) Make TestPipeline implement the TestRule interface

2016-12-14 Thread Stas Levin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin reassigned BEAM-298: --- Assignee: Stas Levin > Make TestPipeline implement the TestRule interface >

[jira] [Resolved] (BEAM-807) [SparkRunner] Replace OldDoFn with DoFn

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-807. Resolution: Fixed Fix Version/s: 0.4.0-incubating Resolved by:

[jira] [Resolved] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-757. Resolution: Fixed Fix Version/s: 0.4.0-incubating > The SparkRunner should utilize the SDK's

[GitHub] incubator-beam pull request #1614: [BEAM-853] Force streaming execution on b...

2016-12-14 Thread amitsela
GitHub user amitsela opened a pull request: https://github.com/apache/incubator-beam/pull/1614 [BEAM-853] Force streaming execution on batch pipelines for testing. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ]

[jira] [Assigned] (BEAM-85) PAssert needs sanity check that it's used correctly

2016-12-14 Thread Stas Levin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin reassigned BEAM-85: -- Assignee: Stas Levin > PAssert needs sanity check that it's used correctly >

[GitHub] incubator-beam pull request #1618: [BEAM-1149] Fix NPE in StatefulParDoEvalu...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1618 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[2/2] incubator-beam git commit: This closes #1618

2016-12-14 Thread kenn
This closes #1618 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9fbf429b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9fbf429b Diff:

[jira] [Issue Comment Deleted] (BEAM-853) Force streaming execution on batch pipelines for testing.

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-853: --- Comment: was deleted (was: Streaming tests require forcing streaming mode on {{BoundedFromUnbounded}}, and

[jira] [Issue Comment Deleted] (BEAM-853) Force streaming execution on batch pipelines for testing.

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-853: --- Comment: was deleted (was: I have this one sorted out already, but I'll make it a part of BEAM-920 since there

[1/2] incubator-beam git commit: [BEAM-1033] Retry Bigquery Verifier when Query Fails

2016-12-14 Thread tgroh
Repository: incubator-beam Updated Branches: refs/heads/master 4927cc1ab -> 0b0a1b797 [BEAM-1033] Retry Bigquery Verifier when Query Fails Update Junit to 4.12 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Commented] (BEAM-1033) BigQueryMatcher is flaky

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749430#comment-15749430 ] ASF GitHub Bot commented on BEAM-1033: -- Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #1479: [BEAM-1033] Bigquery Verifier Retry When ...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1479 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2096

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1815

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1815

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749500#comment-15749500 ] ASF GitHub Bot commented on BEAM-1149: -- GitHub user kennknowles opened a pull request:

[GitHub] incubator-beam pull request #1618: [BEAM-1149] Fix NPE in StatefulParDoEvalu...

2016-12-14 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1618 [BEAM-1149] Fix NPE in StatefulParDoEvaluatorFactoryTest mocking Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[1/2] incubator-beam git commit: Fix NPE in StatefulParDoEvaluatorFactoryTest mocking

2016-12-14 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master 0b0a1b797 -> 9fbf429b2 Fix NPE in StatefulParDoEvaluatorFactoryTest mocking Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/00b961df Tree:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #411

2016-12-14 Thread Apache Jenkins Server
See

[GitHub] incubator-beam pull request #1619: [BEAM-1149] Cherry pick some fixes to rel...

2016-12-14 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1619 [BEAM-1149] Cherry pick some fixes to release-0.4.0 Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

[2/2] incubator-beam git commit: This closes #1479

2016-12-14 Thread tgroh
This closes #1479 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0b0a1b79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0b0a1b79 Diff:

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2095

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749514#comment-15749514 ] ASF GitHub Bot commented on BEAM-1149: -- Github user asfgit closed the pull request at:

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2097

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #411

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2098

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749699#comment-15749699 ] ASF GitHub Bot commented on BEAM-1149: -- GitHub user kennknowles opened a pull request:

[GitHub] incubator-beam pull request #1615: [BEAM-1104] Don't incorrectly log error i...

2016-12-14 Thread bjchambers
GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/1615 [BEAM-1104] Don't incorrectly log error in MetricsEnvironment Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [*] Make

[jira] [Closed] (BEAM-1156) Spark runner does not support side-inputs in multiple windows.

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-1156. --- Resolution: Duplicate Fix Version/s: Not applicable > Spark runner does not support side-inputs in

[GitHub] incubator-beam pull request #1617: [BEAM-964] json avro flag migration

2016-12-14 Thread sb2nov
GitHub user sb2nov opened a pull request: https://github.com/apache/incubator-beam/pull/1617 [BEAM-964] json avro flag migration Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is formatted

[jira] [Commented] (BEAM-964) Investing exporting BQ as Avro instead of Json for dataflow runner

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749284#comment-15749284 ] ASF GitHub Bot commented on BEAM-964: - GitHub user sb2nov opened a pull request:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #410

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #409

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Updated] (BEAM-1157) Create HBaseIO

2016-12-14 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-1157: --- Description: Support for reading and writing to HBase. An initial plan is to keep a similar API to

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #409

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators

2016-12-14 Thread Ben Chambers (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749188#comment-15749188 ] Ben Chambers commented on BEAM-1148: In general: Aggregators are being replaced with Metrics for the

[jira] [Comment Edited] (BEAM-1148) Port PAssert away from Aggregators

2016-12-14 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749192#comment-15749192 ] Kenneth Knowles edited comment on BEAM-1148 at 12/14/16 7:17 PM: - The

[2/2] incubator-beam git commit: Implement GetDefaultOutputCoder in DirectGroupByKey

2016-12-14 Thread tgroh
Implement GetDefaultOutputCoder in DirectGroupByKey This uses the standard Coder Inference path to set coders, rather than explicitly setting the output coders for intermediate PCollections. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Commented] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749237#comment-15749237 ] Daniel Halperin commented on BEAM-1149: --- Yes. I think the "right" fix is more to point out that "has

[GitHub] incubator-beam pull request #1583: Implement GetDefaultOutputCoder in Direct...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1583 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[1/2] incubator-beam git commit: This closes #1583

2016-12-14 Thread tgroh
Repository: incubator-beam Updated Branches: refs/heads/master 5a51ace8d -> fdf07318f This closes #1583 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fdf07318 Tree:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1814

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #410

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1153) GcsUtil needs to set timeout and retry explicitly in BatchRequest.

2016-12-14 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749181#comment-15749181 ] Daniel Halperin commented on BEAM-1153: --- Thanks for the info! Why do we think the read timeout has

[jira] [Commented] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749222#comment-15749222 ] Amit Sela commented on BEAM-1149: - FWIW it works for me if I replace: {code} @Override public void

[jira] [Created] (BEAM-1158) Create HiveIO

2016-12-14 Thread JIRA
Ismaël Mejía created BEAM-1158: -- Summary: Create HiveIO Key: BEAM-1158 URL: https://issues.apache.org/jira/browse/BEAM-1158 Project: Beam Issue Type: Improvement Components:

[jira] [Created] (BEAM-1157) Create HBaseIO

2016-12-14 Thread JIRA
Ismaël Mejía created BEAM-1157: -- Summary: Create HBaseIO Key: BEAM-1157 URL: https://issues.apache.org/jira/browse/BEAM-1157 Project: Beam Issue Type: Improvement Components:

[jira] [Commented] (BEAM-1104) WordCount: Metrics error in the DirectRunner

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749228#comment-15749228 ] ASF GitHub Bot commented on BEAM-1104: -- GitHub user bjchambers opened a pull request:

[jira] [Commented] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749260#comment-15749260 ] ASF GitHub Bot commented on BEAM-1149: -- GitHub user kennknowles opened a pull request:

[GitHub] incubator-beam pull request #1616: [BEAM-1149] SimpleDoFnRunner observes win...

2016-12-14 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1616 [BEAM-1149] SimpleDoFnRunner observes window if SideInputReader is nonempty Be sure to do all of the following to help us incorporate your contribution quickly and easily:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1814

2016-12-14 Thread Apache Jenkins Server
See

[2/2] incubator-beam git commit: This closes #1616

2016-12-14 Thread kenn
This closes #1616 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4927cc1a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4927cc1a Diff:

[1/2] incubator-beam git commit: SimpleDoFnRunner observes window if SideInputReader is nonempty

2016-12-14 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master fdf07318f -> 4927cc1ab SimpleDoFnRunner observes window if SideInputReader is nonempty Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #1616: [BEAM-1149] SimpleDoFnRunner observes win...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1616 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Updated] (BEAM-1153) GcsUtil needs to set timeout and retry explicitly in BatchRequest.

2016-12-14 Thread Pei He (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He updated BEAM-1153: - Description: Non-batch requests uses RetryHttpRequestInitializer, which set read timeout as 80 seconds, and does

[jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators

2016-12-14 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749192#comment-15749192 ] Kenneth Knowles commented on BEAM-1148: --- The trouble with side output + combine is that we don't have

[jira] [Comment Edited] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

2016-12-14 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749237#comment-15749237 ] Daniel Halperin edited comment on BEAM-1149 at 12/14/16 7:30 PM: - Yes. I

[jira] [Updated] (BEAM-853) Force streaming execution on batch pipelines for testing.

2016-12-14 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-853: --- Description: The SDK's {{streaming}} tests actually use a {{BoundedReadFromUnboundedSource}} while "forcing" a

[jira] [Updated] (BEAM-1153) GcsUtil needs to set timeout and retry explicitly in BatchRequest.

2016-12-14 Thread Pei He (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He updated BEAM-1153: - Description: Non-batch requests uses RetryHttpRequestInitializer, which set read timeout as 80 seconds, and does

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2094

2016-12-14 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-1154) ReduceFnRunner fetches side input from the wrong window

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749748#comment-15749748 ] ASF GitHub Bot commented on BEAM-1154: -- GitHub user jkff opened a pull request:

[GitHub] incubator-beam pull request #1620: [BEAM-1154] Get side input from proper wi...

2016-12-14 Thread jkff
GitHub user jkff opened a pull request: https://github.com/apache/incubator-beam/pull/1620 [BEAM-1154] Get side input from proper window in ReduceFn R: @kennknowles CC: @peihe You can merge this pull request into a Git repository by running: $ git pull

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2102

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #415

2016-12-14 Thread Apache Jenkins Server
See

[1/3] incubator-beam git commit: SimpleDoFnRunner observes window if SideInputReader is nonempty

2016-12-14 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating 10bb4767a -> ea0d7f5c2 SimpleDoFnRunner observes window if SideInputReader is nonempty Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Created] (BEAM-1159) DoFnSignature should have info on the fn's side inputs and outputs

2016-12-14 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-1159: -- Summary: DoFnSignature should have info on the fn's side inputs and outputs Key: BEAM-1159 URL: https://issues.apache.org/jira/browse/BEAM-1159 Project: Beam

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #2099

2016-12-14 Thread Apache Jenkins Server
See

[GitHub] incubator-beam pull request #1622: Make {Metric,Counter,Distribution}Cell pu...

2016-12-14 Thread bjchambers
GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/1622 Make {Metric,Counter,Distribution}Cell public Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [*] Make sure the PR title

[2/2] incubator-beam git commit: Fail to split in FileBasedSource if filePattern expands to empty.

2016-12-14 Thread dhalperi
Fail to split in FileBasedSource if filePattern expands to empty. Typically, input file patterns are validated during Pipeline construction, but standard Read transforms include an option to disable validation. This is generally useful but can lead to cases where a Pipeline executes successfully

[1/2] incubator-beam git commit: Closes #1621

2016-12-14 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master 46566fc71 -> 1ad638e51 Closes #1621 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1ad638e5 Tree:

[jira] [Commented] (BEAM-1160) Disabling Read transform validation cause empty file patterns to unexpected succeed

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749956#comment-15749956 ] ASF GitHub Bot commented on BEAM-1160: -- Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #1621: [BEAM-1160] Fail to split in FileBasedSou...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1621 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[3/3] incubator-beam git commit: This closes #1619

2016-12-14 Thread kenn
This closes #1619 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ea0d7f5c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ea0d7f5c Diff:

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #412

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #412

2016-12-14 Thread Apache Jenkins Server
See

[2/2] incubator-beam git commit: [BEAM-1153] GcsUtil: use non-batch API for single file size requests.

2016-12-14 Thread dhalperi
[BEAM-1153] GcsUtil: use non-batch API for single file size requests. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/028408f5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/028408f5 Diff:

[1/2] incubator-beam git commit: Closes #1611

2016-12-14 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master 9fbf429b2 -> 46566fc71 Closes #1611 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/46566fc7 Tree:

[GitHub] incubator-beam pull request #1611: [BEAM-1153] GcsUtil: use non-batch API fo...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1611 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] incubator-beam pull request #1621: Fail to split in FileBasedSource if fileP...

2016-12-14 Thread swegner
GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/1621 Fail to split in FileBasedSource if filePattern expands to empty Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1816

2016-12-14 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1816

2016-12-14 Thread Apache Jenkins Server
See

[GitHub] incubator-beam pull request #1619: [BEAM-1149] Cherry pick some fixes to rel...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1619 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

  1   2   >