[jira] [Created] (BEAM-1580) Typo in bigquery_tornadoes example

Ahmet Altay created BEAM-1580: - Summary: Typo in bigquery_tornadoes example Key: BEAM-1580 URL: https://issues.apache.org/jira/browse/BEAM-1580 Project: Beam Issue Type: Bug Components:

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2783

See

[jira] [Commented] (BEAM-1514) change default timestamp in KafkaIO

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

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1092

See

[GitHub] beam pull request #2135: BEAM-1514: change default timestamp in KafkaIO

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/2135 BEAM-1514: change default timestamp in KafkaIO I use Java reflection here to check if timestamp is available and get the value, based on the performance test as below. As the function is called for

[jira] [Closed] (BEAM-1426) SortValues should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1426. -- > SortValues should comply with PTransform style guide >

[jira] [Closed] (BEAM-1424) ToString should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1424. -- > ToString should comply with PTransform style guide > --

[jira] [Commented] (BEAM-1424) ToString should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889586#comment-15889586 ] Eugene Kirpichov commented on BEAM-1424: Actual backward-incompatible changes: kv r

[jira] [Closed] (BEAM-1423) Sample should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1423. -- > Sample should comply with PTransform style guide >

[jira] [Closed] (BEAM-1421) Latest should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1421. -- > Latest should comply with PTransform style guide >

[jira] [Closed] (BEAM-1420) GroupByKey should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1420. -- > GroupByKey should comply with PTransform style guide >

[jira] [Closed] (BEAM-1419) Flatten should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1419. -- > Flatten should comply with PTransform style guide > ---

[jira] [Commented] (BEAM-1419) Flatten should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889580#comment-15889580 ] Eugene Kirpichov commented on BEAM-1419: Actually renamed to Flatten.Iterables and

[GitHub] beam pull request #2134: Beam 1514

Github user XuMingmin closed the pull request at: https://github.com/apache/beam/pull/2134 --- 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 en

[jira] [Commented] (BEAM-1417) Count should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889575#comment-15889575 ] Eugene Kirpichov commented on BEAM-1417: Actual backward-incompatible changes made:

[jira] [Closed] (BEAM-1417) Count should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1417. -- > Count should comply with PTransform style guide > --- >

[jira] [Closed] (BEAM-1416) Write transform should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1416. -- > Write transform should comply with PTransform style guide > ---

