[jira] [Assigned] (BEAM-855) Remove the need for --streaming option in the spark runner

[ https://issues.apache.org/jira/browse/BEAM-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-855: - Assignee: Jean-Baptiste Onofré (was: Amit Sela) > Remove the need for --streaming

[jira] [Commented] (BEAM-855) Remove the need for --streaming option in the spark runner

[ https://issues.apache.org/jira/browse/BEAM-855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15614511#comment-15614511 ] Jean-Baptiste Onofré commented on BEAM-855: --- Agree. I think I already did somethin

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #689

See

[jira] [Created] (BEAM-855) Remove the need for --streaming option in the spark runner

Ismaël Mejía created BEAM-855: - Summary: Remove the need for --streaming option in the spark runner Key: BEAM-855 URL: https://issues.apache.org/jira/browse/BEAM-855 Project: Beam Issue Type: Imp

[jira] [Commented] (BEAM-854) ReifyTimestampAndWindows explodes windows

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

[GitHub] incubator-beam pull request #1216: [BEAM-854] Directly implement ReifyTimest...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1216 [BEAM-854] Directly implement ReifyTimestampsAndWindows in SparkRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x]

[GitHub] incubator-beam-site pull request #54: Add downstream merge exemption to cont...

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

[1/3] incubator-beam-site git commit: Add downstream merge exemption to contribution guide

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 71d95e3b2 -> 6f087916f Add downstream merge exemption to contribution guide 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

[3/3] incubator-beam-site git commit: This closes #54.

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

[2/3] incubator-beam-site git commit: Regenerate html

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

[4/5] incubator-beam-site git commit: Regenerate html for #40

Regenerate html for #40 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/27b5e76b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/27b5e76b Diff: http://git-wip-us.apache.org/re

[GitHub] incubator-beam-site pull request #40: Create the WordCount walkthrough [WIP]

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

[2/5] incubator-beam-site git commit: Temporarily disable tests for v2/, since the links are all fake

Temporarily disable tests for v2/, since the links are all fake 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/456e8615 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/456e86

[3/5] incubator-beam-site git commit: Regenerate html for #40

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/27b5e76b/content/use/wordcount-example/index.html -- diff --git a/content/use/wordcount-example/index.html b/content/use/wordcount-example/index.html new file mode 10

[1/5] incubator-beam-site git commit: Add a first version of the WordCount walkthrough.

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site dc711798d -> 71d95e3b2 Add a first version of the WordCount walkthrough. 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/f2

[5/5] incubator-beam-site git commit: [Beam-665] This closes #40.

[Beam-665] This closes #40. 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/71d95e3b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/71d95e3b Diff: http://git-wip-us.apache.or

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[GitHub] incubator-beam pull request #1215: [BEAM-498] Add static factory method for ...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1215 [BEAM-498] Add static factory method for DoFnInfo Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR tit

[GitHub] incubator-beam-site pull request #54: Add downstream merge exemption to cont...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam-site/pull/54 Add downstream merge exemption to contribution guide R: @francesperry You can merge this pull request into a Git repository by running: $ git pull https://github.com/kennknowle

[jira] [Assigned] (BEAM-800) DoFnLifeCycleManager should hold DoFnInvoker, not DoFn/OldDoFn

[ https://issues.apache.org/jira/browse/BEAM-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang reassigned BEAM-800: --- Assignee: Manu Zhang > DoFnLifeCycleManager should hold DoFnInvoker, not DoFn/OldDoFn > ---

[jira] [Commented] (BEAM-800) DoFnLifeCycleManager should hold DoFnInvoker, not DoFn/OldDoFn

[ https://issues.apache.org/jira/browse/BEAM-800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15613941#comment-15613941 ] Manu Zhang commented on BEAM-800: - {{DoFnRunner}} is currently created by the corresponding

[GitHub] incubator-beam pull request #1214: Merge master into apex-runner

GitHub user tweise opened a pull request: https://github.com/apache/incubator-beam/pull/1214 Merge master into apex-runner 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:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #688

See

[jira] [Updated] (BEAM-852) Validate sources when they are created

[ https://issues.apache.org/jira/browse/BEAM-852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-852: Assignee: Chamikara Jayalath (was: Frances Perry) > Validate sources when they are created >

[jira] [Updated] (BEAM-852) Validate sources when they are created

[ https://issues.apache.org/jira/browse/BEAM-852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-852: Assignee: Frances Perry > Validate sources when they are created > ---

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #687

See

[5/5] incubator-beam-site git commit: Generate html of the v2 directory for the first time

Generate html of the v2 directory for the first time 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/dc711798 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/dc711798 Diff: ht

[1/5] incubator-beam-site git commit: Generate html of the v2 directory for the first time

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 2aa002784 -> dc711798d http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/dc711798/content/v2/slick/slick.min.js -- diff --git a/content/v2/slic

[4/5] incubator-beam-site git commit: Generate html of the v2 directory for the first time

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/dc711798/content/v2/css/beam.css -- diff --git a/content/v2/css/beam.css b/content/v2/css/beam.css new file mode 100644 index 000..7d318e3 --- /dev/null +++ b/cont

[3/5] incubator-beam-site git commit: Generate html of the v2 directory for the first time

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/dc711798/content/v2/images/apache.png -- diff --git a/content/v2/images/apache.png b/content/v2/images/apache.png new file mode 100644 index 000..769fb14 Binary fi

[2/5] incubator-beam-site git commit: Generate html of the v2 directory for the first time

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/dc711798/content/v2/slick/slick.js -- diff --git a/content/v2/slick/slick.js b/content/v2/slick/slick.js new file mode 100644 index 000..70c0aaa --- /dev/null +++

[GitHub] incubator-beam pull request #1210: [BEAM-847] Use a int Sequence instead of ...

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

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

Repository: incubator-beam Updated Branches: refs/heads/master f2ec82453 -> 215980ad3 Closes #1210 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/215980ad Tree: http://git-wip-us.apache.org/repos/asf/inc

[jira] [Commented] (BEAM-847) DelelgatingAggregator uses UUID.randomUUID, which uses a synchronized Random method

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

[2/2] incubator-beam git commit: Use a int Sequence instead of a Random UUID for Aggregator IDs

Use a int Sequence instead of a Random UUID for Aggregator IDs Aggregator IDs are used to ensure that an Aggregator's identity is consistent across synchronization barriers. This is only relevant when constructing the map of Step -> Aggregator to enable querying, as the DoFns represented within th

[jira] [Commented] (BEAM-261) Apache Apex Runner

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

[GitHub] incubator-beam pull request #1213: BEAM-261 Make translators package private...

GitHub user tweise opened a pull request: https://github.com/apache/incubator-beam/pull/1213 BEAM-261 Make translators package private. 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-854) ReifyTimestampAndWindows explodes windows

[ https://issues.apache.org/jira/browse/BEAM-854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15613571#comment-15613571 ] Kenneth Knowles commented on BEAM-854: -- Ah, my mistake. You are correct. This needlessl

[4/6] incubator-beam-site git commit: [BEAM-501] New skin proposal

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/9a04037f/v2/css/beam.css -- diff --git a/v2/css/beam.css b/v2/css/beam.css new file mode 100644 index 000..7d318e3 --- /dev/null +++ b/v2/css/beam.css @@ -0,0 +1,5

[1/6] incubator-beam-site git commit: [BEAM-501] New skin proposal

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site e0ae01c5f -> 2aa002784 http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/9a04037f/v2/slick/slick.min.js -- diff --git a/v2/slick/slick.min.js b

[2/6] incubator-beam-site git commit: [BEAM-501] New skin proposal

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/9a04037f/v2/slick/slick.js -- diff --git a/v2/slick/slick.js b/v2/slick/slick.js new file mode 100644 index 000..70c0aaa --- /dev/null +++ b/v2/slick/slick.js @@ -

[5/6] incubator-beam-site git commit: [BEAM-501] New skin proposal

[BEAM-501] New skin proposal 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/9a04037f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/9a04037f Diff: http://git-wip-us.apache.o

[6/6] incubator-beam-site git commit: This closes #51

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

[3/6] incubator-beam-site git commit: [BEAM-501] New skin proposal

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/9a04037f/v2/images/apache.png -- diff --git a/v2/images/apache.png b/v2/images/apache.png new file mode 100644 index 000..769fb14 Binary files /dev/null and b/v2/i

[jira] [Commented] (BEAM-501) Update website skin

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

[GitHub] incubator-beam-site pull request #51: [BEAM-501] New skin proposal

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

[jira] [Updated] (BEAM-854) ReifyTimestampAndWindows explodes windows

[ https://issues.apache.org/jira/browse/BEAM-854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-854: -- Priority: Major (was: Critical) > ReifyTimestampAndWindows explodes windows > ---

[jira] [Created] (BEAM-854) ReifyTimestampAndWindows explodes windows

Eugene Kirpichov created BEAM-854: - Summary: ReifyTimestampAndWindows explodes windows Key: BEAM-854 URL: https://issues.apache.org/jira/browse/BEAM-854 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-853) Support bound adapters for sources.

Amit Sela created BEAM-853: -- Summary: Support bound adapters for sources. Key: BEAM-853 URL: https://issues.apache.org/jira/browse/BEAM-853 Project: Beam Issue Type: Bug Components: runner

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #686

See

[jira] [Assigned] (BEAM-836) JavaDocs for DoFnRunner is not updated

[ https://issues.apache.org/jira/browse/BEAM-836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-836: Assignee: Kenneth Knowles (was: Frances Perry) > JavaDocs for DoFnRunner is not updated > --

[jira] [Assigned] (BEAM-820) Travis test_wordcount.sh retrieve snapshot from repo, not Maven reactor

[ https://issues.apache.org/jira/browse/BEAM-820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-820: Assignee: Kenneth Knowles (was: Jason Kuster) > Travis test_wordcount.sh retrieve snapshot f

[jira] [Resolved] (BEAM-821) test_wordcount.sh uses Travis CI's default settings.xml, not ours

[ https://issues.apache.org/jira/browse/BEAM-821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-821. -- Resolution: Fixed Fix Version/s: Not applicable > test_wordcount.sh uses Travis CI's defaul

[jira] [Assigned] (BEAM-821) test_wordcount.sh uses Travis CI's default settings.xml, not ours

[ https://issues.apache.org/jira/browse/BEAM-821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-821: Assignee: Kenneth Knowles (was: Jason Kuster) > test_wordcount.sh uses Travis CI's default s

[jira] [Resolved] (BEAM-820) Travis test_wordcount.sh retrieve snapshot from repo, not Maven reactor

[ https://issues.apache.org/jira/browse/BEAM-820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-820. -- Resolution: Fixed Fix Version/s: Not applicable > Travis test_wordcount.sh retrieve snapsho

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

[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-115: Assignee: Kenneth Knowles (was: Davor Bonaci) > Beam Runner API > --- > >

[jira] [Commented] (BEAM-846) Decouple side input window mapping from WindowFn

[ https://issues.apache.org/jira/browse/BEAM-846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15613384#comment-15613384 ] Kenneth Knowles commented on BEAM-846: -- Design 1-pager is https://s.apache.org/beam-sid

[jira] [Assigned] (BEAM-846) Decouple side input window mapping from WindowFn

[ https://issues.apache.org/jira/browse/BEAM-846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-846: Assignee: Kenneth Knowles (was: Frances Perry) > Decouple side input window mapping from Win

[jira] [Commented] (BEAM-822) SDK build writes timestamp to source tree, causing spurious builds

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

[2/2] incubator-beam git commit: Separate package-info.java compilation to avoid spurious rebuilds

Separate package-info.java compilation to avoid spurious rebuilds Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/324a36d5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/324a36d5 Diff: http:

[GitHub] incubator-beam pull request #1205: [BEAM-822] Adjust how and when we build p...

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

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

Repository: incubator-beam Updated Branches: refs/heads/master 3fd3951de -> f2ec82453 This closes #1205 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f2ec8245 Tree: http://git-wip-us.apache.org/repos/as

[jira] [Created] (BEAM-852) Validate sources when they are created

Chamikara Jayalath created BEAM-852: --- Summary: Validate sources when they are created Key: BEAM-852 URL: https://issues.apache.org/jira/browse/BEAM-852 Project: Beam Issue Type: Improvement

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #685

See

[jira] [Commented] (BEAM-839) The DirectRunner slows down significantly as the number of keys increases

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

[2/2] incubator-beam git commit: Use a NavigableSet Instead of a PriorityQueue in WatermarkManager

Use a NavigableSet Instead of a PriorityQueue in WatermarkManager This removes an O(n) call to remove, replacing it with an O(log(n)) call. This significantly improves scaling behavior of the DirectRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-

[GitHub] incubator-beam pull request #1202: [BEAM-839] Use a NavigableSet Instead of ...

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

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

Repository: incubator-beam Updated Branches: refs/heads/master 4cb1d10df -> 3fd3951de This closes #1202 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3fd3951d Tree: http://git-wip-us.apache.org/repos/as

[jira] [Commented] (BEAM-839) The DirectRunner slows down significantly as the number of keys increases

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

[2/2] incubator-beam git commit: Use a Constant TupleTag in GroupAlsoByWindowEvaluator

Use a Constant TupleTag in GroupAlsoByWindowEvaluator This avoids the cost of generating a random ID, which is moderately expensive. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/34a236ce Tree: http://git-

[GitHub] incubator-beam pull request #1196: [BEAM-839] Use a Constant TupleTag in Gro...

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

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

Repository: incubator-beam Updated Branches: refs/heads/master 064f18a8f -> 4cb1d10df This closes #1196 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4cb1d10d Tree: http://git-wip-us.apache.org/repos/as

[jira] [Created] (BEAM-851) Identify streaming pipelines implicitly.

Amit Sela created BEAM-851: -- Summary: Identify streaming pipelines implicitly. Key: BEAM-851 URL: https://issues.apache.org/jira/browse/BEAM-851 Project: Beam Issue Type: Improvement Compo

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[GitHub] incubator-beam pull request #1134: [BEAM-551] Allow TextIO to accept ValuePr...

GitHub user sammcveety reopened a pull request: https://github.com/apache/incubator-beam/pull/1134 [BEAM-551] Allow TextIO to accept ValueProvider Thinking about testing, is it worth having something sub-integration-test level? We'd likely want to add some convenience methods to RV

[GitHub] incubator-beam pull request #1134: [BEAM-551] Allow TextIO to accept ValuePr...

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

[jira] [Commented] (BEAM-850) Add Display Data to the Python Transforms, Sinks, Sources, etc.

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

[jira] [Created] (BEAM-850) Add Display Data to the Python Transforms, Sinks, Sources, etc.

Pablo Estrada created BEAM-850: -- Summary: Add Display Data to the Python Transforms, Sinks, Sources, etc. Key: BEAM-850 URL: https://issues.apache.org/jira/browse/BEAM-850 Project: Beam Issue T

[GitHub] incubator-beam pull request #1212: [BEAM-850] Adding display data to sink/so...

GitHub user pabloem opened a pull request: https://github.com/apache/incubator-beam/pull/1212 [BEAM-850] Adding display data to sink/sources PubSub, BigQuery, NativeFile, Fil… Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[jira] [Created] (BEAM-849) Redesign PipelineResult API

Pei He created BEAM-849: --- Summary: Redesign PipelineResult API Key: BEAM-849 URL: https://issues.apache.org/jira/browse/BEAM-849 Project: Beam Issue Type: Improvement Components: sdk-java-cor

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #684

See

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[GitHub] incubator-beam pull request #1176: [BEAM-498] Make DoFnInfo carry unspecifie...

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

[2/3] incubator-beam git commit: Update Dataflow worker image pointer

Update Dataflow worker image pointer Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/95bf7a83 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/95bf7a83 Diff: http://git-wip-us.apache.org/repos

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

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

[1/3] incubator-beam git commit: Make DoFnInfo carry OldDoFn or DoFn

Repository: incubator-beam Updated Branches: refs/heads/master ee6ad2fe4 -> 064f18a8f Make DoFnInfo carry OldDoFn or DoFn This will allow consumers to prepare to accept DoFn while still accepting existing jobs that use OldDoFn. It is a move towards treating the Fn itself as just a serialized b

[2/2] incubator-beam git commit: Removing superfluous TODO after unittest is passing

Removing superfluous TODO after unittest is passing Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/595bd0d5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/595bd0d5 Diff: http://git-wip-us.a

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

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 03662da9d -> 811858bca Closes #1209 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/811858bc Tree: http://git-wip-us.apache.org/repos/asf

[jira] [Assigned] (BEAM-826) Dynamically create subscriptions if unspecified in PubSubIO

[ https://issues.apache.org/jira/browse/BEAM-826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-826: Assignee: (was: Thomas Groh) > Dynamically create subscriptions if unspecified in PubSubIO >

[jira] [Assigned] (BEAM-826) Dynamically create subscriptions if unspecified in PubSubIO

[ https://issues.apache.org/jira/browse/BEAM-826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-826: Assignee: Thomas Groh > Dynamically create subscriptions if unspecified in PubSubIO > ---

[jira] [Assigned] (BEAM-828) Remove PipelineOptions from BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-828: Assignee: (was: Thomas Groh) > Remove PipelineOptions from BigQueryIO > -

[GitHub] incubator-beam pull request #1211: Compare display data items, not dicts.

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1211 Compare display data items, not dicts. R: @pabloem You can merge this pull request into a Git repository by running: $ git pull https://github.com/robertwb/incubator-beam display-dat

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #683

See

[jira] [Commented] (BEAM-722) Add Display Data to the Python SDK

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

[GitHub] incubator-beam pull request #1112: [BEAM-722] Display data infrastructure

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

[GitHub] incubator-beam pull request #1097: [BEAM-443] Update Beam batch examples to ...

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

[1/6] incubator-beam git commit: Addressing comments

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 57f03f793 -> 03662da9d Addressing comments Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1d478dd4 Tree: http://git-wip-us.apache.org/re

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

Closes #1112 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03662da9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/03662da9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff

[5/6] incubator-beam git commit: Moving files. Using DisplayDataItem to enable dictionaries to be used as display data

Moving files. Using DisplayDataItem to enable dictionaries to be used as 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/d864d968 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree

  1   2   >