[GitHub] incubator-beam pull request: Implement BigQueryIO.Write as a custo...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/48 Implement BigQueryIO.Write as a custom sink. commit: "Move tempLocation to PipelineOptions." is sent out as a separate pull request. I am including it to have diff base, and will remove it

[jira] [Updated] (BEAM-115) Beam Runner API

[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-115: - Description: The PipelineRunner API from the SDK is not ideal for the Beam technical vision. It has

[jira] [Updated] (BEAM-115) Beam Runner API

[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-115: - Description: The PipelineRunner API from the SDK is not ideal for the Beam technical vision. It has

[jira] [Created] (BEAM-115) Beam Runner API

Kenneth Knowles created BEAM-115: Summary: Beam Runner API Key: BEAM-115 URL: https://issues.apache.org/jira/browse/BEAM-115 Project: Beam Issue Type: Improvement Components: runner

[4/4] incubator-beam git commit: This closes #47

This closes #47 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c0b9fc66 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c0b9fc66 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/d

[GitHub] incubator-beam pull request: Dataflow 1.5.0

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/47 --- 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

[2/4] incubator-beam git commit: Select worker harness container image for release 1.5.0

Select worker harness container image for release 1.5.0 Release Notes [] - Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=116798931 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-b

[1/4] incubator-beam git commit: Version management

Repository: incubator-beam Updated Branches: refs/heads/master c3fbeda6c -> c0b9fc660 Version management Declare version 1.6.0-SNAPSHOT. Release Notes [] - Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=116803966 Project: http://git-wip-us.apache.org/re

[3/4] incubator-beam git commit: Version management for remaining poms

Version management for remaining poms Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8d17dde0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8d17dde0 Diff: http://git-wip-us.apache.org/repo

[GitHub] incubator-beam pull request: Dataflow 1.5.0

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/47 Dataflow 1.5.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam dataflow-1.5.0 Alternatively you can review and

[jira] [Comment Edited] (BEAM-114) Assemble and provide a source distribution

[ https://issues.apache.org/jira/browse/BEAM-114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194498#comment-15194498 ] Jean-Baptiste Onofré edited comment on BEAM-114 at 3/15/16 1:07 AM: --

[jira] [Commented] (BEAM-114) Assemble and provide a source distribution

[ https://issues.apache.org/jira/browse/BEAM-114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194498#comment-15194498 ] Jean-Baptiste Onofré commented on BEAM-114: --- Yes, we should provide a apache-beam-

[jira] [Commented] (BEAM-114) Assemble and provide a source distribution

[ https://issues.apache.org/jira/browse/BEAM-114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194494#comment-15194494 ] Davor Bonaci commented on BEAM-114: --- We can (and should) release the source jars with each

[jira] [Commented] (BEAM-78) Rename Dataflow to Beam

[ https://issues.apache.org/jira/browse/BEAM-78?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194492#comment-15194492 ] ASF GitHub Bot commented on BEAM-78: GitHub user jbonofre opened a pull request: htt

[GitHub] incubator-beam pull request: BEAM-78 - First step of the renaming:...

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/46 BEAM-78 - First step of the renaming: Maven coordonates You can merge this pull request into a Git repository by running: $ git pull https://github.com/jbonofre/incubator-beam RENAMING

[GitHub] incubator-beam pull request: Re-interrupt current thread when igno...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/45 Re-interrupt current thread when ignoring InterruptedException You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam code-cl

[jira] [Created] (BEAM-114) Assemble and provide a source distribution

Jean-Baptiste Onofré created BEAM-114: - Summary: Assemble and provide a source distribution Key: BEAM-114 URL: https://issues.apache.org/jira/browse/BEAM-114 Project: Beam Issue Type: Tas

incubator-beam git commit: Add DISCLAINER and NOTICE files

Repository: incubator-beam Updated Branches: refs/heads/master 45309caec -> c3fbeda6c Add DISCLAINER and NOTICE files Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c3fbeda6 Tree: http://git-wip-us.apach

[GitHub] incubator-beam pull request: Move tempLocation to PipelineOptions.

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/44 Move tempLocation to PipelineOptions. You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam temp-option Alternatively you c

[GitHub] incubator-beam pull request: Move stagingLocation and tempLocation...

Github user peihe closed the pull request at: https://github.com/apache/incubator-beam/pull/31 --- 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 i

[jira] [Created] (BEAM-113) Update Spark runner README

Amit Sela created BEAM-113: -- Summary: Update Spark runner README Key: BEAM-113 URL: https://issues.apache.org/jira/browse/BEAM-113 Project: Beam Issue Type: Improvement Components: runner-

[jira] [Created] (BEAM-112) Using non-IntervalWindows seems to fail

Ben Chambers created BEAM-112: - Summary: Using non-IntervalWindows seems to fail Key: BEAM-112 URL: https://issues.apache.org/jira/browse/BEAM-112 Project: Beam Issue Type: Bug Componen

[jira] [Closed] (BEAM-105) We may attempt to remove an inactive window from the active window set.

[ https://issues.apache.org/jira/browse/BEAM-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shields closed BEAM-105. - Resolution: Fixed > We may attempt to remove an inactive window from the active window set. > --

[jira] [Commented] (BEAM-110) Use SDK implementation for HadoopIO in contrib/hadoop

[ https://issues.apache.org/jira/browse/BEAM-110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193657#comment-15193657 ] Davor Bonaci commented on BEAM-110: --- Similar comment as BEAM-111: It might not be a good

[jira] [Commented] (BEAM-105) We may attempt to remove an inactive window from the active window set.

[ https://issues.apache.org/jira/browse/BEAM-105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193652#comment-15193652 ] Davor Bonaci commented on BEAM-105: --- Fixed? > We may attempt to remove an inactive window

[jira] [Commented] (BEAM-111) Use SDK implementation of WritableCoder

[ https://issues.apache.org/jira/browse/BEAM-111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193651#comment-15193651 ] Davor Bonaci commented on BEAM-111: --- It might not be a good idea for any runner to depend

[jira] [Created] (BEAM-111) Use SDK implementation of WritableCoder

Amit Sela created BEAM-111: -- Summary: Use SDK implementation of WritableCoder Key: BEAM-111 URL: https://issues.apache.org/jira/browse/BEAM-111 Project: Beam Issue Type: Improvement Compon

[jira] [Created] (BEAM-110) Use SDK implementation for HadoopIO in contrib/hadoop

Amit Sela created BEAM-110: -- Summary: Use SDK implementation for HadoopIO in contrib/hadoop Key: BEAM-110 URL: https://issues.apache.org/jira/browse/BEAM-110 Project: Beam Issue Type: Improvement

[GitHub] incubator-beam pull request: BEAM-36 : TimestampedValueInMultipleW...

GitHub user yssharma opened a pull request: https://github.com/apache/incubator-beam/pull/43 BEAM-36 : TimestampedValueInMultipleWindows changes LinkedHashSet to … Minor fix for TimestampedValueInMultipleWindows. Changed LinkedHashSet to HashSet. Checked build with test cases.

[jira] [Commented] (BEAM-36) TimestampedValueInMultipleWindows should use a more compact set representation

[ https://issues.apache.org/jira/browse/BEAM-36?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193064#comment-15193064 ] ASF GitHub Bot commented on BEAM-36: GitHub user yssharma opened a pull request: htt