[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] [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] [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: -- Summary: Cannot run UserScore on Flink runner due to AvroCoder classload issues (was: Cannot

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

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

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]

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #1715

See

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3383

See

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

[1/2] beam git commit: [BEAM-2013] Upgrade to Jackson 2.8.8

Repository: beam Updated Branches: refs/heads/master 7515c2602 -> d54ace4f3 [BEAM-2013] Upgrade to Jackson 2.8.8 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0650d666 Tree:

[GitHub] beam pull request #2596: [BEAM-2017] Fix NPE in DataflowRunner when there ar...

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

[jira] [Commented] (BEAM-2017) DataflowRunner: fix NullPointerException that can occur when no metrics are present

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

[GitHub] beam pull request #2599: Add javadoc to the Metric interfaces

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/2599 Add javadoc to the Metric interfaces 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] [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

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

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2410

See

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:

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

[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

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

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

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-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] [Updated] (BEAM-1763) TestPipeline should ensure that all assertions succeeded

[ https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1763: Description: This doesn't need to be part of each {{PipelineRunner}} implementation if it goes through the

[jira] [Comment Edited] (BEAM-2012) Rebuild the Dataflow worker and remove the BoundedSource.splitIntoBundles deprecated method

[ https://issues.apache.org/jira/browse/BEAM-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974230#comment-15974230 ] Etienne Chauchot edited comment on BEAM-2012 at 4/19/17 7:40 AM: - [~jkff] I

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1701

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2879

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=15974601#comment-15974601 ] Amit Sela commented on BEAM-1789: - Thanks for clearing this for me, now I can pinpoint the issue. Starting

[01/18] beam git commit: [BEAM-1994] Remove Flink examples package

Repository: beam Updated Branches: refs/heads/master 8a00f2254 -> 83193698d http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/test/java/org/apache/beam/runners/flink/streaming/UnboundedSourceWrapperTest.java

[09/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/streaming/TestCountingSource.java -- diff --git

[08/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java -- diff --git

[12/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java -- diff --git

[11/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkKeyGroupStateInternals.java -- diff --git

[02/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/test/java/org/apache/beam/runners/flink/streaming/DoFnOperatorTest.java -- diff --git

[05/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java -- diff --git

[07/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java -- diff --git

[04/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/BoundedSourceWrapper.java -- diff --git

[03/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkSplitStateInternals.java -- diff --git

[17/18] beam git commit: [BEAM-1994] Remove Flink examples package

[BEAM-1994] Remove Flink examples package Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cdd2544b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cdd2544b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/cdd2544b

[14/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java -- diff --git

[13/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/package-info.java -- diff --git

[10/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/ReadSourceITCase.java -- diff --git

[15/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkRunnerRegistrar.java -- diff --git

[18/18] beam git commit: This closes #2576

This closes #2576 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/83193698 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/83193698 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/83193698 Branch:

[06/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkMergingNonShuffleReduceFunction.java -- diff --git

[16/18] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/pom.xml -- diff --git a/runners/flink/runner/pom.xml b/runners/flink/runner/pom.xml deleted file mode 100644 index 18343ef..000 ---

[GitHub] beam pull request #2576: [BEAM-1994] Remove Flink examples package

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

[jira] [Commented] (BEAM-1994) Remove Flink examples package

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

[jira] [Resolved] (BEAM-1994) Remove Flink examples package

[ https://issues.apache.org/jira/browse/BEAM-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1994. Resolution: Fixed > Remove Flink examples package > - > >

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1702

See

[GitHub] beam pull request #2588: Pin default commons-compress version to beam-parent...

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/2588 Pin default commons-compress version to beam-parent pom Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2878

See

[1/2] beam git commit: Pin default commons-compress version to beam-parent pom

Repository: beam Updated Branches: refs/heads/master 470808c06 -> 8a00f2254 Pin default commons-compress version to beam-parent pom Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/28b692d5 Tree:

[GitHub] beam pull request #2588: Pin default commons-compress version to beam-parent...

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

This closes #2588 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8a00f225 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8a00f225 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8a00f225 Branch:

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #2396

See -- [...truncated 256.02 KB...] ! fd96188...418f756 refs/pull/2577/merge -> origin/pr/2577/merge (unable to update local ref) * [new ref]

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1700

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #327

See Changes: [jbonofre] [BEAM-1914] XmlIO now complies with PTransform style guide [iemejia] Pin default commons-compress version to beam-parent pom --

Build failed in Jenkins: beam_PerformanceTests_JDBC #133

See Changes: [jbonofre] [BEAM-1914] XmlIO now complies with PTransform style guide [iemejia] Pin default commons-compress version to beam-parent pom --

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Flink #2397

See

[jira] [Resolved] (BEAM-1829) MQTT message compression not working on Rapsberry Pi

[ https://issues.apache.org/jira/browse/BEAM-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-1829. Resolution: Fixed Fix Version/s: First stable release > MQTT message

[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] [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-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] [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=15975998#comment-15975998 ] tianyou commented on BEAM-1789: --- bq. Some block quoted text > 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=15975997#comment-15975997 ] tianyou commented on BEAM-1789: --- bq ttt bq > 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: 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 =

<    1   2   3   4   >