[jira] [Commented] (BEAM-1325) DataflowRunner support for Class-Path jars

[ https://issues.apache.org/jira/browse/BEAM-1325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839880#comment-15839880 ] Luke Cwik commented on BEAM-1325: - We can recursively look at the "Class-Path" manifest of each jar, seeded

[jira] [Comment Edited] (BEAM-1325) DataflowRunner support for Class-Path jars

[ https://issues.apache.org/jira/browse/BEAM-1325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839821#comment-15839821 ] Luke Cwik edited comment on BEAM-1325 at 1/26/17 3:07 PM: -- Its not just that the

[jira] [Commented] (BEAM-1325) DataflowRunner support for Class-Path jars

[ https://issues.apache.org/jira/browse/BEAM-1325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839821#comment-15839821 ] Luke Cwik commented on BEAM-1325: - Its not just that the Class-Path should be understood and added to

[jira] [Resolved] (BEAM-708) Migrate BoundedReadFromUnboundedSource to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-708. Resolution: Fixed Assignee: Kai Jiang (was: Davor Bonaci) Fix Version/s: 0.5.0 > Migrate

[jira] [Comment Edited] (BEAM-1223) Add static factory methods for Sum.[*]Fn classes

[ https://issues.apache.org/jira/browse/BEAM-1223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815469#comment-15815469 ] Luke Cwik edited comment on BEAM-1223 at 1/10/17 4:47 PM: -- Interfaces and base

[jira] [Created] (BEAM-1266) Use full windowed value representations within Dataflow job representation

Luke Cwik created BEAM-1266: --- Summary: Use full windowed value representations within Dataflow job representation Key: BEAM-1266 URL: https://issues.apache.org/jira/browse/BEAM-1266 Project: Beam

[jira] [Closed] (BEAM-1266) Use full windowed value representations within Dataflow job representation

[ https://issues.apache.org/jira/browse/BEAM-1266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-1266. --- Resolution: Fixed Fix Version/s: 0.5.0 > Use full windowed value representations within Dataflow job

[jira] [Commented] (BEAM-849) Redesign PipelineResult API

[ https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15812425#comment-15812425 ] Luke Cwik commented on BEAM-849: [~staslev], a user needs to understand that a Pipeline will be executing

[jira] [Updated] (BEAM-1231) Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix

[ https://issues.apache.org/jira/browse/BEAM-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-1231: Description: Add support for using kind for well known coder types in Apache Beam for Java The following

[jira] [Created] (BEAM-1231) Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix

Luke Cwik created BEAM-1231: --- Summary: Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix Key: BEAM-1231 URL: https://issues.apache.org/jira/browse/BEAM-1231 Project: Beam

[jira] [Commented] (BEAM-1210) PipelineRunners should receive a copy of PipelineOptions rather than the original Options

[ https://issues.apache.org/jira/browse/BEAM-1210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15783848#comment-15783848 ] Luke Cwik commented on BEAM-1210: - This won't be trivial since there are some types of options which are

[jira] [Assigned] (BEAM-1208) Visibility of Sum.SumIntegerFn/Sum.SumDoubleFn/Sum.SumYYYFn should be reduced

[ https://issues.apache.org/jira/browse/BEAM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-1208: --- Assignee: Luke Cwik (was: Davor Bonaci) > Visibility of

[jira] [Created] (BEAM-1208) Visibility of Sum.SumIntegerFn/Sum.SumDoubleFn/Sum.SumYYYFn should be reduced

Luke Cwik created BEAM-1208: --- Summary: Visibility of Sum.SumIntegerFn/Sum.SumDoubleFn/Sum.SumYYYFn should be reduced Key: BEAM-1208 URL: https://issues.apache.org/jira/browse/BEAM-1208 Project: Beam

[jira] [Assigned] (BEAM-464) HolderCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-464: -- Assignee: (was: Luke Cwik) > HolderCoder should be a StandardCoder and not a CustomCoder >

[jira] [Commented] (BEAM-1930) Abstract Coder translation from Runner API Protos

[ https://issues.apache.org/jira/browse/BEAM-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964647#comment-15964647 ] Luke Cwik commented on BEAM-1930: - I think with Jackson/ObjectMapper you could do the same thing and have

[jira] [Commented] (BEAM-1283) DoFn finishBundle should be required to specify the window

[ https://issues.apache.org/jira/browse/BEAM-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957382#comment-15957382 ] Luke Cwik commented on BEAM-1283: - I don't think the Fn API really is interested in whether an SDK exposes

[jira] [Commented] (BEAM-463) BoundedHeapCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963790#comment-15963790 ] Luke Cwik commented on BEAM-463: The motivation was about getting introspection into the coder components,

[jira] [Commented] (BEAM-2021) Fix Java's Coder class hierarchy

[ https://issues.apache.org/jira/browse/BEAM-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977506#comment-15977506 ] Luke Cwik commented on BEAM-2021: - I believe CoderEncoder interface lives in core construction (or another

[jira] [Commented] (BEAM-1786) AutoService registration of coders, like we do with PipelineRunners

[ https://issues.apache.org/jira/browse/BEAM-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977572#comment-15977572 ] Luke Cwik commented on BEAM-1786: - Users should look at

[jira] [Resolved] (BEAM-1786) AutoService registration of coders, like we do with PipelineRunners

[ https://issues.apache.org/jira/browse/BEAM-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-1786. - Resolution: Fixed > AutoService registration of coders, like we do with PipelineRunners >

[jira] [Commented] (BEAM-2021) Fix Java's Coder class hierarchy

[ https://issues.apache.org/jira/browse/BEAM-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977613#comment-15977613 ] Luke Cwik commented on BEAM-2021: - Won't core construction have proto shaded and then shaded proto versions

[jira] [Comment Edited] (BEAM-2021) Fix Java's Coder class hierarchy

[ https://issues.apache.org/jira/browse/BEAM-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977613#comment-15977613 ] Luke Cwik edited comment on BEAM-2021 at 4/20/17 9:49 PM: -- Won't core construction

[jira] [Resolved] (BEAM-2040) Occasional build failures caused by AutoValue

[ https://issues.apache.org/jira/browse/BEAM-2040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2040. - Resolution: Fixed Fix Version/s: First stable release > Occasional build failures caused by

[jira] [Commented] (BEAM-2026) High performance direct runner

[ https://issues.apache.org/jira/browse/BEAM-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977210#comment-15977210 ] Luke Cwik commented on BEAM-2026: - The python equivalent of the java direct runner is currently not in a

[jira] [Commented] (BEAM-1970) Cannot run UserScore on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15968254#comment-15968254 ] Luke Cwik commented on BEAM-1970: - The work around is to use a different coder then Avro like

[jira] [Created] (BEAM-2015) Dataflow PostCommit has been failing since build #2814

Luke Cwik created BEAM-2015: --- Summary: Dataflow PostCommit has been failing since build #2814 Key: BEAM-2015 URL: https://issues.apache.org/jira/browse/BEAM-2015 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-2015) Dataflow PostCommit has been failing since build #2814

[ https://issues.apache.org/jira/browse/BEAM-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2015: Description: https://builds.apache.org/view/Beam/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/2814/

[jira] [Resolved] (BEAM-2015) Dataflow PostCommit has been failing since build #2814

[ https://issues.apache.org/jira/browse/BEAM-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2015. - Resolution: Fixed Fix Version/s: Not applicable > Dataflow PostCommit has been failing since build

[jira] [Commented] (BEAM-2015) Dataflow PostCommit has been failing since build #2814

[ https://issues.apache.org/jira/browse/BEAM-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975390#comment-15975390 ] Luke Cwik commented on BEAM-2015: - Tests are now passing again:

[jira] [Resolved] (BEAM-2014) Upgrade to Google Auth 0.6.1

[ https://issues.apache.org/jira/browse/BEAM-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2014. - Resolution: Fixed Fix Version/s: First stable release > Upgrade to Google Auth 0.6.1 >

[jira] [Commented] (BEAM-2030) Implement beam FileSystem's copy()

[ https://issues.apache.org/jira/browse/BEAM-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976973#comment-15976973 ] Luke Cwik commented on BEAM-2030: - What about concat with a single src path?

[jira] [Commented] (BEAM-2026) High performance direct runner

[ https://issues.apache.org/jira/browse/BEAM-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976979#comment-15976979 ] Luke Cwik commented on BEAM-2026: - Some runners have local execution modes like Flink and Spark, would this

[jira] [Commented] (BEAM-2021) Fix Java's Coder class hierarchy

[ https://issues.apache.org/jira/browse/BEAM-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976987#comment-15976987 ] Luke Cwik commented on BEAM-2021: - We can just use Java serialization for all CustomCoder payloads and we

[jira] [Created] (BEAM-2034) Embed example/test data within jars instead of using world readable Google Cloud Storage paths

Luke Cwik created BEAM-2034: --- Summary: Embed example/test data within jars instead of using world readable Google Cloud Storage paths Key: BEAM-2034 URL: https://issues.apache.org/jira/browse/BEAM-2034

[jira] [Commented] (BEAM-1970) Cannot run UserScore on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969234#comment-15969234 ] Luke Cwik commented on BEAM-1970: - The workaround wasn't need on other runners (tried Direct, Spark local

[jira] [Created] (BEAM-1953) Google Credential refresh failures aren't consistently retried

Luke Cwik created BEAM-1953: --- Summary: Google Credential refresh failures aren't consistently retried Key: BEAM-1953 URL: https://issues.apache.org/jira/browse/BEAM-1953 Project: Beam Issue Type:

[jira] [Resolved] (BEAM-2013) Upgrade to Jackson 2.8.8

[ https://issues.apache.org/jira/browse/BEAM-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2013. - Resolution: Fixed Fix Version/s: First stable release > Upgrade to Jackson 2.8.8 >

[jira] [Assigned] (BEAM-1786) AutoService registration of coders, like we do with PipelineRunners

[ https://issues.apache.org/jira/browse/BEAM-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-1786: --- Assignee: Luke Cwik > AutoService registration of coders, like we do with PipelineRunners >

[jira] [Commented] (BEAM-1786) AutoService registration of coders, like we do with PipelineRunners

[ https://issues.apache.org/jira/browse/BEAM-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975814#comment-15975814 ] Luke Cwik commented on BEAM-1786: - This is needed to thin out the Java SDK core BEAM-1871 otherwise we are

[jira] [Updated] (BEAM-1786) AutoService registration of coders, like we do with PipelineRunners

[ https://issues.apache.org/jira/browse/BEAM-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-1786: Fix Version/s: First stable release > AutoService registration of coders, like we do with PipelineRunners >

[jira] [Updated] (BEAM-2045) Add ValidatesRunner Tests for Custom Windows, WindowCoders that do not define good equals methods

[ https://issues.apache.org/jira/browse/BEAM-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2045: Description: This exercises a good portion of the runner logic which should only compare windows based on

[jira] [Updated] (BEAM-496) Remove the notion of a Fake subscription from PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-496: --- Labels: backwards-incompatible (was: ) > Remove the notion of a Fake subscription from PubsubIO >

[jira] [Updated] (BEAM-463) BoundedHeapCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-463: --- Fix Version/s: First stable release > BoundedHeapCoder should be a StandardCoder and not a CustomCoder >

[jira] [Updated] (BEAM-490) Swap to using CoGBK as grouping primitive instead of GBK

[ https://issues.apache.org/jira/browse/BEAM-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-490: --- Fix Version/s: First stable release > Swap to using CoGBK as grouping primitive instead of GBK >

[jira] [Updated] (BEAM-490) Swap to using CoGBK as grouping primitive instead of GBK

[ https://issues.apache.org/jira/browse/BEAM-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-490: --- Labels: backwards-incompatible (was: ) > Swap to using CoGBK as grouping primitive instead of GBK >

[jira] [Updated] (BEAM-464) HolderCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-464: --- Affects Version/s: First stable release > HolderCoder should be a StandardCoder and not a CustomCoder >

[jira] [Updated] (BEAM-466) QuantileStateCoder should be a StandardCoder

[ https://issues.apache.org/jira/browse/BEAM-466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-466: --- Fix Version/s: First stable release > QuantileStateCoder should be a StandardCoder >

[jira] [Updated] (BEAM-496) Remove the notion of a Fake subscription from PubsubIO

[ https://issues.apache.org/jira/browse/BEAM-496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-496: --- Affects Version/s: First stable release > Remove the notion of a Fake subscription from PubsubIO >

[jira] [Assigned] (BEAM-1871) Thin Java SDK Core

[ https://issues.apache.org/jira/browse/BEAM-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-1871: --- Assignee: Luke Cwik > Thin Java SDK Core > -- > > Key: BEAM-1871 >

[jira] [Commented] (BEAM-2061) Hint to template job creation in DataflowRunner / DataflowPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981375#comment-15981375 ] Luke Cwik commented on BEAM-2061: - If you would like to take on this task, feel free to assign the issue to

[jira] [Updated] (BEAM-466) QuantileStateCoder should be a StandardCoder

[ https://issues.apache.org/jira/browse/BEAM-466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-466: --- Fix Version/s: (was: First stable release) > QuantileStateCoder should be a StandardCoder >

[jira] [Updated] (BEAM-463) BoundedHeapCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-463: --- Fix Version/s: (was: First stable release) > BoundedHeapCoder should be a StandardCoder and not a

[jira] [Updated] (BEAM-760) Validation needs to exist that ValidatesRunner tests execute

[ https://issues.apache.org/jira/browse/BEAM-760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-760: --- Fix Version/s: (was: First stable release) > Validation needs to exist that ValidatesRunner tests execute >

[jira] [Resolved] (BEAM-2054) Upgrade dataflow.version to v1b3-rev196-1.22.0

[ https://issues.apache.org/jira/browse/BEAM-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2054. - Resolution: Fixed Fix Version/s: First stable release > Upgrade dataflow.version to

[jira] [Assigned] (BEAM-2054) Upgrade dataflow.version to v1b3-rev196-1.22.0

[ https://issues.apache.org/jira/browse/BEAM-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2054: --- Assignee: David Rieber (was: Davor Bonaci) > Upgrade dataflow.version to v1b3-rev196-1.22.0 >

[jira] [Updated] (BEAM-464) HolderCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-464: --- Affects Version/s: (was: First stable release) > HolderCoder should be a StandardCoder and not a

[jira] [Created] (BEAM-2771) Allow using side inputs as ValueProviders

Luke Cwik created BEAM-2771: --- Summary: Allow using side inputs as ValueProviders Key: BEAM-2771 URL: https://issues.apache.org/jira/browse/BEAM-2771 Project: Beam Issue Type: New Feature

[jira] [Assigned] (BEAM-2553) Update Maven exec plugin to 1.6.0 to incorporate messaging improvements

[ https://issues.apache.org/jira/browse/BEAM-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2553: --- Assignee: Luke Cwik (was: Frances Perry) > Update Maven exec plugin to 1.6.0 to incorporate

[jira] [Resolved] (BEAM-2553) Update Maven exec plugin to 1.6.0 to incorporate messaging improvements

[ https://issues.apache.org/jira/browse/BEAM-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2553. - Resolution: Fixed Fix Version/s: 2.2.0 > Update Maven exec plugin to 1.6.0 to incorporate messaging

[jira] [Commented] (BEAM-2614) Harness doesn't build with Java7

[ https://issues.apache.org/jira/browse/BEAM-2614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086734#comment-16086734 ] Luke Cwik commented on BEAM-2614: - I think this is working as intended as I think our only goal is that

[jira] [Commented] (BEAM-1286) DataflowRunner handling of missing filesToStage

[ https://issues.apache.org/jira/browse/BEAM-1286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16082439#comment-16082439 ] Luke Cwik commented on BEAM-1286: - I think the point is that if there is nothing to stage (even after

[jira] [Resolved] (BEAM-2552) Update Dataflow container version for 2.1.0 release

[ https://issues.apache.org/jira/browse/BEAM-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2552. - Resolution: Fixed Fix Version/s: 2.1.0 > Update Dataflow container version for 2.1.0 release >

[jira] [Updated] (BEAM-2642) Upgrade to Google Auth 0.7.1

[ https://issues.apache.org/jira/browse/BEAM-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2642: Description: Looking up application default credentials on a GCE VM can fail due to VM metadata server

[jira] [Commented] (BEAM-2676) move BeamSqlRow and BeamSqlRowType to sdk/java/core

[ https://issues.apache.org/jira/browse/BEAM-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099989#comment-16099989 ] Luke Cwik commented on BEAM-2676: - I would suggest moving this to *org.apache.beam.sdk.values* instead of

[jira] [Commented] (BEAM-2658) SerializableCoder has higher precedence over ProtoCoder in CoderRegistry#getCoder

[ https://issues.apache.org/jira/browse/BEAM-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097685#comment-16097685 ] Luke Cwik commented on BEAM-2658: - I think this issue will come up more often then this single case. Is

[jira] [Updated] (BEAM-2445) DSL SQL to use service locator pattern to automatically register UDFs

[ https://issues.apache.org/jira/browse/BEAM-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2445: Labels: (was: dsl_sql_merge) > DSL SQL to use service locator pattern to automatically register UDFs >

[jira] [Updated] (BEAM-2662) Quickstart for Spark Java not working

[ https://issues.apache.org/jira/browse/BEAM-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2662: Description: Spark version is missing in generated examples archetype pom.xml: {code}

[jira] [Commented] (BEAM-2662) Quickstart for Spark Java not working

[ https://issues.apache.org/jira/browse/BEAM-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097794#comment-16097794 ] Luke Cwik commented on BEAM-2662: -

[jira] [Comment Edited] (BEAM-2662) Quickstart for Spark Java not working

[ https://issues.apache.org/jira/browse/BEAM-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097794#comment-16097794 ] Luke Cwik edited comment on BEAM-2662 at 7/23/17 8:32 PM: --

[jira] [Comment Edited] (BEAM-2662) Quickstart for Spark Java not working

[ https://issues.apache.org/jira/browse/BEAM-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097794#comment-16097794 ] Luke Cwik edited comment on BEAM-2662 at 7/23/17 8:32 PM: --

[jira] [Resolved] (BEAM-2440) DSL SQL: Reduce visibility to simplify backwards compatibility

[ https://issues.apache.org/jira/browse/BEAM-2440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2440. - Resolution: Fixed Fix Version/s: 2.2.0 > DSL SQL: Reduce visibility to simplify backwards

[jira] [Resolved] (BEAM-2442) DSL SQL: Public classes/methods should not expose/use calcite types

[ https://issues.apache.org/jira/browse/BEAM-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2442. - Resolution: Fixed Fix Version/s: 2.2.0 > DSL SQL: Public classes/methods should not expose/use

[jira] [Created] (BEAM-2662) Quickstart for Spark Java not working

Luke Cwik created BEAM-2662: --- Summary: Quickstart for Spark Java not working Key: BEAM-2662 URL: https://issues.apache.org/jira/browse/BEAM-2662 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-2662) Quickstart for Spark Java not working

[ https://issues.apache.org/jira/browse/BEAM-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2662: Description: Spark version is missing in generated examples archetype pom.xml: {code}

[jira] [Commented] (BEAM-2441) DSL SQL maven module location and name

[ https://issues.apache.org/jira/browse/BEAM-2441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097796#comment-16097796 ] Luke Cwik commented on BEAM-2441: - The reason why I believe its important to choose a good name know is

[jira] [Assigned] (BEAM-2658) SerializableCoder has higher precedence over ProtoCoder in CoderRegistry#getCoder

[ https://issues.apache.org/jira/browse/BEAM-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2658: --- Assignee: Neville Li (was: Davor Bonaci) > SerializableCoder has higher precedence over ProtoCoder

[jira] [Resolved] (BEAM-2658) SerializableCoder has higher precedence over ProtoCoder in CoderRegistry#getCoder

[ https://issues.apache.org/jira/browse/BEAM-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2658. - Resolution: Fixed Fix Version/s: 2.2.0 > SerializableCoder has higher precedence over ProtoCoder in

[jira] [Updated] (BEAM-2642) Upgrade to Google Auth 0.7.1

[ https://issues.apache.org/jira/browse/BEAM-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2642: Description: Looking up application default credentials on a GCE VM can fail due to VM metadata server

[jira] [Created] (BEAM-2642) Upgrade to Google Auth 0.7.1

Luke Cwik created BEAM-2642: --- Summary: Upgrade to Google Auth 0.7.1 Key: BEAM-2642 URL: https://issues.apache.org/jira/browse/BEAM-2642 Project: Beam Issue Type: Bug Components:

[jira] [Resolved] (BEAM-2642) Upgrade to Google Auth 0.7.1

[ https://issues.apache.org/jira/browse/BEAM-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2642. - Resolution: Fixed Fix Version/s: 2.2.0 > Upgrade to Google Auth 0.7.1 >

[jira] [Updated] (BEAM-2662) Quickstart for Spark Java not working

[ https://issues.apache.org/jira/browse/BEAM-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2662: Fix Version/s: (was: 2.2.0) > Quickstart for Spark Java not working >

[jira] [Updated] (BEAM-2642) Upgrade to Google Auth 0.7.1

[ https://issues.apache.org/jira/browse/BEAM-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2642: Fix Version/s: (was: 2.2.0) > Upgrade to Google Auth 0.7.1 > > >

[jira] [Commented] (BEAM-2658) SerializableCoder has higher precedence over ProtoCoder in CoderRegistry#getCoder

[ https://issues.apache.org/jira/browse/BEAM-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098322#comment-16098322 ] Luke Cwik commented on BEAM-2658: - Arbitrary number based precedence orders are difficult to maintain. I

[jira] [Comment Edited] (BEAM-2658) SerializableCoder has higher precedence over ProtoCoder in CoderRegistry#getCoder

[ https://issues.apache.org/jira/browse/BEAM-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098322#comment-16098322 ] Luke Cwik edited comment on BEAM-2658 at 7/24/17 12:57 PM: --- Arbitrary number

[jira] [Comment Edited] (BEAM-2658) SerializableCoder has higher precedence over ProtoCoder in CoderRegistry#getCoder

[ https://issues.apache.org/jira/browse/BEAM-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098322#comment-16098322 ] Luke Cwik edited comment on BEAM-2658 at 7/24/17 12:57 PM: --- Arbitrary number

[jira] [Reopened] (BEAM-2430) Java FnApiDoFnRunner to share across runners

[ https://issues.apache.org/jira/browse/BEAM-2430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reopened BEAM-2430: - Assignee: Kenneth Knowles (was: Luke Cwik) PR/3432 was about writing a DoFnRunner for executing DoFns

[jira] [Resolved] (BEAM-2373) AvroSource: Premature End of stream Exception on SnappyCompressorInputStream

[ https://issues.apache.org/jira/browse/BEAM-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2373. - Resolution: Fixed > AvroSource: Premature End of stream Exception on SnappyCompressorInputStream >

[jira] [Created] (BEAM-2552) Update Dataflow container version for 2.1.0 release

Luke Cwik created BEAM-2552: --- Summary: Update Dataflow container version for 2.1.0 release Key: BEAM-2552 URL: https://issues.apache.org/jira/browse/BEAM-2552 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-2553) Update Maven exec plugin to 1.6.0 to incorporate messaging improvements

Luke Cwik created BEAM-2553: --- Summary: Update Maven exec plugin to 1.6.0 to incorporate messaging improvements Key: BEAM-2553 URL: https://issues.apache.org/jira/browse/BEAM-2553 Project: Beam

[jira] [Commented] (BEAM-1757) Improve log configuration when using multiple logging frameworks in Pipeline

[ https://issues.apache.org/jira/browse/BEAM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075231#comment-16075231 ] Luke Cwik commented on BEAM-1757: - Once the Runner/Fn API progresses to a point, this will just be

[jira] [Updated] (BEAM-1757) Improve log configuration when using multiple logging frameworks in Pipeline

[ https://issues.apache.org/jira/browse/BEAM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-1757: Component/s: beam-model-runner-api beam-model-fn-api > Improve log configuration when using

[jira] [Resolved] (BEAM-2389) GcpCoreApiSurfaceTest isn't testing right module

[ https://issues.apache.org/jira/browse/BEAM-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2389. - Resolution: Fixed > GcpCoreApiSurfaceTest isn't testing right module >

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

[ https://issues.apache.org/jira/browse/BEAM-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-1187: Description: The http request retries are failing and seemingly being immediately retried if there is a

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

[ https://issues.apache.org/jira/browse/BEAM-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-1187: Description: The http request retries are failing and seemingly being immediately retried if there is a

[jira] [Resolved] (BEAM-2077) Remove AvroCoder#createDatum(Reader/Writer)

[ https://issues.apache.org/jira/browse/BEAM-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2077. - Resolution: Fixed This was fixed with

[jira] [Assigned] (BEAM-2077) Remove AvroCoder#createDatum(Reader/Writer)

[ https://issues.apache.org/jira/browse/BEAM-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2077: --- Assignee: Luke Cwik (was: Thomas Groh) > Remove AvroCoder#createDatum(Reader/Writer) >

[jira] [Assigned] (BEAM-659) WindowFn#isCompatible should provide a meaningful reason

[ https://issues.apache.org/jira/browse/BEAM-659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-659: -- Assignee: Huafeng Wang > WindowFn#isCompatible should provide a meaningful reason >

[jira] [Assigned] (BEAM-2062) EventHandler jaxb unmarshaller should be optional

[ https://issues.apache.org/jira/browse/BEAM-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2062: --- Assignee: Damien GOUYETTE > EventHandler jaxb unmarshaller should be optional >

[jira] [Resolved] (BEAM-2062) EventHandler jaxb unmarshaller should be optional

[ https://issues.apache.org/jira/browse/BEAM-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2062. - Resolution: Fixed Fix Version/s: First stable release > EventHandler jaxb unmarshaller should be

[jira] [Commented] (BEAM-2101) (Potential) Reading public GCS files requires authentication

[ https://issues.apache.org/jira/browse/BEAM-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15987056#comment-15987056 ] Luke Cwik commented on BEAM-2101: - We ran into the same problem within the Java code base, the issue is

  1   2   3   4   5   6   7   8   9   10   >