[jira] [Updated] (BEAM-1775) fix issue of start_from_previous_offset in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1775: - Priority: Minor (was: Major) > fix issue of start_from_previous_offset in KafkaIO > --

[jira] [Updated] (BEAM-1705) add method in Pipeline to visualize the DAG

[ https://issues.apache.org/jira/browse/BEAM-1705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1705: - Priority: Minor (was: Major) > add method in Pipeline to visualize the DAG > -

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

[ https://issues.apache.org/jira/browse/BEAM-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin resolved BEAM-1514. -- Resolution: Fixed Fix Version/s: Not applicable > change default timestamp in KafkaIO > --

[GitHub] beam pull request #2340: [BEAM-1328] DataflowRunner: Send WindowingStrategy ...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2340 [BEAM-1328] DataflowRunner: Send WindowingStrategy as proto Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR tit

[jira] [Commented] (BEAM-1328) Serialize/deserialize WindowingStrategy in a language-agnostic manner

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

[jira] [Updated] (BEAM-1797) add CoGroupByKey to chapter 'Using GroupByKey'

[ https://issues.apache.org/jira/browse/BEAM-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1797: - Description: In https://beam.apache.org/documentation/programming-guide/#transforms-sideio, the chapter {{

[jira] [Updated] (BEAM-1797) add CoGroupByKey to chapter 'Using GroupByKey'

[ https://issues.apache.org/jira/browse/BEAM-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1797: - Description: In https://beam.apache.org/documentation/programming-guide/#transforms-sideio, the chapter {{

[jira] [Updated] (BEAM-1797) add CoGroupByKey to chapter 'Using GroupByKey'

[ https://issues.apache.org/jira/browse/BEAM-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1797: - Description: In https://beam.apache.org/documentation/programming-guide/#transforms-sideio, the chapter {{

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

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

[1/2] beam git commit: Fix Python Dataflow default job name

Repository: beam Updated Branches: refs/heads/master 44472c76c -> 07274bbfe Fix Python Dataflow default job name Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/021e2a07 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree

[GitHub] beam pull request #2322: [BEAM-1801] Fix Python Dataflow default job name

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2322 --- 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] [Commented] (BEAM-1801) default_job_name can generate names not accepted by DataFlow

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

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2657

See

[jira] [Resolved] (BEAM-1770) DoFn javadoc claims no runner supports state or timers

[ https://issues.apache.org/jira/browse/BEAM-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1770. --- Resolution: Fixed Fix Version/s: First stable release > DoFn javadoc claims no runner su

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

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

[jira] [Resolved] (BEAM-1801) default_job_name can generate names not accepted by DataFlow

[ https://issues.apache.org/jira/browse/BEAM-1801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1801. --- Resolution: Fixed Fix Version/s: First stable release > default_job_name can generate names not

[GitHub] beam pull request #2243: [BEAM-1693] Detect supported Python & pip executabl...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2243 --- 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-1693] Detect supported Python & pip executables in Python-SDK

Repository: beam Updated Branches: refs/heads/master 07274bbfe -> affcca669 [BEAM-1693] Detect supported Python & pip executables in Python-SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c7c153a5 Tree: http://git-wip-us

[GitHub] beam-site pull request #195: [BEAM-1797] add CoGroupByKey to chapter 'Using ...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam-site/pull/195 [BEAM-1797] add CoGroupByKey to chapter 'Using GroupByKey' `CoGroupByKey` is the main component to create a JOIN operation in Beam pipeline, add the usage to chapter `Using GroupByKey`. Yo

[jira] [Commented] (BEAM-1797) add CoGroupByKey to chapter 'Using GroupByKey'

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

[jira] [Commented] (BEAM-1693) Detect supported Python & pip executables in Python-SDK

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

[1/3] beam-site git commit: Reword RunnableOnService to ValidatesRunner

Repository: beam-site Updated Branches: refs/heads/asf-site e3423939c -> 0ee032422 Reword RunnableOnService to ValidatesRunner Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/81bafde5 Tree: http://git-wip-us.apache

[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/7453a1a8 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/7453a1a8 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/7453a1a8 Bra

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

This closes #194 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/0ee03242 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/0ee03242 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/0ee03242 Branc

[GitHub] beam-site pull request #194: [BEAM-1622] Reword RunnableOnService to Validat...

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

[1/2] beam git commit: [BEAM-1778] Clean up unused dataflow javadoc directory

Repository: beam Updated Branches: refs/heads/master affcca669 -> 6d627534b [BEAM-1778] Clean up unused dataflow javadoc directory Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa64a63b Tree: http://git-wip-us.apache.org/r

[jira] [Commented] (BEAM-1622) Java: Rename RunnableOnService to ValidatesRunner

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

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

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

[GitHub] beam pull request #2316: [BEAM-1778] Clean up unused dataflow javadoc direct...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2316 --- 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-1514) change default timestamp in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-1514: --- Fix Version/s: (was: Not applicable) First stable release > change default times

[jira] [Commented] (BEAM-1778) Clean up pass of dataflow/google references/URLs in Java SDK

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

[jira] [Assigned] (BEAM-1820) Source.getDefaultOutputCoder() should be @Nullable

[ https://issues.apache.org/jira/browse/BEAM-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1820: -- Assignee: (was: Davor Bonaci) > Source.getDefaultOutputCoder() should be @Nullable > ---

[jira] [Commented] (BEAM-1717) Maven release/deploy tries to uploads some artifacts more than once

[ https://issues.apache.org/jira/browse/BEAM-1717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944168#comment-15944168 ] Davor Bonaci commented on BEAM-1717: Thanks! (I'll let you know if I get a little bit o

[jira] [Commented] (BEAM-688) Failure of beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944171#comment-15944171 ] Davor Bonaci commented on BEAM-688: --- Anybody else? ([~kenn], [~neelesh77], [~venbijjam])

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3056

See

[GitHub] beam pull request #2341: Refers to NeedsRunner in javadoc of TestPipeline

GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/2341 Refers to NeedsRunner in javadoc of TestPipeline This is more correct than referring to ValidatesRunner, since NeedsRunner is the far more common use case for end-users, and ValidatesRunner is it

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2658

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #238

See Changes: [klk] Port Java modules from RunnableOnService to ValidatesRunner [klk] Remove deprecated RunnableOnService [altay] Pin the python postcommit jenkins nodes [tgroh] Do not reify timest

[GitHub] beam pull request #2342: Add region option to Dataflow pipeline options.

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2342 Add region option to Dataflow pipeline options. R: @charlesccychen cc: @dhalperi You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam r

[jira] [Commented] (BEAM-1735) Retry 403:rateLimitExceeded in GCS

[ https://issues.apache.org/jira/browse/BEAM-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944295#comment-15944295 ] Davor Bonaci commented on BEAM-1735: This is a batched copy request to Cloud Storage du

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

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

[1/2] beam git commit: Querying of both structured and unstructured metrics in dataflow.

Repository: beam Updated Branches: refs/heads/master 6d627534b -> e58155263 Querying of both structured and unstructured metrics in dataflow. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b98bde91 Tree: http://git-wip-us.a

[GitHub] beam pull request #2290: [BEAM-772] Querying of both structured and unstruct...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2290 --- 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] [Commented] (BEAM-772) Implement Metrics support for Dataflow Runner

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

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3059

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3060

See Changes: [altay] Querying of both structured and unstructured metrics in dataflow. -- [...truncated 1.40 MB...] 2017-03-28T00:59:33.348 [INFO] urls[20

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

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

[1/2] beam git commit: Add region option to Dataflow pipeline options.

Repository: beam Updated Branches: refs/heads/master e58155263 -> fe441e34b Add region option to Dataflow pipeline options. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c8d251fc Tree: http://git-wip-us.apache.org/repos/as

[GitHub] beam pull request #2342: Add region option to Dataflow pipeline options.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2342 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] beam pull request #2326: [BEAM-1809] Make TravisCI builds less broken

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

[jira] [Commented] (BEAM-1809) Fix one error in TravisCI build

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #1644

See Changes: [altay] Add region option to Dataflow pipeline options. -- [...truncated 505.83 KB...] test_getitem_duplicates_ignored (apache_beam.typehints.ty

[jira] [Commented] (BEAM-1793) Frequent python post commit errors

[ https://issues.apache.org/jira/browse/BEAM-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944369#comment-15944369 ] Ahmet Altay commented on BEAM-1793: --- Another error after the change: https://builds.apach

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3061

See

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2660

See

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

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

[GitHub] beam pull request #2304: [BEAM-1792] Changing Spark to use MetricFiltering

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2304 --- 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-1792] Use MetricFiltering in Spark runner.

Repository: beam Updated Branches: refs/heads/master fe441e34b -> 85b820c37 [BEAM-1792] Use MetricFiltering in Spark runner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/241ded90 Tree: http://git-wip-us.apache.org/repos/a

[jira] [Commented] (BEAM-1792) Spark runner uses its own filtering logic to match metrics

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

[jira] [Resolved] (BEAM-1698) Comply with metrics querying semantics in Spark Runner

[ https://issues.apache.org/jira/browse/BEAM-1698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1698. - Resolution: Duplicate Fix Version/s: Not applicable > Comply with metrics querying semantics in Spar

[jira] [Resolved] (BEAM-1792) Spark runner uses its own filtering logic to match metrics

[ https://issues.apache.org/jira/browse/BEAM-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1792. - Resolution: Fixed Fix Version/s: First stable release > Spark runner uses its own filtering logic to

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3062

See -- [...truncated 219.30 KB...] x [deleted] (none) -> origin/pr/972/head x [deleted] (none) -> origin/pr/973/head x [deleted] (none

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #1404

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

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Flink #2090

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

[jira] [Updated] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded.

[ https://issues.apache.org/jira/browse/BEAM-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1074: Issue Type: Improvement (was: Sub-task) Parent: (was: BEAM-848) > Set default-partitioner in Sou

[jira] [Updated] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded.

[ https://issues.apache.org/jira/browse/BEAM-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1074: Description: The SparkRunner uses {{mapWithState}} to read and manage CheckpointMarks, and this stateful ope

[jira] [Updated] (BEAM-848) A better shuffle after reading from within mapWithState.

[ https://issues.apache.org/jira/browse/BEAM-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-848: --- Description: It would be wise to shuffle the read values _after_ flatmap to increase parallelism in processing o

[jira] [Updated] (BEAM-848) Shuffle the input read-values to get maximum parallelism.

[ https://issues.apache.org/jira/browse/BEAM-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-848: --- Summary: Shuffle the input read-values to get maximum parallelism. (was: A better shuffle after reading from wi

[jira] [Resolved] (BEAM-1622) Java: Rename RunnableOnService to ValidatesRunner

[ https://issues.apache.org/jira/browse/BEAM-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1622. --- Resolution: Fixed Fix Version/s: First stable release > Java: Rename RunnableOnService t

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2661

See

[jira] [Updated] (BEAM-848) Shuffle input read-values to get maximum parallelism.

[ https://issues.apache.org/jira/browse/BEAM-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-848: --- Summary: Shuffle input read-values to get maximum parallelism. (was: Shuffle the input read-values to get maxim

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1645

See

[jira] [Commented] (BEAM-1439) Beam Example(s) exploring public document datasets

[ https://issues.apache.org/jira/browse/BEAM-1439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944466#comment-15944466 ] Kenneth Knowles commented on BEAM-1439: --- And also, please engage with the Beam commun

[1/2] beam git commit: [BEAM-1397] Introduce IO metrics

Repository: beam Updated Branches: refs/heads/master 85b820c37 -> 48fee91f7 [BEAM-1397] Introduce IO metrics Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/65b5f001 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/65b

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

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

[GitHub] beam pull request #2162: [BEAM-1397] Introduce IO metrics

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2162 --- 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] [Commented] (BEAM-1397) Introduce IO metrics

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

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Flink #2091

See

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Spark #1405

See

[GitHub] beam pull request #2343: Finish move from RunnableOnService to ValidatesRunn...

GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/2343 Finish move from RunnableOnService to ValidatesRunner. Signed-off-by: Jason Kuster Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[GitHub] beam pull request #2344: [BEAM-1398] KafkaIO metrics.

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2344 [BEAM-1398] KafkaIO metrics. 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: `[BEA

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

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

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3063

See

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2662

See

[jira] [Resolved] (BEAM-1397) Introduce IO metrics

[ https://issues.apache.org/jira/browse/BEAM-1397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1397. - Resolution: Done Fix Version/s: First stable release > Introduce IO metrics > >

Build failed in Jenkins: beam_PerformanceTests_Dataflow #239

See Changes: [altay] Querying of both structured and unstructured metrics in dataflow. [altay] Add region option to Dataflow pipeline options. [aviemzur] [BEAM-1792] Use MetricFiltering in Spark ru

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1406

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3064

See

<    1   2