[3/3] incubator-beam git commit: This closes #1076

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

[GitHub] incubator-beam pull request #1076: [BEAM-115] Remove PCollectionView#fromIte...

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

[2/3] incubator-beam git commit: Remove last use of PCollectionView.fromIterableInternal

Remove last use of PCollectionView.fromIterableInternal Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1ab5d00e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1ab5d00e Diff:

incubator-beam git commit: Minor rewording to drop Dataflow from Beam SDK core

Repository: incubator-beam Updated Branches: refs/heads/master 4d10f86cf -> c561cd9c1 Minor rewording to drop Dataflow from Beam SDK core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c561cd9c Tree:

[jira] [Created] (BEAM-744) A runner should be able to override KafkaIO max wait properties.

Amit Sela created BEAM-744: -- Summary: A runner should be able to override KafkaIO max wait properties. Key: BEAM-744 URL: https://issues.apache.org/jira/browse/BEAM-744 Project: Beam Issue Type:

[GitHub] incubator-beam-site pull request #43: Blog post about Strata+Hadoop World Tu...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam-site/pull/43 --- 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/3] incubator-beam-site git commit: Added blog post about Strata+Hadoop World tutorial. Added Jesse Anderson as an author. Added the images for the blog post.

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 976b0302a -> 349759274 Added blog post about Strata+Hadoop World tutorial. Added Jesse Anderson as an author. Added the images for the blog post. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo

[3/3] incubator-beam-site git commit: This closes #43

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

[jira] [Updated] (BEAM-744) A runner should be able to override KafkaIO max wait properties.

