[3/3] beam git commit: This closes #2468

This closes #2468 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c58f4f89 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c58f4f89 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c58f4f89 Branch:

[2/3] beam git commit: Removes DoFn.ProcessContinuation completely

Removes DoFn.ProcessContinuation completely Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/62e23b71 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/62e23b71 Diff:

[1/3] beam git commit: Bump Dataflow worker to 20170410

Repository: beam Updated Branches: refs/heads/master 0a0b1c80c -> c58f4f89b Bump Dataflow worker to 20170410 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/159ac581 Tree: http://git-wip-us.apache.org/repos/asf/beam/t

[GitHub] beam pull request #2468: Removes DoFn.ProcessContinuation completely

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

[jira] [Commented] (BEAM-1891) Java @Autovalue: currently doesn't have a good coder

[ https://issues.apache.org/jira/browse/BEAM-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963833#comment-15963833 ] Raghavendra Nayak M commented on BEAM-1891: --- Thanks Stephen, Yes I was looking for that. > Java

[jira] [Commented] (BEAM-463) BoundedHeapCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963790#comment-15963790 ] Luke Cwik commented on BEAM-463: The motivation was about getting introspection into the coder components,

[jira] [Updated] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environment variable

[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangping wu updated BEAM-1491: -- Summary: HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environment variable

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3247

See

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Apex #1046

See

[jira] [Resolved] (BEAM-1053) ApexGroupByKeyOperator serialization issues

[ https://issues.apache.org/jira/browse/BEAM-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved BEAM-1053. Resolution: Fixed Fix Version/s: First stable release > ApexGroupByKeyOperator serialization

[jira] [Commented] (BEAM-1832) Potentially unclosed OutputStream in ApexYarnLauncher

[ https://issues.apache.org/jira/browse/BEAM-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963765#comment-15963765 ] Thomas Weise commented on BEAM-1832: [~davor] can you please add Rekha as contributor? > Potentially

[jira] [Resolved] (BEAM-1832) Potentially unclosed OutputStream in ApexYarnLauncher

[ https://issues.apache.org/jira/browse/BEAM-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved BEAM-1832. Resolution: Fixed Fix Version/s: First stable release > Potentially unclosed OutputStream in

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #2272

See -- [...truncated 230.29 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

[GitHub] beam pull request #2486: [BEAM-1928] Move WindowingStrategies to runners-cor...

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

[jira] [Commented] (BEAM-1928) Populate Runner API Components from the Java SDK

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

[2/2] beam git commit: This closes #2486

This closes #2486 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0a0b1c80 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0a0b1c80 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0a0b1c80 Branch:

[1/2] beam git commit: Move WindowingStrategies to runners-core-construction

Repository: beam Updated Branches: refs/heads/master 7fd9c6516 -> 0a0b1c80c Move WindowingStrategies to runners-core-construction Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/40b36686 Tree:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Apex #1045

See

[GitHub] beam-site pull request #206: [BEAM-1452] Add composite triggers section to p...

GitHub user melap opened a pull request: https://github.com/apache/beam-site/pull/206 [BEAM-1452] Add composite triggers section to programming guide You can merge this pull request into a Git repository by running: $ git pull https://github.com/melap/beam-site composite

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3241

See

[jira] [Commented] (BEAM-1891) Java @Autovalue: currently doesn't have a good coder

[ https://issues.apache.org/jira/browse/BEAM-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963586#comment-15963586 ] Stephen Sisk commented on BEAM-1891: You'll need to learn about coders, which can be a bit tricky, but

[jira] [Commented] (BEAM-1865) Input Coder of GroupByKey should be a KV Coder in the Python SDK

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

[GitHub] beam pull request #2470: [BEAM-1865]: Fix GroupByKeyInputVisitor for Direct ...

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

[2/2] beam git commit: This closes #2470

This closes #2470 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7fd9c651 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7fd9c651 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7fd9c651 Branch:

[1/2] beam git commit: Fix GroupByKeyInputVisitor for Direct Runner

Repository: beam Updated Branches: refs/heads/master 1761d1cab -> 7fd9c6516 Fix GroupByKeyInputVisitor for Direct Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9e453fab Tree:

[jira] [Commented] (BEAM-802) Support Dynamic PipelineOptions for python

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

[1/2] beam git commit: Skip query metrics when creating a template

Repository: beam Updated Branches: refs/heads/master 1c7a974ab -> 1761d1cab Skip query metrics when creating a template Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/67883309 Tree:

[GitHub] beam pull request #2475: [BEAM-802] Skip query metrics for template creation

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

[2/2] beam git commit: This closes #2475

This closes #2475 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1761d1ca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1761d1ca Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1761d1ca Branch:

[jira] [Commented] (BEAM-1928) Populate Runner API Components from the Java SDK

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

[GitHub] beam pull request #2484: Upgrade dependencies

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

[GitHub] beam-site pull request #205: Add to in-progress IO list and alphabetize

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

[1/2] beam git commit: Upgrade dependencies.

Repository: beam Updated Branches: refs/heads/master 8afa62398 -> 1c7a974ab Upgrade dependencies. Minor version changes to use latest versions of avro, pyyaml, google-apitools, googledatastore. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #2484

This closes #2484 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1c7a974a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1c7a974a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1c7a974a Branch:

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

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/4810a749 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/4810a749 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/4810a749

[1/3] beam-site git commit: Add to in-progress IO list and alphabetize

Repository: beam-site Updated Branches: refs/heads/asf-site fd7fe0627 -> 0542df3af Add to in-progress IO list and alphabetize Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/732378da Tree:

[3/3] beam-site git commit: This closes #205

This closes #205 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/0542df3a Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/0542df3a Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/0542df3a

[jira] [Commented] (BEAM-1928) Populate Runner API Components from the Java SDK

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

[GitHub] beam pull request #2459: [BEAM-1928] Add SdkComponents

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

[1/2] beam git commit: This closes #2459

Repository: beam Updated Branches: refs/heads/master fc1006500 -> 8afa62398 This closes #2459 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8afa6239 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8afa6239 Diff:

[2/2] beam git commit: Add SdkComponents

Add SdkComponents This takes SDK objects and assigns IDs to them. It is effectively a ComponentsBuilder context where a component is referred to by the Java object which is being translated, rather than by an opaque string or protocol buffer. Project:

[jira] [Created] (BEAM-1928) Populate Runner API Components from the Java SDK

Thomas Groh created BEAM-1928: - Summary: Populate Runner API Components from the Java SDK Key: BEAM-1928 URL: https://issues.apache.org/jira/browse/BEAM-1928 Project: Beam Issue Type: New

[GitHub] beam pull request #2486: Move WindowingStrategies to runners-core-constructi...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2486 Move WindowingStrategies to runners-core-construction Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Commented] (BEAM-1891) Java @Autovalue: currently doesn't have a good coder

[ https://issues.apache.org/jira/browse/BEAM-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963558#comment-15963558 ] Raghavendra Nayak M commented on BEAM-1891: --- I could see this improvement is listed as

[jira] [Created] (BEAM-1927) Add tfrecord io to built in IO list

Ahmet Altay created BEAM-1927: - Summary: Add tfrecord io to built in IO list Key: BEAM-1927 URL: https://issues.apache.org/jira/browse/BEAM-1927 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-1708) Better error messages when GCP features are not installed

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

[GitHub] beam pull request #2485: [BEAM-1708] Improve error message when GCP not inst...

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/2485 [BEAM-1708] Improve error message when GCP not installed Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Commented] (BEAM-1895) Create tranform in python sdk should be a custom source

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

[GitHub] beam pull request #2446: [BEAM-1895] Python Create as a custom source

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

[1/2] beam git commit: Create as custom source

Repository: beam Updated Branches: refs/heads/master 836e8e4aa -> fc1006500 Create as custom source Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/33d4a02b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/33d4a02b

[2/2] beam git commit: This closes #2446

This closes #2446 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fc100650 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fc100650 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fc100650 Branch:

[GitHub] beam pull request #2484: Upgrade dependencies

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2484 Upgrade dependencies Minor version changes to use latest versions of avro, pyyaml, google-apitools, googledatastore. R: @vikkyrk @eddavisson You can merge this pull request into a Git

[GitHub] beam pull request #2483: [BEAM-1222] Chunk size should be FS dependent

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/2483 [BEAM-1222] Chunk size should be FS dependent Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[jira] [Commented] (BEAM-1053) ApexGroupByKeyOperator serialization issues

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

[GitHub] beam pull request #2473: [BEAM-1053] ApexGroupByKeyOperator serialization is...

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

[1/2] beam git commit: BEAM-1053 ApexGroupByKeyOperator serialization issues

Repository: beam Updated Branches: refs/heads/master 80d2548f2 -> 836e8e4aa BEAM-1053 ApexGroupByKeyOperator serialization issues Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/74e31c35 Tree:

[2/2] beam git commit: This closes #2473

This closes #2473 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/836e8e4a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/836e8e4a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/836e8e4a Branch:

[jira] [Created] (BEAM-1926) Need 3 Python snippets for composite transforms section in programming guide

Melissa Pashniak created BEAM-1926: -- Summary: Need 3 Python snippets for composite transforms section in programming guide Key: BEAM-1926 URL: https://issues.apache.org/jira/browse/BEAM-1926

[jira] [Commented] (BEAM-1922) DataSource in JdbcIO is not closed

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

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #3237

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #292

See Changes: [altay] better log message for bigquery temp tables [dhalperi] BEAM-1390 Update top level README.md to include Apex Runner [dhalperi] [BEAM-386] Move UnboundedReadFromBoundedSource to

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Apex #1039

See

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963264#comment-15963264 ] Aljoscha Krettek commented on BEAM-1612: I'll see if we can still get it into Flink 1.3. Then yes,

[jira] [Assigned] (BEAM-464) HolderCoder should be a StandardCoder and not a CustomCoder

[ https://issues.apache.org/jira/browse/BEAM-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-464: -- Assignee: (was: Luke Cwik) > HolderCoder should be a StandardCoder and not a CustomCoder >

[jira] [Commented] (BEAM-1924) pip download failed in post commit

[ https://issues.apache.org/jira/browse/BEAM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963254#comment-15963254 ] Sourabh Bajaj commented on BEAM-1924: - One improvement that comes to mind is that we should pass the

[jira] [Resolved] (BEAM-1124) Python ValidateRunner Test test_multi_valued_singleton_side_input Break Postcommit

[ https://issues.apache.org/jira/browse/BEAM-1124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1124. --- Resolution: Fixed Fix Version/s: Not applicable > Python ValidateRunner Test

[jira] [Commented] (BEAM-1124) Python ValidateRunner Test test_multi_valued_singleton_side_input Break Postcommit

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

[GitHub] beam pull request #2467: [BEAM-1124] enable test_multi_valued_singleton_side...

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

[1/2] beam git commit: enable test_multi_valued_singleton_side_input test

Repository: beam Updated Branches: refs/heads/master e0e39a975 -> 80d2548f2 enable test_multi_valued_singleton_side_input test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a3a15a53 Tree:

[jira] [Commented] (BEAM-1925) Make DoFn invocation logic of Python SDK more extensible

[ https://issues.apache.org/jira/browse/BEAM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963243#comment-15963243 ] Chamikara Jayalath commented on BEAM-1925: -- cc: [~sb2nov] [~robertwb] [~jkff] > Make DoFn

[jira] [Updated] (BEAM-1924) pip download failed in post commit

[ https://issues.apache.org/jira/browse/BEAM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-1924: -- Description: A post commit failed with a pip failure:

[jira] [Created] (BEAM-1924) pip download failed in post commit

Ahmet Altay created BEAM-1924: - Summary: pip download failed in post commit Key: BEAM-1924 URL: https://issues.apache.org/jira/browse/BEAM-1924 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-1925) Make DoFn invocation logic of Python SDK more extensible

Chamikara Jayalath created BEAM-1925: Summary: Make DoFn invocation logic of Python SDK more extensible Key: BEAM-1925 URL: https://issues.apache.org/jira/browse/BEAM-1925 Project: Beam

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3236

See

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963239#comment-15963239 ] Kenneth Knowles commented on BEAM-1612: --- Do think this is possible for the first stable release? >

[jira] [Closed] (BEAM-1905) ParDoTranslation should translate a ParDo more simple?

[ https://issues.apache.org/jira/browse/BEAM-1905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1905. -- Resolution: Won't Fix Fix Version/s: Not applicable This was changed in

[jira] [Commented] (BEAM-1886) Remove TextIO override in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963232#comment-15963232 ] Kenneth Knowles commented on BEAM-1886: --- CC: [~reuvenlax] who is making changes in that area of the

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1802

See

[jira] [Assigned] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-1105: - Assignee: (was: Neelesh Srinivas Salian) > Adding Beam's pico Wordcount to the existing

[jira] [Resolved] (BEAM-1753) ImportError (cannot import name descriptor) in new venv after 'python setup.py install'

[ https://issues.apache.org/jira/browse/BEAM-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1753. --- Resolution: Cannot Reproduce Fix Version/s: Not applicable > ImportError (cannot import name

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1578

See

[jira] [Commented] (BEAM-1886) Remove TextIO override in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963221#comment-15963221 ] Aljoscha Krettek commented on BEAM-1886: +1 I think we should remove these overrides. They are

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963220#comment-15963220 ] Aljoscha Krettek commented on BEAM-1612: Yes, it would also allow multiple buffers to be considered

[jira] [Comment Edited] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963215#comment-15963215 ] Neelesh Srinivas Salian edited comment on BEAM-1105 at 4/10/17 5:18 PM:

[jira] [Commented] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963215#comment-15963215 ] Neelesh Srinivas Salian commented on BEAM-1105: --- Feel free to grab [~altay] > Adding Beam's

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Apex #1038

See

[GitHub] beam pull request #2481: [BEAM-386] Move UnboundedReadFromBoundedSource to c...

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

[jira] [Commented] (BEAM-386) Dataflow runner to support Read.Bounded in streaming mode.

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

[1/3] beam git commit: [BEAM-386] Move UnboundedReadFromBoundedSource to core-construction-java

Repository: beam Updated Branches: refs/heads/master e53f959f9 -> e0e39a975 http://git-wip-us.apache.org/repos/asf/beam/blob/66229142/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowUnboundedReadFromBoundedSource.java

[3/3] beam git commit: This closes #2481

This closes #2481 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0e39a97 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0e39a97 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e0e39a97 Branch:

[jira] [Updated] (BEAM-976) Update examples README.md to fix instructions to run pipelines

[ https://issues.apache.org/jira/browse/BEAM-976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-976: - Fix Version/s: First stable release > Update examples README.md to fix instructions to run pipelines >

[jira] [Commented] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963208#comment-15963208 ] Ahmet Altay commented on BEAM-1105: --- Hey [~nssalian], are you working on this? > Adding Beam's pico

[jira] [Resolved] (BEAM-1056) Reference beam version only once in Archetypes

[ https://issues.apache.org/jira/browse/BEAM-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1056. --- Resolution: Fixed Fix Version/s: Not applicable > Reference beam version only once in

[jira] [Assigned] (BEAM-933) Findbugs doesn't pass in Java Examples

[ https://issues.apache.org/jira/browse/BEAM-933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-933: Assignee: (was: Davor Bonaci) > Findbugs doesn't pass in Java Examples >

[jira] [Updated] (BEAM-933) Findbugs doesn't pass in Java Examples

[ https://issues.apache.org/jira/browse/BEAM-933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-933: - Labels: newbie starter (was: ) > Findbugs doesn't pass in Java Examples >

[jira] [Updated] (BEAM-934) Findbugs doesn't pass in Java8 Examples

[ https://issues.apache.org/jira/browse/BEAM-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-934: - Labels: newbie starter (was: ) > Findbugs doesn't pass in Java8 Examples >

[jira] [Assigned] (BEAM-934) Findbugs doesn't pass in Java8 Examples

[ https://issues.apache.org/jira/browse/BEAM-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-934: Assignee: (was: Davor Bonaci) > Findbugs doesn't pass in Java8 Examples >

[jira] [Closed] (BEAM-1864) Shorten combining state names: "CombiningValue" and "AccumulatorCombiningState" to Combining (as appropriate)

[ https://issues.apache.org/jira/browse/BEAM-1864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-1864. - Resolution: Fixed > Shorten combining state names: "CombiningValue" and >

[jira] [Updated] (BEAM-1864) Shorten combining state names: "CombiningValue" and "AccumulatorCombiningState" to Combining (as appropriate)

[ https://issues.apache.org/jira/browse/BEAM-1864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1864: -- Labels: backward-incompatible (was: ) > Shorten combining state names: "CombiningValue" and >

[jira] [Updated] (BEAM-539) Error when writing to the root of a GCS location

[ https://issues.apache.org/jira/browse/BEAM-539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-539: - Labels: newbie starter (was: ) > Error when writing to the root of a GCS location >

  1   2   >