[jira] [Commented] (BEAM-1857) Add Neo4jIO

2017-04-01 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952534#comment-15952534 ] Jean-Baptiste Onofré commented on BEAM-1857: Warning: neo4j is under GPL license which is a

[jira] [Assigned] (BEAM-1857) Add Neo4jIO

2017-04-01 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1857: -- Assignee: Jean-Baptiste Onofré (was: Davor Bonaci) > Add Neo4jIO > ---

[jira] [Updated] (BEAM-1581) JSON source and sink

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1581: Description: JSON source and sink to read/write JSON files. Similarly to {{XmlSource}}/{{XmlSink}}, these be

[jira] [Updated] (BEAM-1581) JSON source and sink

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1581: Description: JSON source and sink to read/write JSON files. Similarly to {{XmlSource}}/{{XmlSink}}, these be

[jira] [Updated] (BEAM-1581) JSON source and sink

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1581: Description: JSON source and sink to read/write JSON files. Similarly to {{XmlSource}}/{{XmlSink}}, these be

[jira] [Updated] (BEAM-1581) JSON source and sink

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1581: Description: JSON source and sink to read/write JSON files. Similarly to {{XmlSource}}/{{XmlSink}}, these be

[jira] [Assigned] (BEAM-1858) improve error message when Create.of() is called with an empty iterator

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1858: --- Assignee: Davor Bonaci (was: Frances Perry) > improve error message when Create.of() is called with

[jira] [Updated] (BEAM-1858) improve error message when Create.of() is called with an empty iterator

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1858: Priority: Trivial (was: Major) > improve error message when Create.of() is called with an empty iterator >

[jira] [Updated] (BEAM-1858) improve error message when Create.of() is called with an empty iterator

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1858: Component/s: (was: beam-model) sdk-java-core > improve error message when Create.of()

[GitHub] beam pull request #2402: Add example to BoundedCountingInput javadoc

2017-04-01 Thread wtanaka
GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2402 Add example to BoundedCountingInput javadoc You can merge this pull request into a Git repository by running: $ git pull https://github.com/wtanaka/beam example Alternatively you can review

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1472

2017-04-01 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #258

2017-04-01 Thread Apache Jenkins Server
See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam5 (beam) in workspace

[jira] [Created] (BEAM-1858) improve error message when Create.of() is called with an empty iterator

2017-04-01 Thread Wesley Tanaka (JIRA)
Wesley Tanaka created BEAM-1858: --- Summary: improve error message when Create.of() is called with an empty iterator Key: BEAM-1858 URL: https://issues.apache.org/jira/browse/BEAM-1858 Project: Beam

[GitHub] beam pull request #2401: New copy for error when Create called w/zero items

2017-04-01 Thread wtanaka
GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2401 New copy for error when Create called w/zero items You can merge this pull request into a Git repository by running: $ git pull https://github.com/wtanaka/beam master Alternatively you can

[jira] [Commented] (BEAM-1843) 'PDone' object has no attribute 'to_runner_api'

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952367#comment-15952367 ] ASF GitHub Bot commented on BEAM-1843: -- GitHub user robertwb opened a pull request:

[GitHub] beam pull request #2400: [BEAM-1843] Avoid Runner API translation of pipelin...

2017-04-01 Thread robertwb
GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/2400 [BEAM-1843] Avoid Runner API translation of pipelines with PDone. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Assigned] (BEAM-302) Add Scio Scala DSL to Beam