[ https://issues.apache.org/jira/browse/BEAM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-744: --- Assignee: (was: James Malone) > A runner should be able to override KafkaIO max wait properties. >

[jira] [Commented] (BEAM-744) A runner should be able to override KafkaIO max wait properties.

[ https://issues.apache.org/jira/browse/BEAM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569856#comment-15569856 ] Raghu Angadi commented on BEAM-744: --- > KAFKA_POLL_TIMEOUT - consumer poll timeout, default: 1 second. This

[2/3] incubator-beam-site git commit: Regenerate html and make 'rake test' pass.

Regenerate html and make 'rake test' pass. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/4165ad18 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/4165ad18 Diff:

[GitHub] incubator-beam pull request #1088: Support display data for transforms with ...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/1088 Support display data for transforms with nested components of the same instance Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[jira] [Commented] (BEAM-739) Log full exception stack trace in WordCountIT and BigQueryTornadoesIT

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

[GitHub] incubator-beam pull request #1079: [BEAM-739] Log exceptions full stack trac...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1079 --- 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: Disable trimStackTrace in maven-failsafe-plugin

Repository: incubator-beam Updated Branches: refs/heads/master 135790bc9 -> 4f991fd82 Disable trimStackTrace in maven-failsafe-plugin Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1affcccd Tree:

[2/2] incubator-beam git commit: [BEAM-739] Log exceptions full stack track in IT tests

[BEAM-739] Log exceptions full stack track in IT tests This closes #1079 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4f991fd8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4f991fd8

[jira] [Commented] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569001#comment-15569001 ] Aljoscha Krettek commented on BEAM-696: --- Flink doesn't use bundles but it just keeps all the elements

[jira] [Commented] (BEAM-743) JdbcIO should not use getConnection() with username and password when using DBCP BasicDataSource

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

[jira] [Resolved] (BEAM-739) Log full exception stack trace in WordCountIT and BigQueryTornadoesIT

[ https://issues.apache.org/jira/browse/BEAM-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He resolved BEAM-739. - Resolution: Fixed Fix Version/s: Not applicable > Log full exception stack trace in WordCountIT and

[GitHub] incubator-beam pull request #1087: Resolve Registered Runners that don't end...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1087 Resolve Registered Runners that don't end with Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] incubator-beam pull request #1085: Remove Debug Message when Delivering Time...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1085 Remove Debug Message when Delivering Timers Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Build failed in Jenkins: beam_PostCommit_RunnableOnService_FlinkLocal #541

See Changes: [dhalperi] Add compression codec for AvroIO.Write -- [...truncated 1403 lines...] [WARNING] - 134 more... [WARNING] jcip-annotations-1.0.jar,

[GitHub] incubator-beam pull request #894: Rename TIMESTAMP_MIN/MAX to POSITIVE/NEGAT...

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

[GitHub] incubator-beam pull request #689: Express ParDo.Bound in terms of ParDo.Boun...

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

[GitHub] incubator-beam pull request #1077: Add profile_memory flag

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

Re: Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1503

Just an FYI that the issues here were legitimate issues in an external service that have since been resolved. They were present for approximately 90 minutes in a small set of places, and we were affected :) On Tue, Oct 11, 2016 at 7:37 PM, Apache Jenkins Server < jenk...@builds.apache.org> wrote:

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

[GitHub] incubator-beam pull request #1086: [BEAM-25] Add DoFn.StateId annotation and...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1086 [BEAM-25] Add DoFn.StateId annotation and validation on fields Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[jira] [Commented] (BEAM-714) Migrate DatastoreV1 to use AutoValue to reduce boilerplate

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

[1/2] incubator-beam git commit: Converts Datastore to use AutoValue

Repository: incubator-beam Updated Branches: refs/heads/master e2868d687 -> a5d129361 Converts Datastore to use AutoValue Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/251e3e1e Tree:

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

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

[GitHub] incubator-beam pull request #1016: [BEAM-684] pom.xml: replace dataflow.java...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1016 --- 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-684) De-Dataflow Beam

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

[jira] [Closed] (BEAM-714) Migrate DatastoreV1 to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-714. Resolution: Fixed Fix Version/s: Not applicable > Migrate DatastoreV1 to use AutoValue to

[jira] [Commented] (BEAM-737) Update TextSource to not maintain local state

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

incubator-beam git commit: Closes #1016

Repository: incubator-beam Updated Branches: refs/heads/master c561cd9c1 -> e2868d687 Closes #1016 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e2868d68 Tree:

[jira] [Created] (BEAM-745) Display Data fails on transforms with nested components of the same type

Scott Wegner created BEAM-745: - Summary: Display Data fails on transforms with nested components of the same type Key: BEAM-745 URL: https://issues.apache.org/jira/browse/BEAM-745 Project: Beam

[jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

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

[GitHub] incubator-beam pull request #1089: [BEAM-742] Replicate triggers to runners-...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1089 [BEAM-742] Replicate triggers to runners-core, favoring commit history over blame Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[jira] [Commented] (BEAM-714) Migrate DatastoreV1 to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570357#comment-15570357 ] Eugene Kirpichov commented on BEAM-714: --- Should be closed. > Migrate DatastoreV1 to use AutoValue to

[jira] [Assigned] (BEAM-714) Migrate DatastoreV1 to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov reassigned BEAM-714: - Assignee: Eugene Kirpichov (was: Daniel Halperin) > Migrate DatastoreV1 to use AutoValue

[jira] [Reopened] (BEAM-701) Support Avro Compression for writes

[ https://issues.apache.org/jira/browse/BEAM-701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reopened BEAM-701: -- Assignee: Rafal Wojdyla Reopening to assign to Rav > Support Avro Compression for writes >

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

Repository: incubator-beam Updated Branches: refs/heads/master bc9ed7dbd -> 7675035be Closes #1085 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7675035b Tree:

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

Closes #1038 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/142229e3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/142229e3 Diff:

[jira] [Commented] (BEAM-701) Support Avro Compression for writes

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

[1/2] incubator-beam git commit: Add compression codec for AvroIO.Write

Repository: incubator-beam Updated Branches: refs/heads/master 4f991fd82 -> 142229e37 Add compression codec for AvroIO.Write BEHAVIOUR CHANGE: prior to this change Avro output would not use compression. Starting from this commit, by default Avro output is compressed using deflate codec (level

[GitHub] incubator-beam pull request #1038: [BEAM-701] Support Avro write compression

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1038 --- 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-25) Add user-ready API for interacting with state

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

[1/2] incubator-beam git commit: Refactor StateSpec out of StateTag

Repository: incubator-beam Updated Branches: refs/heads/master 142229e37 -> bc9ed7dbd Refactor StateSpec out of StateTag Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7c1ba2e1 Tree:

[GitHub] incubator-beam pull request #1044: [BEAM-25] Refactor StateSpec out of State...

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

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

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

[jira] [Closed] (BEAM-556) typo in documentation

[ https://issues.apache.org/jira/browse/BEAM-556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frank Yellin closed BEAM-556. - Resolution: Fixed Fix Version/s: 0.3.0-incubating > typo in documentation > - >

[1/4] incubator-beam git commit: [BEAM-65] SplittableDoFn prototype.

Repository: incubator-beam Updated Branches: refs/heads/master a5d129361 -> 13b45895e http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a0a24883/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokersTest.java

[jira] [Commented] (BEAM-65) SplittableDoFn

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

[GitHub] incubator-beam pull request #1091: [BEAM-746] Choose BigQuery Write implemen...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1091 [BEAM-746] Choose BigQuery Write implementation based on Input PCollection Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ]

[jira] [Commented] (BEAM-701) Support Avro Compression for writes

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

[GitHub] incubator-beam pull request #896: [BEAM-65] SplittableDoFn prototype.

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

[2/4] incubator-beam git commit: [BEAM-65] SplittableDoFn prototype.

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a0a24883/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java -- diff --git

[3/4] incubator-beam git commit: [BEAM-65] SplittableDoFn prototype.

[BEAM-65] SplittableDoFn prototype. Work in progress. Currently only runs in direct runner, and not ready for any use by real users. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a0a24883 Tree:

[jira] [Created] (BEAM-746) Stop using the Streaming Flag in BigQueryIO.Write

Thomas Groh created BEAM-746: Summary: Stop using the Streaming Flag in BigQueryIO.Write Key: BEAM-746 URL: https://issues.apache.org/jira/browse/BEAM-746 Project: Beam Issue Type: Bug

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1517

See

[4/4] incubator-beam git commit: Closes #896

Closes #896 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13b45895 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13b45895 Diff:

Jenkins build became unstable: beam_PostCommit_MavenVerify #1513

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1513

See