[jira] [Commented] (BEAM-469) NullableCoder optimized encoding via passthrough context

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

[jira] [Commented] (BEAM-1201) Remove producesSortedKeys from Source

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

[jira] [Updated] (BEAM-1201) Remove producesSortedKeys from Source

2016-12-21 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1201: -- Labels: backward-incompatible (was: ) > Remove producesSortedKeys from Sou

[jira] [Updated] (BEAM-1201) Remove producesSortedKeys from BoundedSource

2016-12-21 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1201: -- Summary: Remove producesSortedKeys from BoundedSource (was: Remove producesSortedKeys from

[jira] [Commented] (BEAM-469) NullableCoder optimized encoding via passthrough context

2016-12-21 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768476#comment-15768476 ] Daniel Halperin commented on BEAM-469: -- Sorry I missed this JIRA comment, [~mariusz89016]! A bit late

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

[jira] [Commented] (BEAM-1112) Python E2E Integration Test Framework - Batch Only

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

[jira] [Commented] (BEAM-1112) Python E2E Integration Test Framework - Batch Only

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768462#comment-15768462 ] ASF GitHub Bot commented on BEAM-1112: -- GitHub user markflyhigh reopened a pull request: https

[jira] [Created] (BEAM-1202) Coders should have meaningful equals methods

2016-12-21 Thread Thomas Groh (JIRA)
Thomas Groh created BEAM-1202: - Summary: Coders should have meaningful equals methods Key: BEAM-1202 URL: https://issues.apache.org/jira/browse/BEAM-1202 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-1202) Coders should have meaningful equals methods

2016-12-21 Thread Thomas Groh (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-1202: -- Assignee: (was: Davor Bonaci) > Coders should have meaningful equals meth

[jira] [Created] (BEAM-1201) Remove producesSortedKeys from Source

2016-12-21 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-1201: - Summary: Remove producesSortedKeys from Source Key: BEAM-1201 URL: https://issues.apache.org/jira/browse/BEAM-1201 Project: Beam Issue Type: Improvement

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

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

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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 s

[jira] [Created] (BEAM-1200) PubsubIO should allow for a user to supply the function which computes the watermark that is reported

2016-12-21 Thread Luke Cwik (JIRA)
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

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

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread Thomas Groh (JIRA)
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] [Comment Edited] (BEAM-846) Decouple side input window mapping from WindowFn

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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 1

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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 pa

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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: K

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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 Windo

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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 outs

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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.isCompati

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1149: -- Component/s: runner-core > Side input access fails in direct runner (possibly others too) w

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread Kenneth Knowles (JIRA)
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

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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] [Commented] (BEAM-79) Gearpump runner

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread Eugene Kirpichov (JIRA)
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] [Updated] (BEAM-430) Introducing gcpTempLocation that default to tempLocation

