[2/2] incubator-beam git commit: Support BigQuery DATE type

Support BigQuery DATE type This closes #985 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8245f9b4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8245f9b4 Diff:

[GitHub] incubator-beam pull request #990: [BEAM-605] Create Bigquery Verifier

GitHub user markflyhigh opened a pull request: https://github.com/apache/incubator-beam/pull/990 [BEAM-605] Create Bigquery Verifier Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Assigned] (BEAM-259) Execute selected RunnableOnService tests with Spark runner

[ https://issues.apache.org/jira/browse/BEAM-259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-259: Assignee: Kenneth Knowles > Execute selected RunnableOnService tests with Spark runner >

[5/5] incubator-beam-site git commit: Regenerated html.

Regenerated html. 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/a02bf8d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/a02bf8d3 Diff:

[3/5] incubator-beam-site git commit: Added toc

Added toc 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/14879db2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/14879db2 Diff:

[1/3] incubator-beam git commit: Update PubsubGrpcClient to not take in mocks as they are not needed anymore Update PubsubGrpcClientTest to use an inprocess server to handle requests/responses for tes

Repository: incubator-beam Updated Branches: refs/heads/master 8245f9b4b -> 4872bde8f Update PubsubGrpcClient to not take in mocks as they are not needed anymore Update PubsubGrpcClientTest to use an inprocess server to handle requests/responses for testing. Add/remove required dependencies

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

See

[4/5] incubator-beam-site git commit: This closes #37

This closes #37 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/1bbf0868 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/1bbf0868 Diff:

[2/5] incubator-beam-site git commit: Updated per PR comments

Updated per PR comments Signed-off-by: Jason Kuster 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/ec1ef53b Tree:

[jira] [Updated] (BEAM-259) Execute selected RunnableOnService tests with Spark runner

[ https://issues.apache.org/jira/browse/BEAM-259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-259: - Assignee: Jason Kuster (was: Kenneth Knowles) > Execute selected RunnableOnService tests with

[2/3] incubator-beam git commit: Better documentation for CompressionTypes.

Better documentation for CompressionTypes. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/04d84c99 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/04d84c99 Diff:

[GitHub] incubator-beam pull request #986: Update grpc to 1.0.1 and protobuf to 3.0.0

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/986 --- 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: Update grpc to 1.0.1 and protobuf to 3.0.0

Update grpc to 1.0.1 and protobuf to 3.0.0 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f93ca9ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f93ca9ce Diff:

[1/2] incubator-beam git commit: Support BigQuery DATE type

Repository: incubator-beam Updated Branches: refs/heads/master 495d8b358 -> 8245f9b4b Support BigQuery DATE type Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/287061b7 Tree:

[3/3] incubator-beam git commit: Update grpc to 1.0.1 and protobuf to 3.0.0

Update grpc to 1.0.1 and protobuf to 3.0.0 This closes #986 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4872bde8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4872bde8 Diff:

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1380

See

[jira] [Commented] (BEAM-259) Execute selected RunnableOnService tests with Spark runner

[ https://issues.apache.org/jira/browse/BEAM-259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514657#comment-15514657 ] Kenneth Knowles commented on BEAM-259: -- [~jasonkuster] any chance you can take a look at why this build

[GitHub] incubator-beam pull request #989: [BEAM-989] Better documentation for Compre...

Github user katsiapis closed the pull request at: https://github.com/apache/incubator-beam/pull/989 --- 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 #985: Support BigQuery DATE type

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/985 --- 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-605) Create BigQuery Verifier

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

[GitHub] incubator-beam-site pull request #37: Add testing guide to website.

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam-site/pull/37 --- 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] [Resolved] (BEAM-657) Support Read.Bounded primitive

[ https://issues.apache.org/jira/browse/BEAM-657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-657. Resolution: Fixed Fix Version/s: 0.3.0-incubating > Support Read.Bounded primitive >

[3/3] incubator-beam git commit: Closes #989

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

[1/5] incubator-beam-site git commit: Add testing guide to website.

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site dcdd8b742 -> a02bf8d3a Add testing guide to website. Signed-off-by: Jason Kuster Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

Jenkins build became unstable: beam_PostCommit_MavenVerify #1378

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1378

See

[GitHub] incubator-beam pull request #983: [BEAM-657] Support Read.Bounded primitive

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/983 --- 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: [BEAM-657] Support Read.Bounded primitive.

Repository: incubator-beam Updated Branches: refs/heads/master 4872bde8f -> a00d2f810 [BEAM-657] Support Read.Bounded primitive. Support Read.Bounded primitive. Avro requires this for snappy. Create is supported by Read.Bounded now. Read.Bounded support should solve gs issues now. remove

[jira] [Commented] (BEAM-657) Support Read.Bounded primitive

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

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

See

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.2.0-incubating [created] 71aaffb7f

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

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

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1193

See

[jira] [Assigned] (BEAM-147) Rename Aggregator to [P]Metric

[ https://issues.apache.org/jira/browse/BEAM-147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers reassigned BEAM-147: - Assignee: Ben Chambers (was: Frances Perry) > Rename Aggregator to [P]Metric >

[GitHub] incubator-beam pull request #991: Allow .whl files to be staged with --extra...

GitHub user charlesccychen opened a pull request: https://github.com/apache/incubator-beam/pull/991 Allow .whl files to be staged with --extra_package You can merge this pull request into a Git repository by running: $ git pull https://github.com/charlesccychen/incubator-beam

[jira] [Created] (BEAM-668) Reinstate runner direct translation for TextIO and AvroIO once Beam SDK supports hdfs.

Amit Sela created BEAM-668: -- Summary: Reinstate runner direct translation for TextIO and AvroIO once Beam SDK supports hdfs. Key: BEAM-668 URL: https://issues.apache.org/jira/browse/BEAM-668 Project: Beam

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1187

See

[1/2] incubator-beam git commit: [BEAM-642] Support Flink Detached Mode for JOB execution

Repository: incubator-beam Updated Branches: refs/heads/master f62d04e22 -> 843275210 [BEAM-642] Support Flink Detached Mode for JOB execution Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dc69bc48

[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=15512839#comment-15512839 ] Amit Sela commented on BEAM-642: [~mxm] I really have no idea what happened here - my guess is this ticket

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

[ https://issues.apache.org/jira/browse/BEAM-642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-642. - Resolution: Fixed Assignee: Sumit Chawla (was: Amit Sela) Fix Version/s:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1191

See

[1/2] incubator-beam git commit: Adds __all__ tags to source modules.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 345fc6985 -> 9565b2c27 Adds __all__ tags to source modules. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fbda5eef Tree:

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

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

[GitHub] incubator-beam pull request #987: Adds __all__ tags to source modules.

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/987 --- 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-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513074#comment-15513074 ] Amit Sela commented on BEAM-645: This https://github.com/apache/incubator-beam/pull/983 should fix

[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=15513164#comment-15513164 ] Maximilian Michels commented on BEAM-642: - I was also wondering why you were assigned. Not that I

[jira] [Updated] (BEAM-613) Add windwoding use cases to SimpleStreamingWordCountTest

[ https://issues.apache.org/jira/browse/BEAM-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-613: Summary: Add windwoding use cases to SimpleStreamingWordCountTest (was: SimpleStreamingWordCountTest tests

[jira] [Updated] (BEAM-613) Add windwoding use cases to SimpleStreamingWordCountTest

[ https://issues.apache.org/jira/browse/BEAM-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-613: Description: {{org.apache.beam.runners.spark.translation.streaming.SimpleStreamingWordCountTest}} should

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

Repository: incubator-beam Updated Branches: refs/heads/master 6082ebcce -> 495d8b358 Closes #984 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/495d8b35 Tree:

[GitHub] incubator-beam pull request #987: Adds __all__ tags to source modules.

GitHub user chamikaramj opened a pull request: https://github.com/apache/incubator-beam/pull/987 Adds __all__ tags to source modules. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

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

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

[jira] [Commented] (BEAM-613) SimpleStreamingWordCountTest does not properly test fixed windows

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

[jira] [Resolved] (BEAM-613) SimpleStreamingWordCountTest does not properly test fixed windows

[ https://issues.apache.org/jira/browse/BEAM-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-613. Resolution: Fixed Fix Version/s: 0.3.0-incubating > SimpleStreamingWordCountTest does not properly

[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=15513640#comment-15513640 ] Amit Sela commented on BEAM-637: [~staslev] do you think this ticket could be about "Spark runner to support

[2/2] incubator-beam git commit: Remove DataflowMatchers

Remove DataflowMatchers This is a Dataflow-specific requirement and should not be present within the core Beam SDK. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d73f8e77 Tree:

[GitHub] incubator-beam pull request #984: Remove DataflowMatchers

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/984 --- 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 #982: [BEAM-613] Revised SimpleStreamingWordCoun...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/982 --- 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: [BEAM-613] Revised SimpleStreamingWordCountTest to better test fixed windows.

Repository: incubator-beam Updated Branches: refs/heads/master 843275210 -> 6082ebcce [BEAM-613] Revised SimpleStreamingWordCountTest to better test fixed windows. Revised the test to test multiple batches Set the timeout to 1 ms since it essentially plays no role here. Removed blank lines

[GitHub] incubator-beam pull request #986: Update grpc to 1.0.1 and protobuf to 3.0.0

GitHub user lukecwik opened a pull request: https://github.com/apache/incubator-beam/pull/986 Update grpc to 1.0.1 and protobuf to 3.0.0 Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Updated] (BEAM-669) SimpleStreamingWordCountTest does not have a test for sliding windows

[ https://issues.apache.org/jira/browse/BEAM-669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-669: --- Assignee: Stas Levin (was: Amit Sela) > SimpleStreamingWordCountTest does not have a test for sliding windows

[jira] [Resolved] (BEAM-15) Applying windowing to cached RDDs fails

[ https://issues.apache.org/jira/browse/BEAM-15?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-15. --- Resolution: Duplicate Fix Version/s: 0.3.0-incubating Resolved by BEAM-610 > Applying windowing to

[jira] [Closed] (BEAM-645) Running Wordcount in Spark Checks Locally and Outputs in HDFS

[ https://issues.apache.org/jira/browse/BEAM-645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-645. -- Resolution: Duplicate Fix Version/s: 0.3.0-incubating > Running Wordcount in Spark Checks Locally and

[jira] [Commented] (BEAM-549) SparkRunner should support Beam's KafkaIO instead of providing it's own.

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

[jira] [Updated] (BEAM-669) SimpleStreamingWordCountTest does not have a test for sliding windows

[ https://issues.apache.org/jira/browse/BEAM-669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-669: --- Assignee: (was: Stas Levin) > SimpleStreamingWordCountTest does not have a test for sliding windows >

[jira] [Closed] (BEAM-549) SparkRunner should support Beam's KafkaIO instead of providing it's own.

[ https://issues.apache.org/jira/browse/BEAM-549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-549. -- Resolution: Duplicate Fix Version/s: 0.3.0-incubating > SparkRunner should support Beam's KafkaIO instead

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1192

See

[jira] [Created] (BEAM-670) FluentBackoff incorrectly handles nextBackOff millis

Luke Cwik created BEAM-670: -- Summary: FluentBackoff incorrectly handles nextBackOff millis Key: BEAM-670 URL: https://issues.apache.org/jira/browse/BEAM-670 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-670) BigQuery TableRow inserter incorrectly handles nextBackOff millis

[ https://issues.apache.org/jira/browse/BEAM-670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-670: --- Summary: BigQuery TableRow inserter incorrectly handles nextBackOff millis (was: FluentBackoff incorrectly

[jira] [Commented] (BEAM-670) BigQuery TableRow inserter incorrectly handles nextBackOff millis

[ https://issues.apache.org/jira/browse/BEAM-670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514377#comment-15514377 ] Daniel Halperin commented on BEAM-670: -- In other words, I believe the check is good, but I might be

[jira] [Commented] (BEAM-670) BigQuery TableRow inserter incorrectly handles nextBackOff millis

[ https://issues.apache.org/jira/browse/BEAM-670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514375#comment-15514375 ] Daniel Halperin commented on BEAM-670: -- The bug is actually at L618. We're calling nextBackoffMillis

[GitHub] incubator-beam pull request #962: [BEAM-] Use sys.executable a...

Github user chrish42 closed the pull request at: https://github.com/apache/incubator-beam/pull/962 --- 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] [Updated] (BEAM-613) SimpleStreamingWordCountTest does not properly test fixed windows

[ https://issues.apache.org/jira/browse/BEAM-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-613: Summary: SimpleStreamingWordCountTest does not properly test fixed windows (was: Add windwoding use cases to

[jira] [Updated] (BEAM-613) SimpleStreamingWordCountTest does not properly test fixed windows

[ https://issues.apache.org/jira/browse/BEAM-613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-613: Description: {{org.apache.beam.runners.spark.translation.streaming.SimpleStreamingWordCountTest}} does not

[GitHub] incubator-beam pull request #988: Add initial scaffolding for default bucket

GitHub user sammcveety opened a pull request: https://github.com/apache/incubator-beam/pull/988 Add initial scaffolding for default bucket @tgroh, could you please take a look? Before reviewing further, I was hoping to get clarity on whether the travis failures I'm seeing

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1189

See

[jira] [Created] (BEAM-669) SimpleStreamingWordCountTest does not have a test for sliding windows

Stas Levin created BEAM-669: --- Summary: SimpleStreamingWordCountTest does not have a test for sliding windows Key: BEAM-669 URL: https://issues.apache.org/jira/browse/BEAM-669 Project: Beam Issue

[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=15513831#comment-15513831 ] Sumit Chawla commented on BEAM-642: --- [~maxmil23] [~amitsela] Sorry i did not have permission to create a

[jira] [Updated] (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:all-tabpanel ] Kenneth Knowles updated BEAM-644: - Description: There is a general need, especially important in the presence of SplittableDoFn, to

[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=15513859#comment-15513859 ] Kenneth Knowles commented on BEAM-644: -- I don't quite understand the comment [~aljoscha]. Can you say

[GitHub] incubator-beam pull request #989: [BEAM-625] Better documentation for Compre...

GitHub user katsiapis opened a pull request: https://github.com/apache/incubator-beam/pull/989 [BEAM-625] Better documentation for CompressionTypes. You can merge this pull request into a Git repository by running: $ git pull https://github.com/katsiapis/incubator-beam