[GitHub] incubator-beam pull request #997: Support BigQuery DATETIME and TIME types

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/997 Support BigQuery DATETIME and TIME types You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam bq-new-types

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1200

See

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

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1385

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1385

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1386

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1386

See

[GitHub] incubator-beam pull request #995: In BigQueryIOTest, changes tests who expec...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/995 --- 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: Update BigQueryIO tests who expect failure to be NeedsRunner tests

Repository: incubator-beam Updated Branches: refs/heads/master 2b8b20ded -> 3fe3bc8eb Update BigQueryIO tests who expect failure to be NeedsRunner tests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: In BigQueryIOTest, changes tests who expect failure to be NeedsRunner tests

In BigQueryIOTest, changes tests who expect failure to be NeedsRunner tests This closes #995 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3fe3bc8e Tree:

[jira] [Commented] (BEAM-310) Exercise splitIntoBundles/generateInitialSplits in the Direct Runner

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

[GitHub] incubator-beam pull request #996: [BEAM-310] Add RootTransformEvaluatorFacto...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/996 [BEAM-310] Add RootTransformEvaluatorFactory, Use for Reads 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 #995: In BigQueryIOTest, changes tests who expec...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/995 In BigQueryIOTest, changes tests who expect failure to be NeedsRunner tests You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (BEAM-672) Figure out TestPipeline.create(PipelineOptions) / TestPipeline.fromOptions(PipelineOptions) story

