[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279835#comment-15279835 ] Maximilian Michels commented on BEAM-242: - Are you still working on this [~jbonofre]? Would be nice

[jira] [Updated] (BEAM-100) Update Flink Runner to 1.0.0

[ https://issues.apache.org/jira/browse/BEAM-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-100: Issue Type: Sub-task (was: Task) Parent: BEAM-273 > Update Flink Runner to 1.0.0 >

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279839#comment-15279839 ] Jean-Baptiste Onofré commented on BEAM-242: --- Hi Max, yes, I have a PR on the way (I will gently

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279851#comment-15279851 ] Maximilian Michels commented on BEAM-242: - Great! > Enable Checkstyle check for the Flink Runner >

[GitHub] incubator-beam pull request: [BEAM-272][flink] remove dependency o...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/324 [BEAM-272][flink] remove dependency on Dataflow Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure the PR title

[jira] [Created] (BEAM-272) Flink Runner depends on Dataflow Runner

Maximilian Michels created BEAM-272: --- Summary: Flink Runner depends on Dataflow Runner Key: BEAM-272 URL: https://issues.apache.org/jira/browse/BEAM-272 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-272) Flink Runner depends on Dataflow Runner

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

[6/9] incubator-beam git commit: Fix Write transform primitive display data

Fix Write transform primitive display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ea8019ec Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ea8019ec Diff:

[5/9] incubator-beam git commit: Exclude JsonIgnore PipelineOptions from DisplayData

Exclude JsonIgnore PipelineOptions from DisplayData Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/43085f7e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/43085f7e Diff:

[2/9] incubator-beam git commit: Exclude default Window.allowedLateness display data

Exclude default Window.allowedLateness display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d9355c28 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d9355c28 Diff:

[3/9] incubator-beam git commit: Add display data for MapElements transform

Add display data for MapElements transform Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0dab643a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0dab643a Diff:

[GitHub] incubator-beam pull request: [BEAM-248] Add display data to additi...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/280 --- 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: This closes #318

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

[1/2] incubator-beam git commit: Use an AtomicReference in InProcessSideInputContainer

Repository: incubator-beam Updated Branches: refs/heads/master 351fc3efa -> be9b15803 Use an AtomicReference in InProcessSideInputContainer This fixes a TOCTOU race in the contents updating logic, where the determination that the current pane should replace the contents of the side input and

[1/3] incubator-beam git commit: Add TypeDescriptors utility class

Repository: incubator-beam Updated Branches: refs/heads/master 9a8688bc3 -> a25fd05e0 Add TypeDescriptors utility class This adds static utility methods for quickly creating readable TypeDescriptor instances for compound types, such as KVs, Lists, and Iterables. Project:

[GitHub] incubator-beam pull request: [BEAM-225] Create Class for Common Ty...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/275 --- 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-225) Create Class for Common TypeDescriptors

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

[2/3] incubator-beam git commit: Add a couple more tests for TypeDescriptors

Add a couple more tests for TypeDescriptors Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77fe0162 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77fe0162 Diff:

[3/3] incubator-beam git commit: This closes #275

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

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

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

[GitHub] incubator-beam pull request: Verify one element per window for Dat...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/317 --- 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: Reuse DoFns in ParDoEvaluators

Repository: incubator-beam Updated Branches: refs/heads/master be9b15803 -> 9a8688bc3 Reuse DoFns in ParDoEvaluators This allows the runner to avoid cloning DoFns for every input bundle. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request: [BEAM-22] Reuse DoFns in ParDoEvaluat...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/320 --- 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: [BEAM-22] Use an AtomicReference in I...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/318 --- 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: Fix various things needed for a relea...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/327 Fix various things needed for a release Fix comment formatting in Flink runner's pom.xml: * The triple '---' trips release plugin, causing a build-time error. Fix release

[3/3] incubator-beam git commit: This closes #327

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

[2/3] incubator-beam git commit: Fix release profile

Fix release profile - Move assembly plugin from 'src' profile to 'release' profile. - Invoke 'release' profile, when invoking release-plugin's goals. - Fix path to the assembly configuration. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[1/3] incubator-beam git commit: Fix comment formatting in Flink runner's pom.xml

Repository: incubator-beam Updated Branches: refs/heads/master 7108bc025 -> ca01b6e60 Fix comment formatting in Flink runner's pom.xml The triple '---' trips release plugin, causing a build-time error. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request: Fix various things needed for a relea...

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

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/290 --- 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-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15280929#comment-15280929 ] Jean-Baptiste Onofré commented on BEAM-242: --- Related to the Flink runner, there are some javadoc

[1/3] incubator-beam git commit: Minor checkArgument style fix

Repository: incubator-beam Updated Branches: refs/heads/master ca01b6e60 -> 6ec9e9680 Minor checkArgument style fix Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/59a12902 Tree:

[GitHub] incubator-beam pull request: [BEAM-22] Cache SideInput contents in...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/326 --- 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] [Created] (BEAM-274) Add Programming Guide Skeleton

Devin Donnelly created BEAM-274: --- Summary: Add Programming Guide Skeleton Key: BEAM-274 URL: https://issues.apache.org/jira/browse/BEAM-274 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-277) Add Transforms Section

Devin Donnelly created BEAM-277: --- Summary: Add Transforms Section Key: BEAM-277 URL: https://issues.apache.org/jira/browse/BEAM-277 Project: Beam Issue Type: Sub-task Reporter:

[GitHub] incubator-beam pull request: [BEAM-22] More regularly schedule add...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/322 --- 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-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Created] (BEAM-275) Add Pipelines Section

Devin Donnelly created BEAM-275: --- Summary: Add Pipelines Section Key: BEAM-275 URL: https://issues.apache.org/jira/browse/BEAM-275 Project: Beam Issue Type: Sub-task Reporter:

[jira] [Created] (BEAM-278) Add I/O section

Devin Donnelly created BEAM-278: --- Summary: Add I/O section Key: BEAM-278 URL: https://issues.apache.org/jira/browse/BEAM-278 Project: Beam Issue Type: Sub-task Reporter: Devin

[jira] [Updated] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-270: -- Summary: Support Timestamps/Windows in Flink Batch (was: Use WindowedValue in Flink Batch) >

[jira] [Assigned] (BEAM-270) Use WindowedValue in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-270: - Assignee: Aljoscha Krettek > Use WindowedValue in Flink Batch >

[jira] [Closed] (BEAM-236) Implement Windowing in batch execution

[ https://issues.apache.org/jira/browse/BEAM-236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-236. - Resolution: Duplicate Superseded by BEAM-270 > Implement Windowing in batch execution >