2016-12-21 Thread Luke Cwik (JIRA)
[ 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 tempLocat

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

2016-12-21 Thread Luke Cwik (JIRA)
[ 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 tempLocat

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

2016-12-21 Thread Luke Cwik (JIRA)
[ 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 tempLocat

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

2016-12-21 Thread Luke Cwik (JIRA)
[ 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 tempLocat

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

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread Daniel Halperin (JIRA)
[ 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

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

2016-12-21 Thread Kenneth Knowles (JIRA)
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] [Created] (BEAM-1195) Give triggers URNs / JSON formats

2016-12-21 Thread Kenneth Knowles (JIRA)
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] [Updated] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.

2016-12-21 Thread Daniel Halperin (JIRA)
[ 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-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats.

2016-12-21 Thread Daniel Halperin (JIRA)
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

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

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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] [Updated] (BEAM-1192) Give transforms URNs, use them instead of instanceof checks

2016-12-21 Thread Kenneth Knowles (JIRA)
[ 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 inst

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

2016-12-21 Thread Kenneth Knowles (JIRA)
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] [Commented] (BEAM-27) Add user-ready API for interacting with timers

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread Eugene Kirpichov (JIRA)
[ 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

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

2016-12-21 Thread Daniel Halperin (JIRA)
[ 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

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

2016-12-21 Thread Daniel Halperin (JIRA)
[ 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

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

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread Kenneth Knowles (JIRA)
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] [Commented] (BEAM-27) Add user-ready API for interacting with timers

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ 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: https

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

2016-12-21 Thread JIRA
[ 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 consist

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

2016-12-21 Thread JIRA
[ 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 consist

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

2016-12-21 Thread JIRA
[ 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 r

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

2016-12-21 Thread JIRA
[ 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 r

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

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

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

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

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

2016-12-21 Thread Aviem Zur (JIRA)
[ 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 artif

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

2016-12-21 Thread Aviem Zur (JIRA)
[ 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 clus

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

2016-12-21 Thread Aviem Zur (JIRA)
[ 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 overh

[jira] [Created] (BEAM-1191) Eliminate OldDoFn from the SDK

2016-12-20 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-1191: - Summary: Eliminate OldDoFn from the SDK Key: BEAM-1191 URL: https://issues.apache.org/jira/browse/BEAM-1191 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-498) Make DoFnWithContext the new DoFn

2016-12-20 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-498. -- Resolution: Fixed Fix Version/s: 0.3.0-incubating > Make DoFnWithContext the new D

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

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

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

2016-12-20 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15766004#comment-15766004 ] Eugene Kirpichov commented on BEAM-1190: Dan - please note I'm suggesting not to ignore non

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

2016-12-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765799#comment-15765799 ] ASF GitHub Bot commented on BEAM-79: GitHub user manuzhang reopened a pull request: https

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

2016-12-20 Thread Paul Findlay (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765711#comment-15765711 ] Paul Findlay commented on BEAM-1190: [~dhalp...@google.com] Correct me if I'm wrong.. but isn't

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

2016-12-20 Thread Paul Findlay (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765711#comment-15765711 ] Paul Findlay edited comment on BEAM-1190 at 12/21/16 12:52 AM: --- [~dhalp

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

2016-12-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765683#comment-15765683 ] Daniel Halperin commented on BEAM-1190: --- The two relevant JIRA issues: [BEAM-76] and [BEAM-60

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

2016-12-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765675#comment-15765675 ] Daniel Halperin commented on BEAM-1190: --- I think this is a very scary default behavior, and something

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

2016-12-20 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765675#comment-15765675 ] Daniel Halperin edited comment on BEAM-1190 at 12/21/16 12:33 AM: -- I think

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

2016-12-20 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765658#comment-15765658 ] Eugene Kirpichov commented on BEAM-1190: CC: [~dhalp...@google.com] [~pei...@gmail.com

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

2016-12-20 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-1190: -- Summary: FileBasedSource should ignore files that matched the glob but don't exist Key: BEAM-1190 URL: https://issues.apache.org/jira/browse/BEAM-1190 Project

[jira] [Updated] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample is flaky

2016-12-20 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1067: -- Summary: apex.examples.WordCountTest.testWordCountExample is flaky

[jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample is be flaky

2016-12-20 Thread Jason Kuster (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765632#comment-15765632 ] Jason Kuster commented on BEAM-1067: https://builds.apache.org/job/beam_PostCommit_Java_MavenInstall

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

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

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

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

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

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

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

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

[jira] [Closed] (BEAM-1097) Dataflow error message for non-existing gcpTempLocation is misleading

2016-12-20 Thread Scott Wegner (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner closed BEAM-1097. -- Resolution: Fixed Fix Version/s: 0.5.0-incubating > Dataflow error message for non-exist

[jira] [Commented] (BEAM-1097) Dataflow error message for non-existing gcpTempLocation is misleading

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

[jira] [Commented] (BEAM-1112) Python E2E Integration Test Framework - Batch Only

2016-12-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765220#comment-15765220 ] ASF GitHub Bot commented on BEAM-1112: -- GitHub user markflyhigh reopened a pull request: https

[jira] [Commented] (BEAM-1112) Python E2E Integration Test Framework - Batch Only

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

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

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

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

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

[jira] [Commented] (BEAM-1189) Add guide for release verifiers in the release guide

2016-12-20 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765117#comment-15765117 ] Jean-Baptiste Onofré commented on BEAM-1189: +1 How to verify artifacts is something

[jira] [Created] (BEAM-1189) Add guide for release verifiers in the release guide

2016-12-20 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-1189: - Summary: Add guide for release verifiers in the release guide Key: BEAM-1189 URL: https://issues.apache.org/jira/browse/BEAM-1189 Project: Beam Issue Type

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

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

[jira] [Updated] (BEAM-1188) More Verifiers For Python E2E Tests

2016-12-20 Thread Mark Liu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-1188: --- Description: Add more basic verifiers in e2e test to verify output data in different storage/fs: 1. File

[jira] [Updated] (BEAM-1188) More Verifiers For Python E2E Tests

2016-12-20 Thread Mark Liu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-1188: --- Description: Add more basic verifiers in e2e test to verify output data in different storage/fs: 1. File

[jira] [Created] (BEAM-1188) More Verifiers For Python E2E Tests

2016-12-20 Thread Mark Liu (JIRA)
Mark Liu created BEAM-1188: -- Summary: More Verifiers For Python E2E Tests Key: BEAM-1188 URL: https://issues.apache.org/jira/browse/BEAM-1188 Project: Beam Issue Type: Task Components

[jira] [Updated] (BEAM-1187) GCP Transport not performing timed backoff after connection failure

2016-12-20 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-1187: --- Assignee: Pei He (was: Davor Bonaci) > GCP Transport not performing timed backoff after connect

[jira] [Reopened] (BEAM-1186) Migrate the remaining tests to use TestPipeline as a JUnit rule.

2016-12-20 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reopened BEAM-1186: --- > Migrate the remaining tests to use TestPipeline as a JUnit r

[jira] [Resolved] (BEAM-1176) Make our test suites use @Rule TestPipeline

2016-12-20 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1176. --- Resolution: Fixed Fix Version/s: 0.5.0-incubating > Make our test suites use @R

[jira] [Resolved] (BEAM-1186) Migrate the remaining tests to use TestPipeline as a JUnit rule.

2016-12-20 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1186. --- Resolution: Fixed Fix Version/s: 0.5.0-incubating > Migrate the remaining tests to

[jira] [Commented] (BEAM-1176) Make our test suites use @Rule TestPipeline

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

[jira] [Created] (BEAM-1187) GCP Transport not performing timed backoff after connection failure

2016-12-20 Thread Luke Cwik (JIRA)
Luke Cwik created BEAM-1187: --- Summary: GCP Transport not performing timed backoff after connection failure Key: BEAM-1187 URL: https://issues.apache.org/jira/browse/BEAM-1187 Project: Beam Issue

[jira] [Commented] (BEAM-1176) Make our test suites use @Rule TestPipeline

2016-12-20 Thread Stas Levin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764919#comment-15764919 ] Stas Levin commented on BEAM-1176: -- Sounds good, enter [BEAM-1186|https://issues.apache.org/jira/browse

[jira] [Created] (BEAM-1186) Migrate the remaining tests to use TestPipeline as a JUnit rule.

2016-12-20 Thread Stas Levin (JIRA)
Stas Levin created BEAM-1186: Summary: Migrate the remaining tests to use TestPipeline as a JUnit rule. Key: BEAM-1186 URL: https://issues.apache.org/jira/browse/BEAM-1186 Project: Beam Issue

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

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

[jira] [Commented] (BEAM-980) Document how to configure the DAG created by Apex Runner

2016-12-20 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764783#comment-15764783 ] Thomas Weise commented on BEAM-980: --- The runner should probably have an option to specify a configuration

  1   2   3   4   5   6   7   8   9   10   >