[GitHub] beam pull request #2134: Beam 1514

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/2134 Beam 1514 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: `[BEAM-] Description of

[jira] [Assigned] (BEAM-1534) Create a dockerized developer environment for Beam

[ https://issues.apache.org/jira/browse/BEAM-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-1534: - Assignee: Ekrem Aksoy (was: Frances Perry) > Create a dockerized developer environment fo

[jira] [Assigned] (BEAM-1577) Python BigqueryTornadoes Example Failed

[ https://issues.apache.org/jira/browse/BEAM-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-1577: - Assignee: Mark Liu (was: Ahmet Altay) > Python BigqueryTornadoes Example Failed > ---

[jira] [Commented] (BEAM-1577) Python BigqueryTornadoes Example Failed

[ https://issues.apache.org/jira/browse/BEAM-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889534#comment-15889534 ] Ahmet Altay commented on BEAM-1577: --- Should be fixed after https://github.com/apache/beam

[GitHub] beam pull request #2133: [BEAM-1337] Infer state coders

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2133 [BEAM-1337] Infer state coders 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: `[B

[jira] [Commented] (BEAM-1337) Use our coder infrastructure for coders for state

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

[jira] [Comment Edited] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers

[ https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889471#comment-15889471 ] Raghu Angadi edited comment on BEAM-1573 at 3/1/17 4:21 AM: [~p

[jira] [Updated] (BEAM-1421) Latest should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1421: -- Labels: backward-incompatible (was: ) > Latest should comply with PTransform style guide > -

[jira] [Resolved] (BEAM-1421) Latest should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1421. --- Resolution: Fixed Fix Version/s: 0.6.0 compat: Hides {{LatestFn}} in favor of static fac

[jira] [Resolved] (BEAM-1420) GroupByKey should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1420. --- Resolution: Fixed Fix Version/s: 0.6.0 > GroupByKey should comply with PTransform style

[jira] [Commented] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers

[ https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889471#comment-15889471 ] Raghu Angadi commented on BEAM-1573: [~peay], it is not clear what you are trying to do

[jira] [Resolved] (BEAM-1419) Flatten should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1419. --- Resolution: Fixed Fix Version/s: 0.6.0 > Flatten should comply with PTransform style gui

[jira] [Resolved] (BEAM-1423) Sample should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1423. --- Resolution: Fixed Fix Version/s: 0.6.0 Backward-incompatible: hides SampleAny, renames t

[jira] [Updated] (BEAM-1423) Sample should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1423: -- Labels: backward-incompatible (was: ) > Sample should comply with PTransform style guide > -

[jira] [Updated] (BEAM-1417) Count should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1417: -- Labels: backward-incompatible (was: ) > Count should comply with PTransform style guide > --

[jira] [Resolved] (BEAM-1426) SortValues should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1426. --- Resolution: Fixed Fix Version/s: 0.6.0 > SortValues should comply with PTransform style

[jira] [Resolved] (BEAM-1417) Count should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1417. --- Resolution: Fixed Fix Version/s: 0.6.0 > Count should comply with PTransform style guide

[jira] [Resolved] (BEAM-1424) ToString should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1424. --- Resolution: Fixed Fix Version/s: 0.6.0 > ToString should comply with PTransform style gu

[jira] [Resolved] (BEAM-1416) Write transform should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1416. --- Resolution: Fixed Fix Version/s: 0.6.0 > Write transform should comply with PTransform s

[jira] [Commented] (BEAM-1576) Use UnsupportedSideInputReader in GroupAlsoByWindowEvaluatorFactory.

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

[jira] [Commented] (BEAM-1353) Beam should comply with PTransform style guide

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

[5/9] beam git commit: BEAM-1424 ToString should comply with PTransform style guide

BEAM-1424 ToString should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4f34caa7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4f34caa7 Diff: http://git-wip-us.apache.org/repos/asf/b

[GitHub] beam pull request #2130: [BEAM-1576] Use UnsupportedSideInputReader in Group...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2130 --- 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 #1943: [BEAM-1353] Easy PTransform style guide compliance ...

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

[6/9] beam git commit: BEAM-1426 SortValues should comply with PTransform style guide

BEAM-1426 SortValues should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fffd2c55 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fffd2c55 Diff: http://git-wip-us.apache.org/repos/asf

[2/9] beam git commit: BEAM-1420 GroupByKey should comply with PTransform style guide

BEAM-1420 GroupByKey should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a7c60cc0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a7c60cc0 Diff: http://git-wip-us.apache.org/repos/asf

[8/9] beam git commit: BEAM-1416 Write transform should comply with PTransform style guide

BEAM-1416 Write transform should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b87621e9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b87621e9 Diff: http://git-wip-us.apache.org/repo

[7/9] beam git commit: BEAM-1417 Count should comply with PTransform style guide

BEAM-1417 Count should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9957c895 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9957c895 Diff: http://git-wip-us.apache.org/repos/asf/beam

[4/9] beam git commit: BEAM-1423 Sample should comply with PTransform style guide

BEAM-1423 Sample should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a8e2387d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a8e2387d Diff: http://git-wip-us.apache.org/repos/asf/bea

[9/9] beam git commit: This closes #1943

This closes #1943 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d66029ca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d66029ca Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d66029ca Branch: refs/heads/maste

[3/9] beam git commit: BEAM-1419 Flatten should comply with PTransform style guide

BEAM-1419 Flatten should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f5056efc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f5056efc Diff: http://git-wip-us.apache.org/repos/asf/be

[1/9] beam git commit: BEAM-1421 Latest should comply with PTransform style guide

Repository: beam Updated Branches: refs/heads/master 63b63f0b5 -> d66029caf BEAM-1421 Latest should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0b9afe8b Tree: http://git-wip-us.apache.o

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1393

See

[jira] [Created] (BEAM-1579) Runners should verify that PT overrides converged

Eugene Kirpichov created BEAM-1579: -- Summary: Runners should verify that PT overrides converged Key: BEAM-1579 URL: https://issues.apache.org/jira/browse/BEAM-1579 Project: Beam Issue Type:

[jira] [Created] (BEAM-1578) Runners should put PT overrides into a list rather than map

Eugene Kirpichov created BEAM-1578: -- Summary: Runners should put PT overrides into a list rather than map Key: BEAM-1578 URL: https://issues.apache.org/jira/browse/BEAM-1578 Project: Beam I

[jira] [Created] (BEAM-1577) Python BigqueryTornadoes Example Failed

Mark Liu created BEAM-1577: -- Summary: Python BigqueryTornadoes Example Failed Key: BEAM-1577 URL: https://issues.apache.org/jira/browse/BEAM-1577 Project: Beam Issue Type: Bug Components:

[jira] [Assigned] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers

[ https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1573: -- Assignee: Raghu Angadi (was: Davor Bonaci) > KafkaIO does not allow using Kafka serializers and

Build failed in Jenkins: beam_PostCommit_Python_Verify #1392

See Changes: [ansela] Better name for batch implementation of GroupAlsoByWindow. [ansela] Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner. [ansela] Utils for SparkGroupAlsoByWi

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1089

See

[GitHub] beam pull request #2128: Update output stream cython declaration

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2128 --- 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: Include cython tests in presubmits for linux platform

Repository: beam Updated Branches: refs/heads/master 3f4e008bf -> 352af855e Include cython tests in presubmits for linux platform Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2a03dd4e Tree: http://git-wip-us.apache.org/re

[3/3] beam git commit: Closes #2128

Closes #2128 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/352af855 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/352af855 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/352af855 Branch: refs/heads/master Com

[2/3] beam git commit: Update output stream cython declaration

Update output stream cython declaration Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b498e115 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b498e115 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b498e115 Br

[jira] [Comment Edited] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers

[ https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15888717#comment-15888717 ] peay edited comment on BEAM-1573 at 3/1/17 12:20 AM: - Actually, thinkin

[jira] [Commented] (BEAM-1569) HDFSFileSource: Unable to read from filePattern with spaces in path

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

[GitHub] beam pull request #2132: BEAM-1569 support file patterns containing spaces

GitHub user adude3141 opened a pull request: https://github.com/apache/beam/pull/2132 BEAM-1569 support file patterns containing spaces Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is format

[jira] [Commented] (BEAM-115) Beam Runner API

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

[GitHub] beam pull request #2131: [BEAM-115] Inline rather than reference FunctionSpe...

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/2131 [BEAM-115] Inline rather than reference FunctionSpecs. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is fo

Build failed in Jenkins: beam_PostCommit_Python_Verify #1391

See Changes: [dhalperi] Upgrade dataflow worker -- [...truncated 1.38 MB...] File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.O

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1088

See

[jira] [Commented] (BEAM-1576) Use UnsupportedSideInputReader in GroupAlsoByWindowEvaluatorFactory.

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

[GitHub] beam pull request #2130: [BEAM-1576] Use UnsupportedSideInputReader in Group...

GitHub user amitsela opened a pull request: https://github.com/apache/beam/pull/2130 [BEAM-1576] Use UnsupportedSideInputReader in GroupAlsoByWindowEvalua… …torFactory. Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[jira] [Created] (BEAM-1576) Use UnsupportedSideInputReader in GroupAlsoByWindowEvaluatorFactory.

Amit Sela created BEAM-1576: --- Summary: Use UnsupportedSideInputReader in GroupAlsoByWindowEvaluatorFactory. Key: BEAM-1576 URL: https://issues.apache.org/jira/browse/BEAM-1576 Project: Beam Issue

[GitHub] beam pull request #2124: Make side inputs a map, rather than embedding the n...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2124 --- 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: Make side inputs a map, rather than embedding the name in the message.

Make side inputs a map, rather than embedding the name in the message. The "local" name only make sense in context. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d59b10f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree

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

Repository: beam Updated Branches: refs/heads/master 61e31e622 -> 3f4e008bf Closes #2124 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3f4e008b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3f4e008b Diff: http://g

[jira] [Resolved] (BEAM-920) Support triggers, panes and watermarks.

[ https://issues.apache.org/jira/browse/BEAM-920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-920. Resolution: Fixed Fix Version/s: 0.6.0 > Support triggers, panes and watermarks. >

[jira] [Commented] (BEAM-920) Support triggers, panes and watermarks.

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

[11/23] beam git commit: Add multi stream and flattened stream tests.

Add multi stream and flattened stream tests. Misc. fixups. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/24ab6053 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/24ab6053 Diff: http://git-wip-us.apache.org/repos/asf/be

[16/23] beam git commit: Batch doesn't use checkpoint dir so nothing to clean.

Batch doesn't use checkpoint dir so nothing to clean. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/82d754cf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/82d754cf Diff: http://git-wip-us.apache.org/repos/asf/beam/dif

[06/23] beam git commit: Utils for SparkGroupAlsoByWindowViaWindowSet.

Utils for SparkGroupAlsoByWindowViaWindowSet. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8c379704 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8c379704 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8c3797

[09/23] beam git commit: Fix streaming translation of Flatten and Window, make CreateStream eager.

Fix streaming translation of Flatten and Window, make CreateStream eager. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9f143504 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9f143504 Diff: http://git-wip-us.apache.or

[05/23] beam git commit: Refactor translators according to new GroupAlsoByWindow implemenation for the Spark runnner.

Refactor translators according to new GroupAlsoByWindow implemenation for the Spark runnner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/96abe4f0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/96abe4f0 Diff: http://

[20/23] beam git commit: Make CreateStream a TimestampedValue Source.

Make CreateStream a TimestampedValue Source. fixup! a nicer DSL to construct CreateStream. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/62ddca63 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/62ddca63 Diff: http://gi

[01/23] beam git commit: Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner.

Repository: beam Updated Branches: refs/heads/master a41afdc68 -> 61e31e622 Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/32a9d61e Tree: http://git-wip-

[GitHub] beam pull request #2050: [BEAM-920] Support triggers, panes and watermarks.

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

[13/23] beam git commit: Fix runnable-on-service profile in the Spark runner.

Fix runnable-on-service profile in the Spark runner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c08e7d86 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c08e7d86 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff

[03/23] beam git commit: Handle test failures in "graceful stop peroid".

Handle test failures in "graceful stop peroid". Further refactoring following changes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b21de69e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b21de69e Diff: http://git-wi

[21/23] beam git commit: Spark GABWVOB to use UnsupportedSideInputReader.

Spark GABWVOB to use UnsupportedSideInputReader. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3c94ff20 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3c94ff20 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3c9

[14/23] beam git commit: Batch executions should block without timeout.

Batch executions should block without timeout. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3867dcd7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3867dcd7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3867d

[17/23] beam git commit: Build trigger state machine from Runner API Trigger proto directly

Build trigger state machine from Runner API Trigger proto directly Remove printouts of stage progress in tests. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bd41d9a3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bd4

[15/23] beam git commit: Tests that can should run with TestSparkRunner.

Tests that can should run with TestSparkRunner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b88e54a9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b88e54a9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b88e

[07/23] beam git commit: Remove streaming tests that were needed before supporting the model.

Remove streaming tests that were needed before supporting the model. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c25a02f4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c25a02f4 Diff: http://git-wip-us.apache.org/rep

[23/23] beam git commit: This closes #2050

This closes #2050 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/61e31e62 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/61e31e62 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/61e31e62 Branch: refs/heads/maste

[19/23] beam git commit: Move LateDataUtils and UnsupportedSideInputReader to runners-core.

Move LateDataUtils and UnsupportedSideInputReader to runners-core. Add missing licenses. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/123f4820 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/123f4820 Diff: http://git-

[02/23] beam git commit: Better name for batch implementation of GroupAlsoByWindow.

Better name for batch implementation of GroupAlsoByWindow. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf0c119b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf0c119b Diff: http://git-wip-us.apache.org/repos/asf/bea

[04/23] beam git commit: Use TestSparkRunner in tests.

Use TestSparkRunner in tests. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2bcd40c2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2bcd40c2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2bcd40c2 Branch: refs

[12/23] beam git commit: Make TimestampTransform Serializable.

Make TimestampTransform Serializable. Rebase leftover fixes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f47e0eba Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f47e0eba Diff: http://git-wip-us.apache.org/repos/asf/

[18/23] beam git commit: Use a PipelineRule for test pipelines.

Use a PipelineRule for test pipelines. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4ca56806 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4ca56806 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4ca56806 Bra

[08/23] beam git commit: Test triggers, panes and watermarks via CreateStream.

Test triggers, panes and watermarks via CreateStream. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/96d373fe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/96d373fe Diff: http://git-wip-us.apache.org/repos/asf/beam/dif

[22/23] beam git commit: Streaming tests, especially the ones using checkpoints, need a time buffer to finish.

Streaming tests, especially the ones using checkpoints, need a time buffer to finish. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2c707431 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2c707431 Diff: http://git-wip

[10/23] beam git commit: Serialize state stream with coders for shuffle and checkpointing.

Serialize state stream with coders for shuffle and checkpointing. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/da5f8497 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/da5f8497 Diff: http://git-wip-us.apache.org/repos/

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2777

See

  1   2   >