Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Spark #519

See

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Spark #519

See

[jira] [Assigned] (BEAM-1146) Decrease spark runner startup overhead

[ https://issues.apache.org/jira/browse/BEAM-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1146: --- Assignee: Aviem Zur (was: Amit Sela) > Decrease spark runner startup overhead >

[jira] [Assigned] (BEAM-1145) Remove classifier from shaded spark runner artifact

[ https://issues.apache.org/jira/browse/BEAM-1145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1145: --- Assignee: Aviem Zur (was: Amit Sela) > Remove classifier from shaded spark runner artifact >

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

[ https://issues.apache.org/jira/browse/BEAM-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1144: --- Assignee: Aviem Zur (was: Amit Sela) > Spark runner fails to deserialize MicrobatchSource in cluster

[jira] [Updated] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.

[ https://issues.apache.org/jira/browse/BEAM-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1194: -- Description: Cloud Dataflow has a minor history of small bugs related to various code paths

[jira] [Created] (BEAM-1195) Give triggers URNs / JSON formats

Kenneth Knowles created BEAM-1195: - Summary: Give triggers URNs / JSON formats Key: BEAM-1195 URL: https://issues.apache.org/jira/browse/BEAM-1195 Project: Beam Issue Type: New Feature

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

[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767972#comment-15767972 ] ASF GitHub Bot commented on BEAM-115: - GitHub user kennknowles reopened a pull request:

[jira] [Resolved] (BEAM-1178) Make naming of logger objects consistent

[ https://issues.apache.org/jira/browse/BEAM-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1178. Resolution: Fixed > Make naming of logger objects consistent >

[jira] [Reopened] (BEAM-1178) Make naming of logger objects consistent

[ https://issues.apache.org/jira/browse/BEAM-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reopened BEAM-1178: > Make naming of logger objects consistent > > >

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #84

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

[jira] [Comment Edited] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist

[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767818#comment-15767818 ] Daniel Halperin edited comment on BEAM-1190 at 12/21/16 6:46 PM: - Not for

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Apex #87

See

[jira] [Created] (BEAM-1196) Serialize/deserialize Pipeline/TransformHierarchy to JSON

Kenneth Knowles created BEAM-1196: - Summary: Serialize/deserialize Pipeline/TransformHierarchy to JSON Key: BEAM-1196 URL: https://issues.apache.org/jira/browse/BEAM-1196 Project: Beam Issue

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

[ https://issues.apache.org/jira/browse/BEAM-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767806#comment-15767806 ] ASF GitHub Bot commented on BEAM-362: - Github user asfgit closed the pull request at:

[3/3] incubator-beam git commit: This closes #1666: Move ExecutionContext and related classes to runners-core

This closes #1666: Move ExecutionContext and related classes to runners-core Move ExecutionContext and related classes to runners-core Update Dataflow worker to beam-master-20161221 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org

[jira] [Commented] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist

[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767871#comment-15767871 ] Eugene Kirpichov commented on BEAM-1190: My proposal is to add a mandatory stat at glob-expand time

[2/2] incubator-beam git commit: This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals

This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7ee8c86d Tree:

[jira] [Created] (BEAM-1193) Give Coders URNs and document their binary formats outside the Java code base

Kenneth Knowles created BEAM-1193: - Summary: Give Coders URNs and document their binary formats outside the Java code base Key: BEAM-1193 URL: https://issues.apache.org/jira/browse/BEAM-1193 Project:

[jira] [Updated] (BEAM-1192) Give transforms URNs, use them instead of instanceof checks

[ https://issues.apache.org/jira/browse/BEAM-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1192: -- Issue Type: New Feature (was: Improvement) > Give transforms URNs, use them instead of

[jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers

[ https://issues.apache.org/jira/browse/BEAM-27?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767732#comment-15767732 ] ASF GitHub Bot commented on BEAM-27: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #1673: [BEAM-27] Require TimeDomain to delete a ...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1673 --- 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] [Commented] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist

[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767818#comment-15767818 ] Daniel Halperin commented on BEAM-1190: --- Not for very long -- the stat at open-time is getting

[GitHub] incubator-beam pull request #662: [BEAM-115] WIP: JSON Schema definition of ...

GitHub user kennknowles reopened a pull request: https://github.com/apache/incubator-beam/pull/662 [BEAM-115] WIP: JSON Schema definition of pipeline This is a json-schema sketch of the concrete schema from the [Pipeline Runner API proposal

[jira] [Reopened] (BEAM-1165) Unexpected file created when checking dependencies on clean repo

[ https://issues.apache.org/jira/browse/BEAM-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reopened BEAM-1165: > Unexpected file created when checking dependencies on clean repo >

[jira] [Resolved] (BEAM-1165) Unexpected file created when checking dependencies on clean repo

[ https://issues.apache.org/jira/browse/BEAM-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1165. Resolution: Fixed > Unexpected file created when checking dependencies on clean repo >

[jira] [Created] (BEAM-1192) Add URNs to known transforms instead of using instanceof checks

Kenneth Knowles created BEAM-1192: - Summary: Add URNs to known transforms instead of using instanceof checks Key: BEAM-1192 URL: https://issues.apache.org/jira/browse/BEAM-1192 Project: Beam

[jira] [Resolved] (BEAM-430) Introducing gcpTempLocation that default to tempLocation

[ https://issues.apache.org/jira/browse/BEAM-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-430. Resolution: Fixed > Introducing gcpTempLocation that default to tempLocation >

[jira] [Closed] (BEAM-430) Introducing gcpTempLocation that default to tempLocation

[ https://issues.apache.org/jira/browse/BEAM-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-430. -- > Introducing gcpTempLocation that default to tempLocation >

[jira] [Updated] (BEAM-430) Introducing gcpTempLocation that default to tempLocation

[ https://issues.apache.org/jira/browse/BEAM-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-430: --- Labels: backward-incompatible (was: ) > Introducing gcpTempLocation that default to tempLocation >

[jira] [Reopened] (BEAM-430) Introducing gcpTempLocation that default to tempLocation

[ https://issues.apache.org/jira/browse/BEAM-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reopened BEAM-430: > Introducing gcpTempLocation that default to tempLocation >

[jira] [Updated] (BEAM-1192) Give transforms URNs, use them instead of instanceof checks

[ https://issues.apache.org/jira/browse/BEAM-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1192: -- Summary: Give transforms URNs, use them instead of instanceof checks (was: Add URNs to known

[jira] [Commented] (BEAM-1190) FileBasedSource should ignore files that matched the glob but don't exist

[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767937#comment-15767937 ] Daniel Halperin commented on BEAM-1190: --- I do not think this is generally safe -- it may mask

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2195

See

[1/3] incubator-beam git commit: Move ExecutionContext and related classes to runners-core

Repository: incubator-beam Updated Branches: refs/heads/master 4843dc59c -> a9447a225 Move ExecutionContext and related classes to runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d2b8e09

[2/3] incubator-beam git commit: Update Dataflow worker to beam-master-20161221

Update Dataflow worker to beam-master-20161221 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/64336e40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/64336e40 Diff: http://git-wip

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #85

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #86

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

[1/2] incubator-beam git commit: Require TimeDomain to delete a timer

Repository: incubator-beam Updated Branches: refs/heads/master 0d0a5e287 -> 4843dc59c Require TimeDomain to delete a timer Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/35a02740 Tree:

[2/2] incubator-beam git commit: This closes #1673: Require TimeDomain to delete a timer

This closes #1673: Require TimeDomain to delete a timer Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4843dc59 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4843dc59 Diff:

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #83

See -- [...truncated 388 lines...] + e6442d2...9680e87 refs/pull/1522/merge -> origin/pr/1522/merge (forced update) + e880c72...164001b refs/pull/1526/head ->

[1/2] incubator-beam git commit: Support set and delete of timer by ID in InMemoryTimerInternals

Repository: incubator-beam Updated Branches: refs/heads/master a9447a225 -> 7ee8c86d3 Support set and delete of timer by ID in InMemoryTimerInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #1660: [BEAM-27] Support setting and deleting ti...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1660 --- 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] [Commented] (BEAM-27) Add user-ready API for interacting with timers

[ https://issues.apache.org/jira/browse/BEAM-27?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767897#comment-15767897 ] ASF GitHub Bot commented on BEAM-27: Github user asfgit closed the pull request at:

[jira] [Created] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.

Daniel Halperin created BEAM-1194: - Summary: DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats. Key: BEAM-1194 URL: https://issues.apache.org/jira/browse/BEAM-1194

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Gearpump #156

See Changes: [ansela] [BEAM-1000, BEAM-1050] Fixed PipelineResult.State Failed for streaming, [ansela] Redistributed some responsibilities in order to remove [klk] Update Dataflow worker to

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Gearpump #156

See Changes: [ansela] [BEAM-1000, BEAM-1050] Fixed PipelineResult.State Failed for streaming, [ansela] Redistributed some responsibilities in order to remove [klk] Update Dataflow worker to

[12/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fce4f658 Tree:

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #2196

See

Re: Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2195

This was a manual invocation, which somehow causes an email to the commits list even though it was not run against master. Please ignore. Context: [BEAM-1194] On Wed, Dec 21, 2016 at 11:41 AM, Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See

[jira] [Updated] (BEAM-846) Decouple side input window mapping from WindowFn

[ https://issues.apache.org/jira/browse/BEAM-846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-846: - Component/s: (was: beam-model) > Decouple side input window mapping from WindowFn >

[jira] [Created] (BEAM-1199) Condense recordAsOutput, finishSpecifyingOutput from POutput

Thomas Groh created BEAM-1199: - Summary: Condense recordAsOutput, finishSpecifyingOutput from POutput Key: BEAM-1199 URL: https://issues.apache.org/jira/browse/BEAM-1199 Project: Beam Issue

[jira] [Commented] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.

[ https://issues.apache.org/jira/browse/BEAM-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768284#comment-15768284 ] ASF GitHub Bot commented on BEAM-1194: -- Github user dhalperi closed the pull request at:

[jira] [Commented] (BEAM-1117) Support for new Timer API in Direct runner

[ https://issues.apache.org/jira/browse/BEAM-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768294#comment-15768294 ] ASF GitHub Bot commented on BEAM-1117: -- Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #1676: Merge remote-tracking branch 'origin/mast...

GitHub user aaltay opened a pull request: https://github.com/apache/incubator-beam/pull/1676 Merge remote-tracking branch 'origin/master' into python-sdk There are frequent Apex runner failures the python-sdk branch, bringing up pom.xml changes to update those. You can merge this

[jira] [Created] (BEAM-1197) Slowly-changing external data as a side input

Eugene Kirpichov created BEAM-1197: -- Summary: Slowly-changing external data as a side input Key: BEAM-1197 URL: https://issues.apache.org/jira/browse/BEAM-1197 Project: Beam Issue Type:

[jira] [Closed] (BEAM-1003) Enable caching of side-input dependent computations

[ https://issues.apache.org/jira/browse/BEAM-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-1003. - Resolution: Duplicate Fix Version/s: Not applicable Looks like an exact duplicate, a la

[jira] [Updated] (BEAM-260) WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources

[ https://issues.apache.org/jira/browse/BEAM-260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-260: - Component/s: (was: beam-model) beam-model-fn-api > WindowMappingFn: Know the

[jira] [Updated] (BEAM-210) Allow control of empty ON_TIME panes analogous to final panes

[ https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-210: - Component/s: (was: beam-model) > Allow control of empty ON_TIME panes analogous to final panes

[jira] [Assigned] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping

[ https://issues.apache.org/jira/browse/BEAM-1198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1198: - Assignee: Kenneth Knowles > ViewFn: explicitly decouple runner materialization of side

[jira] [Created] (BEAM-1198) ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping

Kenneth Knowles created BEAM-1198: - Summary: ViewFn: explicitly decouple runner materialization of side inputs from SDK-specific mapping Key: BEAM-1198 URL: https://issues.apache.org/jira/browse/BEAM-1198

[GitHub] incubator-beam pull request #1670: [BEAM-25, BEAM-1117] Fixes for direct run...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1670 --- 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] [Commented] (BEAM-25) Add user-ready API for interacting with state

[ https://issues.apache.org/jira/browse/BEAM-25?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768175#comment-15768175 ] ASF GitHub Bot commented on BEAM-25: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #1677: Add a Test for Flatten with Heterogeneous...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1677 Add a Test for Flatten with Heterogeneous Coders Add a category, and suppress in the Flink and Apex runners Be sure to do all of the following to help us incorporate your

[49/50] incubator-beam git commit: [BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT

[BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/647034cf Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/647034cf Diff:

[40/50] incubator-beam git commit: This closes #1659: More escaping in Jenkins timestamp spec

This closes #1659: More escaping in Jenkins timestamp spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d13f11f8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d13f11f8 Diff:

[02/50] incubator-beam git commit: Make {Metric, Counter, Distribution}Cell public

Make {Metric,Counter,Distribution}Cell public These classes may be useful to hold on to within a runner where the step context is known to be unchanging and there may be a desire to avoid the extra indirection of using {Counter,Distribution} directly. Project:

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768076#comment-15768076 ] ASF GitHub Bot commented on BEAM-79: Github user asfgit closed the pull request at:

[44/50] incubator-beam git commit: [BEAM-59] initial interfaces and classes of Beam FileSystem

[BEAM-59] initial interfaces and classes of Beam FileSystem This closes #1558 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/28d7913b Tree:

[30/50] incubator-beam git commit: [BEAM-1165] Fix unexpected file creation when checking dependencies

[BEAM-1165] Fix unexpected file creation when checking dependencies This error happens because maven-dependency-plugin asumes the property output used by the flink tests as the export file for the depedency:tree command. Ref.

[15/50] incubator-beam git commit: Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest

Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b78aa669 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b78aa669 Diff:

[01/50] incubator-beam git commit: Closes #1622

Repository: incubator-beam Updated Branches: refs/heads/gearpump-runner b6e7bb659 -> 4c445dd0b Closes #1622 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1ee191fb Tree:

[43/50] incubator-beam git commit: [BEAM-59] initial interfaces and classes of Beam FileSystem.

[BEAM-59] initial interfaces and classes of Beam FileSystem. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/467f7d17 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/467f7d17 Diff:

[jira] [Updated] (BEAM-260) WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources

[ https://issues.apache.org/jira/browse/BEAM-260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-260: - Summary: WindowMappingFn: Know the getSideInputWindow upper bound to release side input resources

[jira] [Updated] (BEAM-653) Refine specification for WindowFn.isCompatible()

[ https://issues.apache.org/jira/browse/BEAM-653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-653: - Component/s: beam-model-runner-api > Refine specification for WindowFn.isCompatible() >

[jira] [Updated] (BEAM-1193) Give Coders URNs and document their binary formats outside the Java code base

[ https://issues.apache.org/jira/browse/BEAM-1193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1193: -- Component/s: (was: beam-model) > Give Coders URNs and document their binary formats outside

[jira] [Comment Edited] (BEAM-846) Decouple side input window mapping from WindowFn

[ https://issues.apache.org/jira/browse/BEAM-846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15613384#comment-15613384 ] Kenneth Knowles edited comment on BEAM-846 at 12/21/16 9:19 PM: Design

[GitHub] incubator-beam pull request #1671: [BEAM-1194] Add DataflowLocationIT

GitHub user dhalperi reopened a pull request: https://github.com/apache/incubator-beam/pull/1671 [BEAM-1194] Add DataflowLocationIT Opening PR to test. You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam

[GitHub] incubator-beam pull request #1671: [BEAM-1194] Add DataflowLocationIT

Github user dhalperi closed the pull request at: https://github.com/apache/incubator-beam/pull/1671 --- 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] [Created] (BEAM-1200) PubsubIO should allow for a user to supply the function which computes the watermark that is reported

Luke Cwik created BEAM-1200: --- Summary: PubsubIO should allow for a user to supply the function which computes the watermark that is reported Key: BEAM-1200 URL: https://issues.apache.org/jira/browse/BEAM-1200

[GitHub] incubator-beam pull request #1663: [BEAM-79] merge master into gearpump-runn...

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

[35/50] incubator-beam git commit: Fix seed job fetch spec

Fix seed job fetch spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2148adb8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2148adb8 Diff:

[41/50] incubator-beam git commit: Change counter name in TestDataflowRunner

Change counter name in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a2f44923 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a2f44923 Diff:

[14/50] incubator-beam git commit: Add timer support to DoFnRunner(s)

Add timer support to DoFnRunner(s) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8af13b01 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8af13b01 Diff:

[16/50] incubator-beam git commit: [BEAM-853] Force streaming execution on batch pipelines for testing. Expose the adapted source.

[BEAM-853] Force streaming execution on batch pipelines for testing. Expose the adapted source. Force streaming execution, if set in PipelineOptions. Added test. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[28/50] incubator-beam git commit: [BEAM-716] This closes #1577

[BEAM-716] This closes #1577 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1e148cd7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1e148cd7 Diff:

[33/50] incubator-beam git commit: Show timestamps on log lines in Jenkins

Show timestamps on log lines in Jenkins Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d964734 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4d964734 Diff:

[20/50] incubator-beam git commit: Change counter name in TestDataflowRunner

Change counter name in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b055d2d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b055d2d Diff:

[37/50] incubator-beam git commit: Add RunnableOnService test for Metrics

Add RunnableOnService test for Metrics Add UsesMetrics interface and exclude from runners that don't yet support Metrics Add Serializability as needed for Metrics to be created during pipeline construction Remove test from DirectRunnerTest Project:

[46/50] incubator-beam git commit: Closes #1656

Closes #1656 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b3de17b3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b3de17b3 Diff:

[18/50] incubator-beam git commit: Closes #1651

Closes #1651 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5255a338 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5255a338 Diff:

[08/50] incubator-beam git commit: Revert "Removes code for wrapping DoFn as an OldDoFn"

Revert "Removes code for wrapping DoFn as an OldDoFn" This reverts commit a22de15012c51e8b7e31143021f0a298e093bf51. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a12fd8c5 Tree:

[36/50] incubator-beam git commit: This closes #1657: Fix seed job fetch spec

This closes #1657: Fix seed job fetch spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/66318d82 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/66318d82 Diff:

[04/50] incubator-beam git commit: Closes #1649

Closes #1649 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/abdbee61 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/abdbee61 Diff:

[39/50] incubator-beam git commit: More escaping in Jenkins timestamp spec

More escaping in Jenkins timestamp spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/627ccb52 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/627ccb52 Diff:

[32/50] incubator-beam git commit: This closes #1655: [BEAM-1178] Make naming of logger objects consistent

This closes #1655: [BEAM-1178] Make naming of logger objects consistent [BEAM-1178] Make naming of logger objects consistent Fix grammar error (repeated for) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[38/50] incubator-beam git commit: Closes #1638

Closes #1638 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a972b233 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a972b233 Diff:

[05/50] incubator-beam git commit: Revert "Move InMemoryTimerInternals to runners-core"

Revert "Move InMemoryTimerInternals to runners-core" This reverts commit ec0bf7b4023ff75f4ec6723d2e77ed507eb57c51. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/45ed5c70 Tree:

[25/50] incubator-beam git commit: Fix grammar error (repeated for)

Fix grammar error (repeated for) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fbfea595 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fbfea595 Diff:

[45/50] incubator-beam git commit: Disable automatic archiving of Maven builds

Disable automatic archiving of Maven builds >From the Web UI: > If checked, Jenkins will not automatically archive all artifacts generated by > this project. If you wish to archive the results of this build within > Jenkins, you will need to use the "Archive the artifacts" post-build action >

  1   2   3   >