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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #258

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

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

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'

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

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

[ 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

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #257

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

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

[ 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

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.

[ 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

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

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

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

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

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

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

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

[ 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

[ 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

See

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

[ 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

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

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

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

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

[ 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

[ 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

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

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

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

See

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

[ 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

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.