[ https://issues.apache.org/jira/browse/BEAM-672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15517821#comment-15517821 ] Kenneth Knowles commented on BEAM-672: -- An important use case to consider (we talked offline about

[jira] [Updated] (BEAM-672) Figure out TestPipeline.create(PipelineOptions) / TestPipeline.fromOptions(PipelineOptions) story

[ https://issues.apache.org/jira/browse/BEAM-672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-672: --- Component/s: sdk-java-core > Figure out TestPipeline.create(PipelineOptions) / >

[jira] [Created] (BEAM-672) Figure out TestPipeline.create(PipelineOptions) / TestPipeline.fromOptions(PipelineOptions) story

Luke Cwik created BEAM-672: -- Summary: Figure out TestPipeline.create(PipelineOptions) / TestPipeline.fromOptions(PipelineOptions) story Key: BEAM-672 URL: https://issues.apache.org/jira/browse/BEAM-672

[GitHub] incubator-beam pull request #852: Correctly type collections in PipelineOpti...

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

[GitHub] incubator-beam pull request #852: Correctly type collections in PipelineOpti...

GitHub user sammcveety reopened a pull request: https://github.com/apache/incubator-beam/pull/852 Correctly type collections in PipelineOptions. @bjchambers @lukecwik I would expect this to work, but the cast to ParameterizedType fails. Luke, were you suggesting something else?

[GitHub] incubator-beam pull request #955: Implement dynamic work rebalancing for con...

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

Jenkins build is back to normal : beam_PostCommit_PythonVerify #442

See

[jira] [Commented] (BEAM-615) Add Support for Processing-Time Timers in FlinkRunner Window Operator

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

[GitHub] incubator-beam pull request #994: [BEAM-615] Add support for processing time...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/994 [BEAM-615] Add support for processing time timers in FlinkRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[jira] [Assigned] (BEAM-615) Add Support for Processing-Time Timers in FlinkRunner Window Operator

[ https://issues.apache.org/jira/browse/BEAM-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-615: Assignee: Kenneth Knowles > Add Support for Processing-Time Timers in FlinkRunner Window

[1/6] incubator-beam git commit: Move ConcatSource into its own module.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 0fa9c4be6 -> 753cc9c2e Move ConcatSource into its own module. Also added some more tests. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[6/6] incubator-beam git commit: Closes #955

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

[4/6] incubator-beam git commit: Implement liquid sharding for concat source.

Implement liquid sharding for concat source. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c7d5a37d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c7d5a37d Diff:

[3/6] incubator-beam git commit: Minor cleanups in docstrings and error messages.

Minor cleanups in docstrings and error messages. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c1f42e62 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c1f42e62 Diff:

[5/6] incubator-beam git commit: Move ConcatSource to iobase.

Move ConcatSource to iobase. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d65d17aa Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d65d17aa Diff:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1199

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1384

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1384

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1384

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1198

See

[jira] [Commented] (BEAM-644) Primitive to shift the watermark while assigning timestamps

[ https://issues.apache.org/jira/browse/BEAM-644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15516981#comment-15516981 ] Kenneth Knowles commented on BEAM-644: -- [~aljoscha], are you referring to two clusters of output

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1383

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1383

See

[GitHub] incubator-beam pull request #992: [BEAM-469] Do not modify the context in Nu...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/992 [BEAM-469] Do not modify the context in NullableCoder Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[GitHub] incubator-beam pull request #993: Minor clean-up of RunnableOnService defini...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/993 --- 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: Minor clean-up of RunnableOnService definition

Minor clean-up of RunnableOnService definition This closes #993 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2b8b20de Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2b8b20de Diff:

[1/2] incubator-beam git commit: Minor clean-up of RunnableOnService definition

Repository: incubator-beam Updated Branches: refs/heads/master a00d2f810 -> 2b8b20ded Minor clean-up of RunnableOnService definition Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/22815474 Tree:

[GitHub] incubator-beam pull request #993: Minor clean-up of RunnableOnService defini...

GitHub user lukecwik opened a pull request: https://github.com/apache/incubator-beam/pull/993 Minor clean-up of RunnableOnService definition Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Created] (BEAM-671) Update Read PTransform to implicitly use maxNumRecords and maxReadTime

Jean-Baptiste Onofré created BEAM-671: - Summary: Update Read PTransform to implicitly use maxNumRecords and maxReadTime Key: BEAM-671 URL: https://issues.apache.org/jira/browse/BEAM-671 Project:

[jira] [Commented] (BEAM-469) NullableCoder should encode using the context given and not always use the nested context

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

Jenkins build is unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1197

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1382

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1382

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1382

See

[jira] [Updated] (BEAM-637) Support Java serialisation (via JavaSerialiser)

[ https://issues.apache.org/jira/browse/BEAM-637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-637: Issue Type: Improvement (was: Bug) > Support Java serialisation (via JavaSerialiser) >

[jira] [Updated] (BEAM-637) Support Java serialisation (via JavaSerialiser)

[ https://issues.apache.org/jira/browse/BEAM-637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-637: Summary: Support Java serialisation (via JavaSerialiser) (was: WindowedValue$ValueInGlobalWindow is not

[jira] [Updated] (BEAM-637) WindowedValue$ValueInGlobalWindow is not serializable when using JavaSerializer instead of Kryo

[ https://issues.apache.org/jira/browse/BEAM-637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-637: Priority: Minor (was: Major) > WindowedValue$ValueInGlobalWindow is not serializable when using >

[jira] [Commented] (BEAM-637) WindowedValue$ValueInGlobalWindow is not serializable when using JavaSerializer instead of Kryo

[ https://issues.apache.org/jira/browse/BEAM-637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15516207#comment-15516207 ] Stas Levin commented on BEAM-637: - [~amitsela] I agree, we can make it about supporting Java serialisation

[jira] [Commented] (BEAM-642) FlinkRunner does not support Detached Mode

[ https://issues.apache.org/jira/browse/BEAM-642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515887#comment-15515887 ] Maximilian Michels commented on BEAM-642: - That's good to know. I added you as a contributor. >

[jira] [Commented] (BEAM-644) Primitive to shift the watermark while assigning timestamps

[ https://issues.apache.org/jira/browse/BEAM-644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515875#comment-15515875 ] Aljoscha Krettek commented on BEAM-644: --- Yes, as a replacement for {{outputWithTimestamp}} and

Build failed in Jenkins: beam_PostCommit_PythonVerify #440

See -- [...truncated 3624 lines...] "component_encodings": [] } ], "is_wrapper": true }, "output_name":

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

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1381

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1381

See