[jira] [Commented] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297705#comment-15297705 ] Jean-Baptiste Onofré commented on BEAM-304: --- Regarding the version range, yes, it's normal. I

Build failed in Jenkins: beam_PostCommit_MavenVerify #486

See Changes: [klk] Factor toBeMerged->mergeResult map out of MergingActiveWindowSet -- [...truncated 3491 lines...] ^

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #486

See -- [...truncated 25 lines...] [INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ flink-runner_2.10 --- [INFO] Using 'UTF-8'

[jira] [Commented] (BEAM-31) When triggers are changed via pipeline update, stale finished triggers data applied

[ https://issues.apache.org/jira/browse/BEAM-31?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297674#comment-15297674 ] Kenneth Knowles commented on BEAM-31: - No, BEAM-179 was one symptom, but this is the root cause. > When

[GitHub] incubator-beam pull request: [BEAM-299] Fix invariant failure in M...

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

[jira] [Commented] (BEAM-299) MergingActiveWindowSet does not preserve invariants across persist/restore

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

[2/2] incubator-beam git commit: This closes #380

This closes #380 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/68b8cbc8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/68b8cbc8 Diff:

[1/2] incubator-beam git commit: Factor toBeMerged->mergeResult map out of MergingActiveWindowSet

Repository: incubator-beam Updated Branches: refs/heads/master 27abf446b -> 68b8cbc81 Factor toBeMerged->mergeResult map out of MergingActiveWindowSet Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

Build failed in Jenkins: beam_PostCommit_MavenVerify #485

See Changes: [dhalperi] TypeDescriptor: remove bogus import -- [...truncated 3503 lines...] * ^

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #485

See -- [...truncated 25 lines...] [INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ flink-runner_2.10 --- [INFO] Using 'UTF-8'

Build failed in Jenkins: beam_PostCommit_MavenVerify #484

See Changes: [davor] Update Flink runner's pom.xml [davor] Update Flink runner's pom.xml [davor] Update Java 8 examples' pom.xml file -- [...truncated 3564 lines...] * ^

[2/2] incubator-beam git commit: Closes #381

Closes #381 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/27abf446 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/27abf446 Diff:

[GitHub] incubator-beam pull request: TypeDescriptor: remove bogus import

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

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #484

See Changes: [davor] Update Flink runner's pom.xml [davor] Update Flink runner's pom.xml -- [...truncated 25 lines...] [INFO] ---

[2/4] incubator-beam git commit: Update Flink runner's pom.xml

Update Flink runner's pom.xml Explicitly disble Javadoc generation phase. This phase runs during the release process, but the current codebase doesn't compile Javadoc. This should be fixed and removed as soon as possible. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo

[4/4] incubator-beam git commit: This closes #377

This closes #377 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2376aea8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2376aea8 Diff:

[GitHub] incubator-beam pull request: Release blocking: disable Javadoc exe...

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

[1/4] incubator-beam git commit: Update Flink runner's pom.xml

Repository: incubator-beam Updated Branches: refs/heads/master 9934a4335 -> 2376aea8f Update Flink runner's pom.xml Removing an extra '-' in the comment XML prefix "!<---". This is not a valid prefix and breaks Maven release plugin. Project:

[3/4] incubator-beam git commit: Update Java 8 examples' pom.xml file

Update Java 8 examples' pom.xml file Disable Javadoc execution, which runs in the release profile, because it is currently broken and blocks release. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request: [BEAM-299] Fix invariant failure in M...

GitHub user mshields822 opened a pull request: https://github.com/apache/incubator-beam/pull/380 [BEAM-299] Fix invariant failure in MergingActiveWindowSet The 'windowToActiveWindow' map in MergingActiveWindowSet had a confused invariant. It was partially tracking the

[jira] [Commented] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

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

[GitHub] incubator-beam pull request: [BEAM-88][WIP] DataflowPipelineOption...

GitHub user ilganeli opened a pull request: https://github.com/apache/incubator-beam/pull/379 [BEAM-88][WIP] DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation This is still a work in progress since it's unclear where the default settings should

[jira] [Commented] (BEAM-211) When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

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

[GitHub] incubator-beam pull request: [BEAM-211] Replace usages of PCollect...

GitHub user ilganeli opened a pull request: https://github.com/apache/incubator-beam/pull/378 [BEAM-211] Replace usages of PCollection.setCoder with Create.of().withCoder * Replaced all usages of ```PCollection.setCoder`` with the recommended ```withCoder```. You can merge this

[jira] [Commented] (BEAM-170) Session windows should not be identified by their bounds

[ https://issues.apache.org/jira/browse/BEAM-170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297300#comment-15297300 ] Ilya Ganelin commented on BEAM-170: --- What presently handles the equality check? Is it possible to add a

[GitHub] incubator-beam pull request: Update Flink runner's pom.xml files

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/377 Update Flink runner's pom.xml files This is needed in preparation for the `0.1.0-incubating` release. Contents: * Fixing comment style, which breaks the release process. *

[jira] [Commented] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

[ https://issues.apache.org/jira/browse/BEAM-88?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297271#comment-15297271 ] Davor Bonaci commented on BEAM-88: -- [~ilganeli], awesome! We look forward to your contributions. [~peihe],

[jira] [Comment Edited] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

[ https://issues.apache.org/jira/browse/BEAM-88?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297271#comment-15297271 ] Davor Bonaci edited comment on BEAM-88 at 5/23/16 10:42 PM: [~ilganeli], awesome!

[jira] [Commented] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

[ https://issues.apache.org/jira/browse/BEAM-88?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297261#comment-15297261 ] Ilya Ganelin commented on BEAM-88: -- Hi - I'd like to fix this. Would it make sense to add this logic in the

[jira] [Commented] (BEAM-31) When triggers are changed via pipeline update, stale finished triggers data applied

[ https://issues.apache.org/jira/browse/BEAM-31?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297221#comment-15297221 ] Ilya Ganelin commented on BEAM-31: -- This is marked as duplicated by BEAM-179, which is resolved - can this

[GitHub] incubator-beam pull request: Verify in unit test that BigQuery exe...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/376 Verify in unit test that BigQuery executing project is used. You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam

[jira] [Commented] (BEAM-117) Implement the API for Static Display Metadata

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

[jira] [Commented] (BEAM-53) PubSubIO: reimplement in Java

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

[GitHub] incubator-beam pull request: [BEAM-53] Mirror some DataflowJavaSDK...

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

[1/2] incubator-beam git commit: PubsubIO: make translation to Dataflow service compatible

Repository: incubator-beam Updated Branches: refs/heads/master c91390026 -> 9934a4335 PubsubIO: make translation to Dataflow service compatible Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6a74143a

[jira] [Resolved] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-304. -- Resolution: Fixed > Build break: maven is picking up Kafka snapshots >

[jira] [Commented] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297042#comment-15297042 ] Daniel Halperin commented on BEAM-304: -- I lied! What actually happened is that Kafka *released* 0.10,

[jira] [Comment Edited] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297042#comment-15297042 ] Daniel Halperin edited comment on BEAM-304 at 5/23/16 8:40 PM: --- I lied! What

[jira] [Commented] (BEAM-304) Build break: maven is picking up Kafka snapshots

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

[jira] [Commented] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297019#comment-15297019 ] Davor Bonaci commented on BEAM-304: --- SGTM. > Build break: maven is picking up Kafka snapshots >

[GitHub] incubator-beam pull request: [BEAM-304] KafkaIO: pin to current wo...

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

[jira] [Commented] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297014#comment-15297014 ] Daniel Halperin commented on BEAM-304: -- +[~rangadi] +[~jbonofre] +[~davor] JB, is grabbing snapshots

[jira] [Created] (BEAM-304) Build break: maven is picking up Kafka snapshots

Daniel Halperin created BEAM-304: Summary: Build break: maven is picking up Kafka snapshots Key: BEAM-304 URL: https://issues.apache.org/jira/browse/BEAM-304 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-77) Reorganize Directory structure

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

[GitHub] incubator-beam pull request: AvroSource: synchronization fix

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/373 AvroSource: synchronization fix You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam

[jira] [Commented] (BEAM-291) PDone type translation fails

[ https://issues.apache.org/jira/browse/BEAM-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296537#comment-15296537 ] Maximilian Michels commented on BEAM-291: - Thanks for the insight [~kenn]! We've actually

[jira] [Commented] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296511#comment-15296511 ] Jean-Baptiste Onofré commented on BEAM-286: --- I agree guys: it doesn't have an impact for end

[jira] [Commented] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296501#comment-15296501 ] Maximilian Michels commented on BEAM-286: - Exactly, the fact that the flink-runner is composed of

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

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296122#comment-15296122 ] Jean-Baptiste Onofré commented on BEAM-79: -- Starting to review and test. Thanks ! > Gearpump runner

[jira] [Created] (BEAM-303) Add Machine Learning DSL and dedicated functions

Jean-Baptiste Onofré created BEAM-303: - Summary: Add Machine Learning DSL and dedicated functions Key: BEAM-303 URL: https://issues.apache.org/jira/browse/BEAM-303 Project: Beam Issue

[jira] [Created] (BEAM-302) Add Beam Scala DSL

Jean-Baptiste Onofré created BEAM-302: - Summary: Add Beam Scala DSL Key: BEAM-302 URL: https://issues.apache.org/jira/browse/BEAM-302 Project: Beam Issue Type: Wish Components:

[jira] [Updated] (BEAM-14) Add declarative DSLs (XML & JSON)

[ https://issues.apache.org/jira/browse/BEAM-14?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-14: - Summary: Add declarative DSLs (XML & JSON) (was: Add declarative DSLs) > Add declarative

[jira] [Created] (BEAM-301) Add a Beam SQL DSL

Jean-Baptiste Onofré created BEAM-301: - Summary: Add a Beam SQL DSL Key: BEAM-301 URL: https://issues.apache.org/jira/browse/BEAM-301 Project: Beam Issue Type: New Feature