Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2090

2017-01-23 Thread Apache Jenkins Server
See

[GitHub] beam pull request #1829: Add checkstyle:check to verify

2017-01-23 Thread ravwojdyla
GitHub user ravwojdyla opened a pull request: https://github.com/apache/beam/pull/1829 Add checkstyle:check to verify 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: `

[GitHub] beam pull request #1828: [BEAM-79] Fix PostCommit test confs for Gearpump ru...

2017-01-23 Thread manuzhang
GitHub user manuzhang opened a pull request: https://github.com/apache/beam/pull/1828 [BEAM-79] Fix PostCommit test confs for Gearpump runner 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 became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2089

2017-01-23 Thread Apache Jenkins Server
See

[GitHub] beam pull request #1827: [BEAM-27] Allow absolute timers

2017-01-23 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/1827 [BEAM-27] Allow absolute timers 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:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1425

2017-01-23 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1424

2017-01-23 Thread Apache Jenkins Server
See

[2/2] beam git commit: This closes #1822: Revert "Simplified API surface verifications"

2017-01-23 Thread kenn
This closes #1822: Revert "Simplified API surface verifications" Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cb6e0a80 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cb6e0a80 Diff: http://git-wip-us.apache.org/repos/a

[GitHub] beam pull request #1822: [BEAM-882,BEAM-883,BEAM-878] Revert "Simplified API...

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

[1/2] beam git commit: Revert "Simplified API surface verifications"

2017-01-23 Thread kenn
Repository: beam Updated Branches: refs/heads/master 6ecbfb9e1 -> cb6e0a80c Revert "Simplified API surface verifications" This reverts commit 29ffaf3859ba9b4d8ba8529efc96fd5e105e21a3. The change to require all whitelisted packages to actually expose something failed in the Dataflow runner pos

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2088

2017-01-23 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Gearpump #158

2017-01-23 Thread Apache Jenkins Server
See Changes: [owenzhang1990] [BEAM-1180] Implement GearpumpPipelineResult [owenzhang1990] update ROS configurations [owenzhang1990] activate ROS on Gearpump by default [owenzhang1990] fix group by wind

[GitHub] beam pull request #1661: [BEAM-1180] Implement GearpumpPipelineResult

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

[11/12] beam git commit: note thread is interrupted on InterruptedException

2017-01-23 Thread kenn
note thread is interrupted on InterruptedException Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d814857a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d814857a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d

[08/12] beam git commit: fix ParDo.BoundMulti translation

2017-01-23 Thread kenn
fix ParDo.BoundMulti translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b2d326ff Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b2d326ff Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b2d326ff Branch: r

[06/12] beam git commit: support OutputTimeFn

2017-01-23 Thread kenn
support OutputTimeFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f6aaf0d9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f6aaf0d9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f6aaf0d9 Branch: refs/heads/ge

[09/12] beam git commit: reduce timeout to wait for result

2017-01-23 Thread kenn
reduce timeout to wait for result Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7613ec44 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7613ec44 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7613ec44 Branch:

[03/12] beam git commit: activate ROS on Gearpump by default

2017-01-23 Thread kenn
activate ROS on Gearpump by default Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ea633d2c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ea633d2c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ea633d2c Branch

[04/12] beam git commit: fix group by window

2017-01-23 Thread kenn
fix group by window Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e63d42d1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e63d42d1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e63d42d1 Branch: refs/heads/gea

[12/12] beam git commit: This closes #1661: Implement GearpumpPipelineResult

2017-01-23 Thread kenn
This closes #1661: Implement GearpumpPipelineResult note thread is interrupted on InterruptedException Remove cache for Gearpump on travis reduce timeout to wait for result fix ParDo.BoundMulti translation return encoded key for GroupByKey translation support OutputTimeFn update to l

[07/12] beam git commit: return encoded key for GroupByKey translation

2017-01-23 Thread kenn
return encoded key for GroupByKey translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/364a3f08 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/364a3f08 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/364a3f

[01/12] beam git commit: [BEAM-1180] Implement GearpumpPipelineResult

2017-01-23 Thread kenn
Repository: beam Updated Branches: refs/heads/gearpump-runner 4c445dd0b -> 1ed16f11a [BEAM-1180] Implement GearpumpPipelineResult Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/21554764 Tree: http://git-wip-us.apache.org/re

[05/12] beam git commit: update to latest gearpump dsl function interface

2017-01-23 Thread kenn
update to latest gearpump dsl function interface Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bf82638 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3bf82638 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3bf

[02/12] beam git commit: update ROS configurations

