[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

[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-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=15976046#comment-15976046 ] Aviem Zur commented on BEAM-2005: - Regarding {{core}} vs {{extensions}}. This can reside in a separate

[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=15976045#comment-15976045 ] Kenneth Knowles commented on BEAM-1107: --- Can we do the easy thing first? Right now the UI has a lot

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

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

[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

[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=15976030#comment-15976030 ] huangxiaofeng commented on BEAM-1458: - [#Aljoscha Krettek] do you have any plan, this feature will

[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

[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=15976028#comment-15976028 ] Kenneth Knowles commented on BEAM-1970: --- I've now paged out the details, but there is a class getting

[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

[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

[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=15976025#comment-15976025 ] Kenneth Knowles commented on BEAM-2022: --- If this is the case, and is not fixable quickly, we can add

[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

[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

[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=15976014#comment-15976014 ] Kenneth Knowles commented on BEAM-986: -- This is fully resolved, yes? > ReduceFnRunner doesn't batch

[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=15976003#comment-15976003 ] tianyou commented on BEAM-1789: --- I change _Window.Bound> fixWindow =

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

[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=15976002#comment-15976002 ] tianyou commented on BEAM-1789: --- I change *Window.Bound> fixWindow =

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

[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=15976000#comment-15976000 ] tianyou commented on BEAM-1789: --- I change *Window.Bound> fixWindow =

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

[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=15975999#comment-15975999 ] tianyou commented on BEAM-1789: --- I change _Window.Bound> fixWindow =

[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=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=15975998#comment-15975998 ] tianyou commented on BEAM-1789: --- 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. 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=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=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=15975989#comment-15975989 ] tianyou commented on BEAM-1789: --- Test _emphasis_ ttt _emphasis_ > window can't not use in spark cluster

[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=15975988#comment-15975988 ] tianyou commented on BEAM-1789: --- I change *strong*Window.Bound> fixWindow =

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

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

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

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

[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

[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

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

[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

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

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=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:

[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

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

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

[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

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]

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

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

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

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

[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

[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=15975690#comment-15975690 ] ASF GitHub Bot commented on BEAM-1414: -- GitHub user jkff opened a pull request:

[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

[GitHub] beam pull request #2601: [BEAM-1414] Replaces CountingInput with style guide...

GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/2601 [BEAM-1414] Replaces CountingInput with style guide compliant GenerateSequence Migration guide: `CountingInput.unbounded()` -> `GenerateSequence.from(0)` `CountingInput.upTo(n)` ->

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2410

See

[GitHub] beam pull request #2543: [BEAM-1956] Modify types for input PCollections of ...

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

[1/2] beam git commit: Modify types for input PCollections of Flatten transform to that of the output PCollection

Repository: beam Updated Branches: refs/heads/master 1721cea27 -> 6224556be Modify types for input PCollections of Flatten transform to that of the output PCollection Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[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=15975654#comment-15975654 ] ASF GitHub Bot commented on BEAM-1871: -- Github user asfgit closed the pull request at:

[GitHub] beam pull request #2598: [BEAM-1871] Remove another depedendency by moving T...

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

[1/2] beam git commit: [BEAM-1871] Remove another depedendency by moving TestCredential

Repository: beam Updated Branches: refs/heads/master 4ab74bf74 -> 1721cea27 [BEAM-1871] Remove another depedendency by moving TestCredential Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c0baf4ce Tree:

[2/2] beam git commit: [BEAM-1871] Remove another depedendency by moving TestCredential

[BEAM-1871] Remove another depedendency by moving TestCredential This closes #2598 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1721cea2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1721cea2 Diff:

[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=15975650#comment-15975650 ] Robert Bradshaw commented on BEAM-1283: --- Python has the same spec. "State plus window expiry

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #2885

See

[jira] [Commented] (BEAM-662) SlidingWindows should support sub-second periods

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

[GitHub] beam pull request #2600: [BEAM-662] Fix for allowing floating point periods ...

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/2600 [BEAM-662] Fix for allowing floating point periods in windows Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[jira] [Assigned] (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 ] Melissa Pashniak reassigned BEAM-919: - Assignee: Frances Perry (was: Melissa Pashniak) > Remove remaining old use/learn links

  1   2   3   4   >