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

[ 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

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

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:

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

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:

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

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

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

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:

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

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:

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

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

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

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:

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

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:

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

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

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

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

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

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

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

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

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

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:

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

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:

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

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:

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

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

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

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:

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

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:

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

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

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

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:

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

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

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

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,

Jenkins build is unstable: beam_PostCommit_Java_RunnableOnService_Flink #1423

See

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

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

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

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 back to normal : beam_PostCommit_Java_MavenInstall #2416

See

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

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:

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

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

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

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

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

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

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

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

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2087

See

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2085

See

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

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #1075

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.

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

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:

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

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

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2086

See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2090

See

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2089

See

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2088

See

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Gearpump #158

See Changes: [owenzhang1990] [BEAM-1180] Implement GearpumpPipelineResult [owenzhang1990] update ROS configurations [owenzhang1990] activate ROS on Gearpump by default [owenzhang1990] fix group by

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

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:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1424

See

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

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:

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

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

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

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:

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

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:

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

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:

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

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:

Build failed in Jenkins: beam_PostCommit_Python_Verify #1076

See -- [...truncated 8345 lines...] { "@type":

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

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

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

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:

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

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:

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

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:

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

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:

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

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

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

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:

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

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:

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

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

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

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:

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

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

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

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

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

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