[jira] [Commented] (BEAM-1946) Add IO module for restful api

[ https://issues.apache.org/jira/browse/BEAM-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976190#comment-15976190 ] Reza Nouri commented on BEAM-1946: -- [~jbonofre], thanks for providing this feature. I have

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1718

See

Build failed in Jenkins: beam_PerformanceTests_JDBC #136

See Changes: [chamikara] add temp dataset location for non-query BigQuerySource -- [...truncated 829.49 KB...] at com.google.cloud.dataflow.worker.runner

Build failed in Jenkins: beam_PerformanceTests_Dataflow #330

See Changes: [chamikara] add temp dataset location for non-query BigQuerySource -- [...truncated 259.98 KB...] * [new ref] refs/pull/2540/merge -> or

[jira] [Updated] (BEAM-1765) Remove Aggregators from Spark runner

[ https://issues.apache.org/jira/browse/BEAM-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1765: -- Fix Version/s: First stable release > Remove Aggregators from Spark runner >

[jira] [Updated] (BEAM-1772) Support merging WindowFn other than IntervalWindow on Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1772: -- Fix Version/s: First stable release > Support merging WindowFn other than IntervalWindow on Flink

[jira] [Resolved] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings

[ https://issues.apache.org/jira/browse/BEAM-986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Whittle resolved BEAM-986. -- Resolution: Fixed Fix Version/s: 0.4.0 > ReduceFnRunner doesn't batch prefetching pane firings > --

[jira] [Commented] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings

[ https://issues.apache.org/jira/browse/BEAM-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976054#comment-15976054 ] Sam Whittle commented on BEAM-986: -- Yes, marked resovled > ReduceFnRunner doesn't batch pr

[jira] [Commented] (BEAM-2005) Add a Hadoop FileSystem implementation of Beam's FileSystem

[ https://issues.apache.org/jira/browse/BEAM-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976046#comment-15976046 ] Aviem Zur commented on BEAM-2005: - Regarding {{core}} vs {{extensions}}. This can reside in

[jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976045#comment-15976045 ] Kenneth Knowles commented on BEAM-1107: --- Can we do the easy thing first? Right now th

[jira] [Updated] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1107: -- Fix Version/s: First stable release > Display user names for steps in the Flink Web UI >

[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 ] Kenneth Knowles updated BEAM-760: - Summary: Validation needs to exist that ValidatesRunner tests execute (was: Validation needs to exi

[jira] [Updated] (BEAM-1766) Remove Aggregators from Apex runner

[ https://issues.apache.org/jira/browse/BEAM-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1766: -- Fix Version/s: First stable release > Remove Aggregators from Apex runner > -

[jira] [Updated] (BEAM-1796) Apex ValidatesRunner fails on testShiftTimestampInvalid

[ https://issues.apache.org/jira/browse/BEAM-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1796: -- Summary: Apex ValidatesRunner fails on testShiftTimestampInvalid (was: Apex RunnableOnService fa

[jira] [Updated] (BEAM-1767) Remove Aggregators from Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1767: -- Fix Version/s: First stable release > Remove Aggregators from Dataflow runner > -

[jira] [Assigned] (BEAM-750) Remove StateTag

[ https://issues.apache.org/jira/browse/BEAM-750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-750: Assignee: (was: Kenneth Knowles) > Remove StateTag > --- > >

[jira] [Updated] (BEAM-1850) Improve interplay between PushbackSideInputRunner and GroupAlsoByWindowViaWindowSetDoFn

[ https://issues.apache.org/jira/browse/BEAM-1850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1850: -- Summary: Improve interplay between PushbackSideInputRunner and GroupAlsoByWindowViaWindowSetDoFn

[jira] [Assigned] (BEAM-311) Add 'garbage collection' hold when receive late element

[ https://issues.apache.org/jira/browse/BEAM-311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-311: Assignee: Kenneth Knowles (was: Mark Shields) > Add 'garbage collection' hold when receive l

[jira] [Assigned] (BEAM-311) Add 'garbage collection' hold when receive late element

[ https://issues.apache.org/jira/browse/BEAM-311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-311: Assignee: (was: Kenneth Knowles) > Add 'garbage collection' hold when receive late elemen

[jira] [Assigned] (BEAM-1867) Element counts missing on Cloud Dataflow when PCollection has anything other than hardcoded name pattern

[ https://issues.apache.org/jira/browse/BEAM-1867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1867: - Assignee: Kenneth Knowles > Element counts missing on Cloud Dataflow when PCollection has

[jira] [Commented] (BEAM-1458) Checkpoint support in Beam

[ https://issues.apache.org/jira/browse/BEAM-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976030#comment-15976030 ] huangxiaofeng commented on BEAM-1458: - [#Aljoscha Krettek] do you have any plan, this f

[jira] [Updated] (BEAM-1970) Cannot run UserScore on Flink runner due to AvroCoder classload issues

[ https://issues.apache.org/jira/browse/BEAM-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1970: -- Summary: Cannot run UserScore on Flink runner due to AvroCoder classload issues (was: Cannot run

[jira] [Commented] (BEAM-1970) Cannot run UserScore on Flink runner due to AvroCoder classload issues

[ https://issues.apache.org/jira/browse/BEAM-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976028#comment-15976028 ] Kenneth Knowles commented on BEAM-1970: --- I've now paged out the details, but there is

[jira] [Updated] (BEAM-1970) Cannot run UserScore on Flink runner due to AvroCoder classload issues

[ https://issues.apache.org/jira/browse/BEAM-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1970: -- Fix Version/s: First stable release > Cannot run UserScore on Flink runner due to AvroCoder class

[jira] [Assigned] (BEAM-2022) ApexTimerInternals seems to treat processing time timers as event time timers

[ https://issues.apache.org/jira/browse/BEAM-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2022: - Assignee: Thomas Weise > ApexTimerInternals seems to treat processing time timers as event

[jira] [Commented] (BEAM-2022) ApexTimerInternals seems to treat processing time timers as event time timers

[ https://issues.apache.org/jira/browse/BEAM-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976025#comment-15976025 ] Kenneth Knowles commented on BEAM-2022: --- If this is the case, and is not fixable quic

[jira] [Updated] (BEAM-2022) ApexTimerInternals seems to treat processing time timers as event time timers

[ https://issues.apache.org/jira/browse/BEAM-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2022: -- Fix Version/s: First stable release > ApexTimerInternals seems to treat processing time timers as

[jira] [Updated] (BEAM-2022) ApexTimerInternals seems to treat processing time timers as event time timers

[ https://issues.apache.org/jira/browse/BEAM-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2022: -- Issue Type: Bug (was: Improvement) > ApexTimerInternals seems to treat processing time timers as

[jira] [Created] (BEAM-2022) ApexTimerInternals seems to treat processing time timers as event time timers

Kenneth Knowles created BEAM-2022: - Summary: ApexTimerInternals seems to treat processing time timers as event time timers Key: BEAM-2022 URL: https://issues.apache.org/jira/browse/BEAM-2022 Project:

[jira] [Assigned] (BEAM-1247) Session state should not be lost when discardingFiredPanes

[ https://issues.apache.org/jira/browse/BEAM-1247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1247: - Assignee: Kenneth Knowles > Session state should not be lost when discardingFiredPanes > -

[jira] [Commented] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings

[ https://issues.apache.org/jira/browse/BEAM-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976014#comment-15976014 ] Kenneth Knowles commented on BEAM-986: -- This is fully resolved, yes? > ReduceFnRunner

[jira] [Updated] (BEAM-1641) Support synchronized processing time in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1641: -- Fix Version/s: First stable release > Support synchronized processing time in Flink runner >

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #1717

See

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976003#comment-15976003 ] tianyou commented on BEAM-1789: --- I change _Window.Bound> fixWindow = Window.> into(FixedWind

[jira] [Comment Edited] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976003#comment-15976003 ] tianyou edited comment on BEAM-1789 at 4/20/17 3:31 AM: I change _*

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change *Window.Bound> fixWindow = Window.> into(FixedWindows.of(size));* to *Windo

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976002#comment-15976002 ] tianyou commented on BEAM-1789: --- I change *Window.Bound> fixWindow = Window.> into(FixedWind

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change *Window.Bound> fixWindow = Window.> into( FixedWindows.of(size) );* to *Wind

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976000#comment-15976000 ] tianyou commented on BEAM-1789: --- I change *Window.Bound> fixWindow = Window.> into( FixedWin

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

Kenneth Knowles created BEAM-2021: - Summary: Fix Java's Coder class hierarchy Key: BEAM-2021 URL: https://issues.apache.org/jira/browse/BEAM-2021 Project: Beam Issue Type: Improvement

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change _Window.Bound> fixWindow = Window.> into( FixedWindows.of(size) );_ to _Win

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975999#comment-15975999 ] tianyou commented on BEAM-1789: --- I change _Window.Bound> fixWindow = Window.> into( FixedWi

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975997#comment-15975997 ] tianyou commented on BEAM-1789: --- bq ttt bq > window can't not use in spark cluster module >

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975998#comment-15975998 ] tianyou commented on BEAM-1789: --- bq. Some block quoted text > window can't not use in spark

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: bq. Some block quoted text) > window can't not use in spark cluster module >

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: bq ttt bq) > window can't not use in spark cluster module >

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975996#comment-15975996 ] tianyou commented on BEAM-1789: --- ??ffdsafds?? > window can't not use in spark cluster module

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: ??ffdsafds??) > window can't not use in spark cluster module > --

[jira] [Assigned] (BEAM-2020) Move CloudObject to Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-2020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2020: - Assignee: Luke Cwik (was: Thomas Groh) > Move CloudObject to Dataflow runner > --

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975992#comment-15975992 ] tianyou commented on BEAM-1789: --- *黑体* > window can't not use in spark cluster module > -

[jira] [Created] (BEAM-2020) Move CloudObject to Dataflow runner

Kenneth Knowles created BEAM-2020: - Summary: Move CloudObject to Dataflow runner Key: BEAM-2020 URL: https://issues.apache.org/jira/browse/BEAM-2020 Project: Beam Issue Type: Improvement

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: *黑体*) > window can't not use in spark cluster module > --

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975989#comment-15975989 ] tianyou commented on BEAM-1789: --- Test _emphasis_ ttt _emphasis_ > window can't not use in sp

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: Test _emphasis_ ttt _emphasis_) > window can't not use in spark cluster module >

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975988#comment-15975988 ] tianyou commented on BEAM-1789: --- I change *strong*Window.Bound> fixWindow = Window.> into(Fi

[jira] [Issue Comment Deleted] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tianyou updated BEAM-1789: -- Comment: was deleted (was: I change *strong*Window.Bound> fixWindow = Window.> into(FixedWindows.of(size));*stro

[jira] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975976#comment-15975976 ] Ivan Li commented on BEAM-315: -- I'm in batch mode, I think it's something wrong with the coder

[jira] [Assigned] (BEAM-969) Add a gearpump runner web page under "learn/runners"

[ https://issues.apache.org/jira/browse/BEAM-969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang reassigned BEAM-969: --- Assignee: Huafeng Wang (was: Manu Zhang) > Add a gearpump runner web page under "learn/runners" >

[GitHub] beam pull request #2607: [BEAM-79] Upgrade Gearpump to a stable version

GitHub user huafengw opened a pull request: https://github.com/apache/beam/pull/2607 [BEAM-79] Upgrade Gearpump to a stable version Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[jira] [Assigned] (BEAM-973) Add end user and developer documentation to gearpump-runner

[ https://issues.apache.org/jira/browse/BEAM-973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang reassigned BEAM-973: --- Assignee: Huafeng Wang (was: Manu Zhang) > Add end user and developer documentation to gearpump-runner

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

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

[jira] [Resolved] (BEAM-973) Add end user and developer documentation to gearpump-runner

[ https://issues.apache.org/jira/browse/BEAM-973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang resolved BEAM-973. - Resolution: Fixed Fix Version/s: Not applicable > Add end user and developer documentation to gearpum

[jira] [Resolved] (BEAM-972) Add basic level of unit testing to gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang resolved BEAM-972. - Resolution: Fixed Fix Version/s: Not applicable > Add basic level of unit testing to gearpump runner

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2414

See

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

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

[GitHub] beam pull request #2606: [BEAM-1871] Remove DeterministicStandardCoder

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2606 [BEAM-1871] Remove DeterministicStandardCoder Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[jira] [Assigned] (BEAM-1860) SerializableCoder should not extend DeterministicStandardCoder

[ https://issues.apache.org/jira/browse/BEAM-1860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-1860: - Assignee: Thomas Groh (was: Davor Bonaci) > SerializableCoder should not extend DeterministicStan

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

[ https://issues.apache.org/jira/browse/BEAM-1199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-1199: - Assignee: (was: Thomas Groh) > Condense recordAsOutput, finishSpecifyingOutput from POutput >

[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&focusedCommentId=15975846#comment-15975846 ] ASF GitHub Bot commented on BEAM-1786: -- GitHub user lukecwik opened a pull request:

[GitHub] beam pull request #2605: [BEAM-1786, BEAM-1871] Add the ability to register ...

GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/2605 [BEAM-1786, BEAM-1871] Add the ability to register coder factories Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

[jira] [Assigned] (BEAM-950) DoFn Setup and Teardown methods should have access to PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-950: Assignee: (was: Thomas Groh) > DoFn Setup and Teardown methods should have access to PipelineOpti

[jira] [Assigned] (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 ] Thomas Groh reassigned BEAM-210: Assignee: (was: Thomas Groh) > Allow control of empty ON_TIME panes analogous to final panes > --

[jira] [Assigned] (BEAM-1028) Merge content from blog post into /documentation/pipelines/test-your-pipeline.md

[ https://issues.apache.org/jira/browse/BEAM-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-1028: - Assignee: (was: Thomas Groh) > Merge content from blog post into > /documentation/pipelines/t

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Spark #1716

See -- [...truncated 232.19 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

[jira] [Commented] (BEAM-1909) BigQuery read transform fails for DirectRunner when querying non-US regions

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

[1/2] beam git commit: add temp dataset location for non-query BigQuerySource

Repository: beam Updated Branches: refs/heads/master 3ef614c72 -> 104f98235 add temp dataset location for non-query BigQuerySource Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/83dc58ee Tree: http://git-wip-us.apache.org/r

[GitHub] beam pull request #2582: [BEAM-1909] BigQuery read transform fails for Direc...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2582 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[2/2] beam git commit: This closes #2582

This closes #2582 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/104f9823 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/104f9823 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/104f9823 Branch: refs/heads/maste

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3383

See

[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] [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&focusedCommentId=15975814#comment-15975814 ] Luke Cwik commented on BEAM-1786: - This is needed to thin out the Java SDK core BEAM-1871 o

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

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #1715

See

[jira] [Closed] (BEAM-919) Remove remaining old use/learn links from website src

[ https://issues.apache.org/jira/browse/BEAM-919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-919. Resolution: Fixed Assignee: Melissa Pashniak (was: Frances Perry) Fix Version/s: Not a

[GitHub] beam pull request #2604: Remove bigshuffle from python examples

GitHub user vikkyrk opened a pull request: https://github.com/apache/beam/pull/2604 Remove bigshuffle from python examples Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

Build failed in Jenkins: beam_PerformanceTests_JDBC #135

See Changes: [kirpichov] Cache result of BigQuerySourceBase.split [dhalperi] [BEAM-2015] Remove shared profile in runners/pom.xml and fix Dataflow [lcwik] [BEAM-2014] Upgrade to Google Auth 0.6.1 [lcw

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2413

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #329

See Changes: [kirpichov] Cache result of BigQuerySourceBase.split [dhalperi] [BEAM-2015] Remove shared profile in runners/pom.xml and fix Dataflow [lcwik] [BEAM-2014] Upgrade to Google Auth 0.6.1

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Spark #1714

See -- [...truncated 241.83 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3382

See -- [...truncated 242.25 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted] (non

[jira] [Commented] (BEAM-2000) run pylint on specific module

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

[GitHub] beam pull request #2579: [BEAM-2000] run pylint on specific module

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2579 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[2/2] beam git commit: This closes #2579

This closes #2579 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3ef614c7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3ef614c7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3ef614c7 Branch: refs/heads/maste

[1/2] beam git commit: added module option, use more common zero test, show module name in log

Repository: beam Updated Branches: refs/heads/master 6224556be -> 3ef614c72 added module option, use more common zero test, show module name in log Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/28a2682b Tree: http://git-wi

[jira] [Commented] (BEAM-2019) Count.globally() requires default values for non-GlobalWindows

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

[GitHub] beam pull request #2603: [BEAM-2019] Count.globally() requires default value...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/2603 [BEAM-2019] Count.globally() requires default values for non-GlobalWindows fix below error of Count.globally() when not using `GlobalWindows`: ``` Exception in thread "main" java.lang.Illega

[GitHub] beam pull request #2602: Validates that input and output GCS paths specify a...

GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/2602 Validates that input and output GCS paths specify a bucket Context: http://stackoverflow.com/questions/43505776/google-dataflow-workflow-error To be backported into Dataflow SDK as well.

[jira] [Created] (BEAM-2019) Count.globally() requires default values for non-GlobalWindows

Xu Mingmin created BEAM-2019: Summary: Count.globally() requires default values for non-GlobalWindows Key: BEAM-2019 URL: https://issues.apache.org/jira/browse/BEAM-2019 Project: Beam Issue Type

[jira] [Commented] (BEAM-1414) CountingInput should comply with PTransform style guide

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

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

[ https://issues.apache.org/jira/browse/BEAM-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1283: -- Summary: DoFn finishBundle should be required to specify the window for output (was: DoFn finish

  1   2   3   4   >