2017-04-01 Thread Neville Li (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neville Li reassigned BEAM-302: --- Assignee: (was: Neville Li) > Add Scio Scala DSL to Beam > -- > >

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1471

2017-04-01 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #257

2017-04-01 Thread Apache Jenkins Server
See -- [...truncated 270.29 KB...] * [new ref] refs/pull/928/head -> origin/pr/928/head * [new ref] refs/pull/929/head -> origin/pr/929/head * [new ref]

[jira] [Created] (BEAM-1857) Add Neo4jIO

2017-04-01 Thread kassem shehady (JIRA)
kassem shehady created BEAM-1857: Summary: Add Neo4jIO Key: BEAM-1857 URL: https://issues.apache.org/jira/browse/BEAM-1857 Project: Beam Issue Type: New Feature Components:

[jira] [Commented] (BEAM-1848) GroupByKey stuck with more than one worker on Dataflow

2017-04-01 Thread peay (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952249#comment-15952249 ] peay commented on BEAM-1848: Indeed, the issue is gone. Thanks for looking into it so quickly -- I hadn't

Build failed in Jenkins: beam_PerformanceTests_Dataflow #256

2017-04-01 Thread Apache Jenkins Server
See Changes: [aviemzur] [BEAM-1337] Infer state coders [kirpichov] [BEAM-1855] Support Splittable DoFn on Flink Runner -- [...truncated 271.44 KB...] *

[jira] [Assigned] (BEAM-1603) Enable programmatic execution of spark pipelines.

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1603: --- Assignee: (was: Aviem Zur) > Enable programmatic execution of spark pipelines. >

[jira] [Commented] (BEAM-1856) HDFSFileSink class do not use the same configuration in master and slave

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952151#comment-15952151 ] ASF GitHub Bot commented on BEAM-1856: -- GitHub user 397090770 opened a pull request:

[GitHub] beam pull request #2399: [BEAM-1856]

2017-04-01 Thread 397090770
GitHub user 397090770 opened a pull request: https://github.com/apache/beam/pull/2399 [BEAM-1856] As described in [BEAM-1856](https://issues.apache.org/jira/browse/BEAM-1856) `HDFSFileSink` class do not use the same configuration in master thread and slave thread. You can merge

[jira] [Commented] (BEAM-1856) HDFSFileSink class do not use the same configuration in master and slave

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952146#comment-15952146 ] ASF GitHub Bot commented on BEAM-1856: -- Github user 397090770 closed the pull request at:

[GitHub] beam pull request #2398: [BEAM-1856]HDFSFileSink class do not use the same c...

2017-04-01 Thread 397090770
Github user 397090770 closed the pull request at: https://github.com/apache/beam/pull/2398 --- 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 feature is

[jira] [Commented] (BEAM-1856) HDFSFileSink class do not use the same configuration in master and slave

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952145#comment-15952145 ] ASF GitHub Bot commented on BEAM-1856: -- GitHub user 397090770 opened a pull request:

[GitHub] beam pull request #2398: [BEAM-1856]HDFSFileSink class do not use the same c...

2017-04-01 Thread 397090770
GitHub user 397090770 opened a pull request: https://github.com/apache/beam/pull/2398 [BEAM-1856]HDFSFileSink class do not use the same configuration in master and slave As described in [BEAM-1856](https://issues.apache.org/jira/browse/BEAM-1856),`HDFSFileSink` class do not use

[jira] [Created] (BEAM-1856) HDFSFileSink class do not use the same configuration in master and slave

2017-04-01 Thread yangping wu (JIRA)
yangping wu created BEAM-1856: - Summary: HDFSFileSink class do not use the same configuration in master and slave Key: BEAM-1856 URL: https://issues.apache.org/jira/browse/BEAM-1856 Project: Beam

[jira] [Updated] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environmen variable

2017-04-01 Thread yangping wu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangping wu updated BEAM-1491: -- Affects Version/s: (was: 0.5.0) 0.6.0 > HDFSFileSource should be able to read

[jira] [Updated] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environmen variable

2017-04-01 Thread yangping wu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangping wu updated BEAM-1491: -- Description: Currently, if we want to read file store on HDFS, we will do it as follow: {code}

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #3126

2017-04-01 Thread Apache Jenkins Server
See

[jira] [Resolved] (BEAM-1855) Support Splittable DoFn in Flink runner

2017-04-01 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov resolved BEAM-1855. Resolution: Fixed Fix Version/s: First stable release > Support Splittable DoFn in

[1/2] beam git commit: [BEAM-1855] Support Splittable DoFn on Flink Runner

2017-04-01 Thread jkff
Repository: beam Updated Branches: refs/heads/master e31ca8b0d -> ea33e3373 [BEAM-1855] Support Splittable DoFn on Flink Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5824bb4b Tree:

[GitHub] beam pull request #2235: Initial version of Flink Streaming Splittable DoFn ...

2017-04-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2235 --- 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 feature is

[2/2] beam git commit: This closes #2235

2017-04-01 Thread jkff
This closes #2235 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ea33e337 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ea33e337 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ea33e337 Branch:

[jira] [Created] (BEAM-1855) Support Splittable DoFn in Flink runner

2017-04-01 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-1855: -- Summary: Support Splittable DoFn in Flink runner Key: BEAM-1855 URL: https://issues.apache.org/jira/browse/BEAM-1855 Project: Beam Issue Type: New

[jira] [Resolved] (BEAM-1337) Use our coder infrastructure for coders for state

2017-04-01 Thread Aviem Zur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1337. - Resolution: Fixed Fix Version/s: First stable release > Use our coder infrastructure for coders for

[jira] [Commented] (BEAM-1337) Use our coder infrastructure for coders for state

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

[1/2] beam git commit: [BEAM-1337] Infer state coders

2017-04-01 Thread aviemzur
Repository: beam Updated Branches: refs/heads/master 03dce6dcc -> e31ca8b0d [BEAM-1337] Infer state coders Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/42e690e8 Tree:

[GitHub] beam pull request #2133: [BEAM-1337] Infer state coders

2017-04-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2133 --- 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 feature is

[2/2] beam git commit: This closes #2133

2017-04-01 Thread aviemzur
This closes #2133 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e31ca8b0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e31ca8b0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e31ca8b0 Branch:

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3125

2017-04-01 Thread Apache Jenkins Server
See

[jira] [Updated] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environmen variable

2017-04-01 Thread yangping wu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangping wu updated BEAM-1491: -- Description: Currently, if we want to read file store on HDFS, we will do it as follow: {code}

Build failed in Jenkins: beam_PerformanceTests_Dataflow #255

2017-04-01 Thread Apache Jenkins Server
See Changes: [kirpichov] KafkaIO : Add withTopic() api that takes single topic. [tgroh] Separate View Evaluation and Overrides [robertwb] Only encode PCollection outputs in Runner API protos.