[GitHub] beam-site pull request #160: Fix broken links due to code path changes

GitHub user melap opened a pull request: https://github.com/apache/beam-site/pull/160 Fix broken links due to code path changes You can merge this pull request into a Git repository by running: $ git pull https://github.com/melap/beam-site linkfix Alternatively you can review

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2376

See

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

[GitHub] beam pull request #2061: [BEAM-646] Deprecate, Document View.CreatePCollecti...

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

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

[1/2] beam git commit: Remove uses of CreatePCollectionView#getView

Repository: beam Updated Branches: refs/heads/master 41de9301a -> b65db428a Remove uses of CreatePCollectionView#getView Views output by this transform should be obtained by inspecting the graph node, not by interrogating the PTransform. Doing otherwise may use incorrect views after Graph Surg

[jira] [Resolved] (BEAM-1465) No natural place to flush resources in FileBasedWriter

[ https://issues.apache.org/jira/browse/BEAM-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1465. - Resolution: Fixed Fix Version/s: 0.6.0 > No natural place to flush resources in FileBasedWriter > --

[jira] [Commented] (BEAM-1465) No natural place to flush resources in FileBasedWriter

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

[GitHub] beam pull request #2067: [BEAM-1465] Add finishWrite method to FileBasedWrit...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2067 --- 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/2] beam git commit: [BEAM-1465] No natural place to flush/close resources in FileBasedWriter

Repository: beam Updated Branches: refs/heads/master ede77c1b5 -> 41de9301a [BEAM-1465] No natural place to flush/close resources in FileBasedWriter Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2b6a08f6 Tree: http://git-w

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

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

[jira] [Commented] (BEAM-475) High-quality javadoc for Beam

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

[2/4] beam-site git commit: Closes #139

Closes #139 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/2d661f9f Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/2d661f9f Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/2d661f9f Branch: re

[3/4] beam-site git commit: Minor tweaks

Minor tweaks Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/28e1b597 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/28e1b597 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/28e1b597 Branch: r

[GitHub] beam-site pull request #139: [BEAM-475] update release instructions for java...

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

[4/4] beam-site git commit: regenerate the website

regenerate the 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/845f589d Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/845f589d Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/845f589d

[1/4] beam-site git commit: [BEAM-475] update release instructions for javadoc

Repository: beam-site Updated Branches: refs/heads/asf-site 940eb0620 -> 845f589d3 [BEAM-475] update release instructions for javadoc Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/bdb0ab46 Tree: http://git-wip-us

[jira] [Assigned] (BEAM-1047) DataflowRunner: support regionalization.

[ https://issues.apache.org/jira/browse/BEAM-1047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-1047: - Assignee: Daniel Halperin (was: Pei He) > DataflowRunner: support regionalization. >

[jira] [Commented] (BEAM-1047) DataflowRunner: support regionalization.

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

[GitHub] beam pull request #2074: [BEAM-1047] Add getRegion to DataflowPipelineOption...

GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/2074 [BEAM-1047] Add getRegion to DataflowPipelineOptions You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/beam r13n-options Alternatively

[jira] [Comment Edited] (BEAM-1442) Performance improvement of the Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879034#comment-15879034 ] Pablo Estrada edited comment on BEAM-1442 at 2/22/17 7:50 PM: --

[jira] [Commented] (BEAM-1442) Performance improvement of the Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879034#comment-15879034 ] Pablo Estrada commented on BEAM-1442: - For a proposal you should include (1) Introduct

[jira] [Updated] (BEAM-1465) No natural place to flush resources in FileBasedWriter

[ https://issues.apache.org/jira/browse/BEAM-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1465: Description: {{FileBasedWriter}} API does not have a natural place to flush resources opened by the writer.

[jira] [Updated] (BEAM-1465) No natural place to flush resources in FileBasedWriter

[ https://issues.apache.org/jira/browse/BEAM-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1465: Summary: No natural place to flush resources in FileBasedWriter (was: No natural place to flush/close resour

[jira] [Commented] (BEAM-1467) Use well-known coder types for known window coders

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

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

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

[GitHub] beam pull request #2018: [BEAM-1467] Add cross-SDK implementations and tests...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2018 --- 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/2] beam git commit: Add cross-SDK implementations and tests of WindowedValueCoder

Repository: beam Updated Branches: refs/heads/master fbaac0fc8 -> ede77c1b5 Add cross-SDK implementations and tests of WindowedValueCoder Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f22f7e56 Tree: http://git-wip-us.apach

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

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

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

[1/3] beam git commit: Migrate DirectRunner one-to-one factories

Repository: beam Updated Branches: refs/heads/master 453e37bc6 -> fbaac0fc8 Migrate DirectRunner one-to-one factories Use SingleInputOutputOverrideFactory to reduce prevalence of boilerplate. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos

[2/3] beam git commit: Add a Base OverrideFactory class for 1-to-1 overrides

Add a Base OverrideFactory class for 1-to-1 overrides These overrides are relatively common, and this reduces the reimplementation of mapping singletons and casting them. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/926385c4

[GitHub] beam pull request #2055: [BEAM-646] Add a Base OverrideFactory class for 1-t...

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

[jira] [Updated] (BEAM-1529) First sentence should end with a period. [JavadocStyle]

[ https://issues.apache.org/jira/browse/BEAM-1529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1529: Description: See a tricky error with mvn verify in my local IDE: {code} [INFO] Starting audit... [ERROR] /Us

[GitHub] beam pull request #2072: Move Streaming View Overrides out of the Flink Runn...

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

[3/6] beam git commit: Move Flink Runner classes to base package and make package private

http://git-wip-us.apache.org/repos/asf/beam/blob/e0e7e52b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java -- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/

[5/6] beam git commit: Move Streaming View Overrides out of the Flink Runner

Move Streaming View Overrides out of the Flink Runner These are specific to the streaming Runner and don't need to be in the FlinkRunner. This is also preparation for getting Flink out of the Runner.apply(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apac

[2/6] beam git commit: Move Flink Runner classes to base package and make package private

http://git-wip-us.apache.org/repos/asf/beam/blob/e0e7e52b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java -- diff --git a/runners/flink/runner/src/main/java/org/apac

[6/6] beam git commit: This closes #2072

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

[1/6] beam git commit: Move Flink Runner classes to base package and make package private

Repository: beam Updated Branches: refs/heads/master 88e842534 -> 453e37bc6 http://git-wip-us.apache.org/repos/asf/beam/blob/e0e7e52b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java

[4/6] beam git commit: Move Flink Runner classes to base package and make package private

Move Flink Runner classes to base package and make package private Moving them all into the same package allows making a lot of stuff package private. This is also in preparation of getting the Flink Runner out of the Runner.apply(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Comm

[GitHub] beam pull request #2035: Obtain Flink Views from the Context Output

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

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

[1/2] beam git commit: Obtain Flink Views from the Context Output

Repository: beam Updated Branches: refs/heads/master d7ed2e23a -> 88e842534 Obtain Flink Views from the Context Output Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/810a5b4b Tree: http://git-wip-us.apache.org/repos/asf/bea

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Dataflow #2373

See

[jira] [Updated] (BEAM-1398) KafkaIO metrics

[ https://issues.apache.org/jira/browse/BEAM-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1398: Description: Add metrics to {{KafkaIO}} using the metrics API. Metrics (Feel free to add more ideas here) pe

[jira] [Commented] (BEAM-1320) Add sphinx or pydocs documentation for python-sdk

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

[GitHub] beam pull request #2059: [BEAM-1320] Fix documentation in the sdk and fail f...

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

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

[1/2] beam git commit: [BEAM-1320] Fix documentation in the sdk and fail for new errors

Repository: beam Updated Branches: refs/heads/master 8b2e8f295 -> d7ed2e23a [BEAM-1320] Fix documentation in the sdk and fail for new errors Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/228b18e8 Tree: http://git-wip-us.ap

[jira] [Updated] (BEAM-1398) KafkaIO metrics

[ https://issues.apache.org/jira/browse/BEAM-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1398: Description: Add metrics to {{KafkaIO}} using the metrics API. Metrics (Feel free to add more ideas here) pe

[jira] [Created] (BEAM-1536) Build a kubernetes environment for running examples on Spark runner

Nitin Lamba created BEAM-1536: - Summary: Build a kubernetes environment for running examples on Spark runner Key: BEAM-1536 URL: https://issues.apache.org/jira/browse/BEAM-1536 Project: Beam Iss

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

[ https://issues.apache.org/jira/browse/BEAM-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15878503#comment-15878503 ] Jean-Baptiste Onofré commented on BEAM-1534: Great thanks ! By the way, I crea

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

[ https://issues.apache.org/jira/browse/BEAM-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15878496#comment-15878496 ] Ekrem Aksoy commented on BEAM-1534: --- I'm taking on this. I will elaborate to create Vagra

[jira] [Created] (BEAM-1535) Build a kubernetes environment for running examples on (direct) Java runner

Nitin Lamba created BEAM-1535: - Summary: Build a kubernetes environment for running examples on (direct) Java runner Key: BEAM-1535 URL: https://issues.apache.org/jira/browse/BEAM-1535 Project: Beam

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

Nitin Lamba created BEAM-1534: - Summary: Create a dockerized developer environment for Beam Key: BEAM-1534 URL: https://issues.apache.org/jira/browse/BEAM-1534 Project: Beam Issue Type: New Featu

[jira] [Updated] (BEAM-1398) KafkaIO metrics

[ https://issues.apache.org/jira/browse/BEAM-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1398: Description: Add metrics to {{KafkaIO}} using the metrics API. Metrics (Feel free to add more ideas here) pe

[jira] [Commented] (BEAM-1048) Spark Runner streaming batch duration does not include duration of reading from source

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

[GitHub] beam pull request #2073: [BEAM-1048] Added a per-batch read duration metric ...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2073 [BEAM-1048] Added a per-batch read duration metric to SparkUnboundedSource. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sur

[jira] [Assigned] (BEAM-1513) Skip slower verifications if '-Dquick' specified. Enable them otherwise

[ https://issues.apache.org/jira/browse/BEAM-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1513: --- Assignee: Davor Bonaci (was: Aviem Zur) > Skip slower verifications if '-Dquick' specified. Enable th

[jira] [Commented] (BEAM-1513) Skip slower verifications if '-Dquick' specified. Enable them otherwise

[ https://issues.apache.org/jira/browse/BEAM-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15878354#comment-15878354 ] Jean-Baptiste Onofré commented on BEAM-1513: I re-open the Jira as we didn't ge

[jira] [Updated] (BEAM-1513) Skip slower verifications if '-Dquick' specified. Enable them otherwise

[ https://issues.apache.org/jira/browse/BEAM-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-1513: --- Fix Version/s: (was: 0.6.0) > Skip slower verifications if '-Dquick' specified. Ena

[jira] [Reopened] (BEAM-1513) Skip slower verifications if '-Dquick' specified. Enable them otherwise

[ https://issues.apache.org/jira/browse/BEAM-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reopened BEAM-1513: > Skip slower verifications if '-Dquick' specified. Enable them otherwise > -

beam git commit: Revert "[BEAM-1513] Skip slower verifications if '-DskipTests' specified"

Repository: beam Updated Branches: refs/heads/master 5ca149de2 -> 8b2e8f295 Revert "[BEAM-1513] Skip slower verifications if '-DskipTests' specified" This reverts commit 22ace8581d6758015d3beff3850c5ee9017b2dd9. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip

[GitHub] beam pull request #2072: Move Streaming View Overrides out of the Flink Runn...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2072 Move Streaming View Overrides out of the Flink Runner These are specific to the streaming Runner and don't need to be in the FlinkRunner. This is also preparation for getting Flink out of the

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Dataflow #2372

See -- [...truncated 1.12 MB...] 2017-02-22T12:08:19.231 [INFO] 2017-02-22T12:08:19.231 [INFO] --- maven-source-plugin:3.0.1:jar-no-fork (attach-sources)

[jira] [Created] (BEAM-1533) Switch split implementation to use Beam’s classes for HBaseIO

Ismaël Mejía created BEAM-1533: -- Summary: Switch split implementation to use Beam’s classes for HBaseIO Key: BEAM-1533 URL: https://issues.apache.org/jira/browse/BEAM-1533 Project: Beam Issue T

[jira] [Assigned] (BEAM-1533) Switch split implementation to use Beam’s classes for HBaseIO

[ https://issues.apache.org/jira/browse/BEAM-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1533: -- Assignee: Ismaël Mejía (was: Davor Bonaci) > Switch split implementation to use Beam’s classes

[jira] [Created] (BEAM-1532) Improve splitting (support sub-splits) for HBaseIO

Ismaël Mejía created BEAM-1532: -- Summary: Improve splitting (support sub-splits) for HBaseIO Key: BEAM-1532 URL: https://issues.apache.org/jira/browse/BEAM-1532 Project: Beam Issue Type: Improve

[jira] [Created] (BEAM-1531) Support dynamic work rebalancing for HBaseIO

Ismaël Mejía created BEAM-1531: -- Summary: Support dynamic work rebalancing for HBaseIO Key: BEAM-1531 URL: https://issues.apache.org/jira/browse/BEAM-1531 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-293) StreamingOptions should not extend GcpOptions

[ https://issues.apache.org/jira/browse/BEAM-293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-293. --- Resolution: Fixed Fix Version/s: 0.6.0 > StreamingOptions should not extend GcpOp

[jira] [Resolved] (BEAM-1157) Create HBaseIO

[ https://issues.apache.org/jira/browse/BEAM-1157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1157. Resolution: Fixed Fix Version/s: 0.6.0 > Create HBaseIO > -- > > K

[jira] [Commented] (BEAM-1517) Garbage collect user state in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15877903#comment-15877903 ] Aljoscha Krettek commented on BEAM-1517: [~lzljs3620320] We cannot depend on users

[jira] [Commented] (BEAM-1442) Performance improvement of the Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15877888#comment-15877888 ] Haoxiang commented on BEAM-1442: Hi Pablo: I'm Interested in this peoject, so what should I

[GitHub] beam pull request #2071: Remove unneeded plugins sections from the IO (inher...

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/2071 Remove unneeded plugins sections from the IO (inherited from parent) Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the P

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Dataflow #2371

See Changes: [ansela] [BEAM-1526] Suppress Spark WatermarkTest#testInDoFn due to flakes -- [...truncated 1.05 MB...] 2017-02-22T08:16:16.509

[jira] [Resolved] (BEAM-1526) Flakes in Spark runner WatermarkTest.testInDoFn

[ https://issues.apache.org/jira/browse/BEAM-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1526. - Resolution: Fixed Fix Version/s: 0.6.0 > Flakes in Spark runner WatermarkTest.testInDoFn > -

[GitHub] beam pull request #2070: [BEAM-1530] Support record-determined output tables

GitHub user reuvenlax opened a pull request: https://github.com/apache/beam/pull/2070 [BEAM-1530] Support record-determined output tables Changes the existing tableRefFunction: BoundedWindow -> String, to a policy that takes a Context object. This allows us to add further items to t

[jira] [Commented] (BEAM-1530) BigQueryIO should support value-dependent windows

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

[jira] [Commented] (BEAM-1526) Flakes in Spark runner WatermarkTest.testInDoFn

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

[GitHub] beam pull request #2060: [BEAM-1526] Suppress Spark WatermarkTest#testInDoFn...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2060 --- 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/2] beam git commit: [BEAM-1526] Suppress Spark WatermarkTest#testInDoFn due to flakes

Repository: beam Updated Branches: refs/heads/master ed0d4577d -> 5ca149de2 [BEAM-1526] Suppress Spark WatermarkTest#testInDoFn due to flakes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/146ce988 Tree: http://git-wip-us.a

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

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

[jira] [Created] (BEAM-1530) BigQueryIO should support value-dependent windows

Reuven Lax created BEAM-1530: Summary: BigQueryIO should support value-dependent windows Key: BEAM-1530 URL: https://issues.apache.org/jira/browse/BEAM-1530 Project: Beam Issue Type: Improvement

<    1   2