2017-01-23 Thread kenn
update ROS configurations Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cfdc971f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cfdc971f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/cfdc971f Branch: refs/hea

Build failed in Jenkins: beam_PostCommit_Python_Verify #1076

2017-01-23 Thread Apache Jenkins Server
See -- [...truncated 8345 lines...] { "@type": "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJy

[10/12] beam git commit: Remove cache for Gearpump on travis

2017-01-23 Thread kenn
Remove cache for Gearpump on travis Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/85dcfbd1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/85dcfbd1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/85dcfbd1 Branch

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2087

2017-01-23 Thread Apache Jenkins Server
See

[GitHub] beam pull request #1826: [BEAM-59] Beam FileSystem.setDefaultConfig: remove ...

2017-01-23 Thread peihe
GitHub user peihe opened a pull request: https://github.com/apache/beam/pull/1826 [BEAM-59] Beam FileSystem.setDefaultConfig: remove scheme from the signature. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Ma

[GitHub] beam pull request #1825: [BEAM-1258] Improve logging in BigQueryIO.verifyTab...

2017-01-23 Thread peihe
GitHub user peihe opened a pull request: https://github.com/apache/beam/pull/1825 [BEAM-1258] Improve logging in BigQueryIO.verifyTableEmpty(). Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title i

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2416

2017-01-23 Thread Apache Jenkins Server
See

[GitHub] beam pull request #1820: [BEAM-1299] Removes Dataflow native text source and...

2017-01-23 Thread chamikaramj
GitHub user chamikaramj reopened a pull request: https://github.com/apache/beam/pull/1820 [BEAM-1299] Removes Dataflow native text source and sink from Beam Python SDK. Users should be using Beam text source and sink available in module 'textio.py' instead of this. Also re

[GitHub] beam pull request #1820: [BEAM-1299] Removes Dataflow native text source and...

2017-01-23 Thread chamikaramj
Github user chamikaramj closed the pull request at: https://github.com/apache/beam/pull/1820 --- 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

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2086

2017-01-23 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2415

2017-01-23 Thread Apache Jenkins Server
See Changes: [tgroh] Ensure Composite Nodes produce no output -- [...truncated 9121 lines...] symbol: class Regions location: class BasicKinesisProvider

Jenkins build is unstable: beam_PostCommit_Java_RunnableOnService_Flink #1423

2017-01-23 Thread Apache Jenkins Server
See

[GitHub] beam pull request #1824: Splittable DoFn: Gives the runner access to Restric...

2017-01-23 Thread jkff
GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/1824 Splittable DoFn: Gives the runner access to RestrictionTracker Changes the SplittableParDo transform so that ProcessFn uses a runner-supplied hook to run the @ProcessElement method, giving it, am

[GitHub] beam pull request #1823: [BEAM-1235] BigQueryIO.Write: log failed load/copy ...

2017-01-23 Thread peihe
GitHub user peihe opened a pull request: https://github.com/apache/beam/pull/1823 [BEAM-1235] BigQueryIO.Write: log failed load/copy jobs. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is for

[GitHub] beam pull request #1788: [BEAM-1279] Ensure Composite Nodes produce no outpu...

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

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

2017-01-23 Thread tgroh
This closes #1788 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6ecbfb9e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6ecbfb9e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6ecbfb9e Branch: refs/heads/maste

[1/2] beam git commit: Ensure Composite Nodes produce no output

2017-01-23 Thread tgroh
Repository: beam Updated Branches: refs/heads/master 338012d14 -> 6ecbfb9e1 Ensure Composite Nodes produce no output Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0e1893a4 Tree: http://git-wip-us.apache.org/repos/asf/beam/

[1/2] beam git commit: PubSubIO: fix and improve testing for DisplayData

2017-01-23 Thread dhalperi
Repository: beam Updated Branches: refs/heads/master f15b52fa3 -> 338012d14 PubSubIO: fix and improve testing for DisplayData Also adds better type/nullability checking in the code. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/

[GitHub] beam pull request #1817: [BEAM-1292] PubSubIO: fix and improve testing for D...

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

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

2017-01-23 Thread dhalperi
This closes #1817 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/338012d1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/338012d1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/338012d1 Branch: refs/heads/maste

[GitHub] beam pull request #1735: [BEAM-646] Always expand getInputs, getOutputs in A...

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

[1/3] beam git commit: This closes #1735

2017-01-23 Thread tgroh
Repository: beam Updated Branches: refs/heads/master 26a2c47f4 -> f15b52fa3 This closes #1735 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f15b52fa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f15b52fa Diff: htt

[3/3] beam git commit: Always expand in AppliedPTransform

2017-01-23 Thread tgroh
Always expand in AppliedPTransform Never provide unexpanded input or output types from AppliedPTransform, as they are not part of the model. Update all runners to obtain appropriate PValues from the expansions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.

[2/3] beam git commit: Always expand in AppliedPTransform

2017-01-23 Thread tgroh
http://git-wip-us.apache.org/repos/asf/beam/blob/7b062d71/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java -- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/tra

[GitHub] beam pull request #1822: [BEAM-882,BEAM-883,BEAM-878] Revert "Simplified API...

2017-01-23 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/1822 [BEAM-882,BEAM-883,BEAM-878] Revert "Simplified API surface verifications" This reverts commit 29ffaf3859ba9b4d8ba8529efc96fd5e105e21a3. The change to require all whitelisted packages to

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2085

2017-01-23 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Python_Verify #1075

2017-01-23 Thread Apache Jenkins Server
See Changes: [chamikara] Increments major version used by Dataflow runner to 5 [robertwb] Remove dataflow_test.py [robertwb] Code cleanup now that all runners support windowed side inputs. --

[GitHub] beam pull request #1821: [BEAM-1301] Support for BigQuery table description

2017-01-23 Thread ravwojdyla
GitHub user ravwojdyla opened a pull request: https://github.com/apache/beam/pull/1821 [BEAM-1301] Support for BigQuery table description Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is form

[GitHub] beam pull request #1812: Code cleanup now that all runners support windowed ...

2017-01-23 Thread robertwb
Github user robertwb closed the pull request at: https://github.com/apache/beam/pull/1812 --- 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 ena

[2/2] beam git commit: Code cleanup now that all runners support windowed side inputs.

2017-01-23 Thread robertwb
Code cleanup now that all runners support windowed side inputs. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6cb2f37e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6cb2f37e Diff: http://git-wip-us.apache.org/repos/as

[GitHub] beam pull request #1813: [BEAM-1218] Remove dataflow_test.py

2017-01-23 Thread robertwb
Github user robertwb closed the pull request at: https://github.com/apache/beam/pull/1813 --- 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 ena

[1/2] beam git commit: Closes #1812

2017-01-23 Thread robertwb
Repository: beam Updated Branches: refs/heads/python-sdk deb2aea4e -> af49908b8 Closes #1812 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/af49908b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/af49908b Diff: http

[1/2] beam git commit: Closes #1813

2017-01-23 Thread robertwb
Repository: beam Updated Branches: refs/heads/python-sdk 01b362807 -> deb2aea4e Closes #1813 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/deb2aea4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/deb2aea4 Diff: http

[2/2] beam git commit: Remove dataflow_test.py

2017-01-23 Thread robertwb
Remove dataflow_test.py Many of these tests were redundant with tests elsewhere, and the ones that weren't were put closer to similar tests. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d5b90d83 Tree: http://git-wip-us.apach

[GitHub] beam pull request #1818: [BEAM-1298] Increments major version used by Datafl...

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

[2/2] beam git commit: Closes #1818

2017-01-23 Thread robertwb
Closes #1818 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/01b36280 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/01b36280 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/01b36280 Branch: refs/heads/python-sdk

[1/2] beam git commit: Increments major version used by Dataflow runner to 5

2017-01-23 Thread robertwb
Repository: beam Updated Branches: refs/heads/python-sdk 894461e64 -> 01b362807 Increments major version used by Dataflow runner to 5 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1811458b Tree: http://git-wip-us.apache.or

[GitHub] beam pull request #1780: [BEAM-882,BEAM-883,BEAM-878] Simplified the creatio...

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

[2/2] beam git commit: This closes #1780: Simplified API surface verifications

2017-01-23 Thread kenn
This closes #1780: Simplified API surface verifications Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/26a2c47f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/26a2c47f Diff: http://git-wip-us.apache.org/repos/asf/beam/d

[1/2] beam git commit: [BEAM-882, BEAM-883, BEAM-878] Simplified API surface verifications.

2017-01-23 Thread kenn
Repository: beam Updated Branches: refs/heads/master a1a022d6b -> 26a2c47f4 [BEAM-882,BEAM-883,BEAM-878] Simplified API surface verifications. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/29ffaf38 Tree: http://git-wip-us.

[GitHub] beam pull request #1820: [BEAM-1299] Removes Dataflow native text source and...

2017-01-23 Thread chamikaramj
GitHub user chamikaramj opened a pull request: https://github.com/apache/beam/pull/1820 [BEAM-1299] Removes Dataflow native text source and sink from Beam Python SDK. Users should be using Beam text source and sink available in module 'textio.py' instead of this. Also remo

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

2017-01-23 Thread dhalperi
This closes #1819 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a1a022d6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a1a022d6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a1a022d6 Branch: refs/heads/maste

[GitHub] beam pull request #1819: [BEAM-1300] Finalize Checkpoints before resuming fr...

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

[1/2] beam git commit: Finalize Checkpoints before resuming from them

2017-01-23 Thread dhalperi
Repository: beam Updated Branches: refs/heads/master daed01a69 -> a1a022d6b Finalize Checkpoints before resuming from them This moves checkpoint finalization in the DirectRunner to occur before the call to createReader instead of between that call and the call to reader.start(). Project: htt

[GitHub] beam pull request #1795: [BEAM-560] Use ThreadLocal to cache Marshaller/Unma...

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

[2/3] beam git commit: Refactor EmptyOnDeserializationThreadLocal to util

2017-01-23 Thread tgroh
Refactor EmptyOnDeserializationThreadLocal to util This is a serialization-capable ThreadLocal used in AvroCoder. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e1ee05e8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e

[1/3] beam git commit: Use a ThreadLocal to for Marshaller/Unmarshaller in JAXBCoder

2017-01-23 Thread tgroh
Repository: beam Updated Branches: refs/heads/master 9db5f746a -> daed01a69 Use a ThreadLocal to for Marshaller/Unmarshaller in JAXBCoder This allows reuse of thread-unsafe marshallers and unmarshallers while encoding elements, while the coder remains thread-safe. Project: http://git-wip-us.

[3/3] beam git commit: This closes #1795

2017-01-23 Thread tgroh
This closes #1795 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/daed01a6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/daed01a6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/daed01a6 Branch: refs/heads/maste

[GitHub] beam pull request #1819: [BEAM-1300] Finalize Checkpoints before resuming fr...

2017-01-23 Thread tgroh
GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/1819 [BEAM-1300] Finalize Checkpoints before resuming from them Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is f

[GitHub] beam pull request #1818: [BEAM-1298] Increments major used by Dataflow runne...

2017-01-23 Thread chamikaramj
GitHub user chamikaramj opened a pull request: https://github.com/apache/beam/pull/1818 [BEAM-1298] Increments major used by Dataflow runner to 5 Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[GitHub] beam pull request #1817: [BEAM-1292] PubSubIO: fix and improve testing for D...

2017-01-23 Thread dhalperi
GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/1817 [BEAM-1292] PubSubIO: fix and improve testing for DisplayData Also adds better type/nullability checking in the code. You can merge this pull request into a Git repository by running: $ git pu

[GitHub] beam pull request #1810: Add some typing to prevent speed regression for old...

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

[GitHub] beam pull request #1816: [BEAM-1297] Update maven plugin versions and fix so...

2017-01-23 Thread iemejia
GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/1816 [BEAM-1297] Update maven plugin versions and fix some maven related issues Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure

[2/2] beam git commit: Closes #1810

2017-01-23 Thread robertwb
Closes #1810 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/894461e6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/894461e6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/894461e6 Branch: refs/heads/python-sdk

[1/2] beam git commit: Add some typing to prevent speed regression for old_dofn.

2017-01-23 Thread robertwb
Repository: beam Updated Branches: refs/heads/python-sdk d0474ab5b -> 894461e64 Add some typing to prevent speed regression for old_dofn. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f68c9dc8 Tree: http://git-wip-us.apach

[1/2] beam git commit: [BEAM-1273] Error with FlinkPipelineOptions serialization after setStateBackend

2017-01-23 Thread aljoscha
Repository: beam Updated Branches: refs/heads/master ddde35327 -> 9db5f746a [BEAM-1273] Error with FlinkPipelineOptions serialization after setStateBackend Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b5bbadf5 Tree: http:

[GitHub] beam pull request #1779: [BEAM-1273] Error with FlinkPipelineOptions seriali...

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

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

2017-01-23 Thread aljoscha
This closes #1779 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9db5f746 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9db5f746 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9db5f746 Branch: refs/heads/maste

[jira] [Closed] (BEAM-1281) GlobalWindow needs non-empty encoding in StateNamespaces

2017-01-23 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-1281. - Resolution: Won't Fix Fix Version/s: Not applicable > GlobalWindow needs non-empty encoding