[jira] [Updated] (BEAM-1629) Init metrics/aggregators accumulators before traversing pipeline

[ https://issues.apache.org/jira/browse/BEAM-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1629: Description: Today aggregators and metrics accumulators are instantiated after pipeline is traversed, and

[jira] [Assigned] (BEAM-1336) A StateSpec that doesn't care about the key shouldn't be forced to declare it as type Object

[ https://issues.apache.org/jira/browse/BEAM-1336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1336: --- Assignee: Aviem Zur > A StateSpec that doesn't care about the key shouldn't be forced to declare it

[jira] [Created] (BEAM-1664) Support Kafka0.8.x client in KakaIO

JiJun Tang created BEAM-1664: Summary: Support Kafka0.8.x client in KakaIO Key: BEAM-1664 URL: https://issues.apache.org/jira/browse/BEAM-1664 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-1668) Add java content for Pipeline I/O authoring

Stephen Sisk created BEAM-1668: -- Summary: Add java content for Pipeline I/O authoring Key: BEAM-1668 URL: https://issues.apache.org/jira/browse/BEAM-1668 Project: Beam Issue Type: Sub-task

svn commit: r18625 - in /dev/beam/0.6.0: ./ apache-beam-0.6.0-source-release.zip apache-beam-0.6.0-source-release.zip.asc apache-beam-0.6.0-source-release.zip.md5 apache-beam-0.6.0-source-release.zip.

Author: altay Date: Thu Mar 9 01:39:05 2017 New Revision: 18625 Log: Stage 0.6.0-RC1 Added: dev/beam/0.6.0/ dev/beam/0.6.0/apache-beam-0.6.0-source-release.zip (with props) dev/beam/0.6.0/apache-beam-0.6.0-source-release.zip.asc

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),linux #2

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 2 originally caused by: GitHub pull

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),linux #2

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 2 originally caused by: GitHub pull request #2204

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),linux #1

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 1 originally caused by: GitHub pull

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),linux #2

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 2 originally caused by: GitHub pull

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),linux #1

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 1 originally caused by: GitHub pull request #2204

[jira] [Updated] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers updated BEAM-1656: --- Even then, we shouldn't call finalize before finishing using the restored instance, I think. >

[jira] [Updated] (BEAM-1664) Support Kafka0.8.x client in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JiJun Tang updated BEAM-1664: - Description: Kafka-0.8 is not supported yet, these's a big change from 0.8 to 0.9. So we need to create a

[jira] [Created] (BEAM-1666) Add language-neutral overview content for Pipeline I/O authoring docs

Stephen Sisk created BEAM-1666: -- Summary: Add language-neutral overview content for Pipeline I/O authoring docs Key: BEAM-1666 URL: https://issues.apache.org/jira/browse/BEAM-1666 Project: Beam

[GitHub] beam pull request #2206: [BEAM-775] Remove Aggregators from internal DoFn ru...

GitHub user pabloem reopened a pull request: https://github.com/apache/beam/pull/2206 [BEAM-775] Remove Aggregators from internal DoFn runner-specific code Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[jira] [Created] (BEAM-1667) Move python content for Pipeline I/O authoring over into new Pipeline I/O section

Stephen Sisk created BEAM-1667: -- Summary: Move python content for Pipeline I/O authoring over into new Pipeline I/O section Key: BEAM-1667 URL: https://issues.apache.org/jira/browse/BEAM-1667 Project:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only) #4

See -- [...truncated 234.99 KB...] 2017-03-09\T\05:16:14.945 [INFO] Downloaded:

[jira] [Created] (BEAM-1670) Pipeline I/O docs - add content on contributing I/O transforms

Stephen Sisk created BEAM-1670: -- Summary: Pipeline I/O docs - add content on contributing I/O transforms Key: BEAM-1670 URL: https://issues.apache.org/jira/browse/BEAM-1670 Project: Beam Issue

[jira] [Created] (BEAM-1669) Pipeline I/O - add content on how to test

Stephen Sisk created BEAM-1669: -- Summary: Pipeline I/O - add content on how to test Key: BEAM-1669 URL: https://issues.apache.org/jira/browse/BEAM-1669 Project: Beam Issue Type: Sub-task

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),linux #1

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 1 originally caused by: GitHub pull

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest) #3

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 3 originally caused by: GitHub pull request #2204 of commit

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only) #3

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 3 originally caused by: GitHub pull request

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only) #3

See -- Started by upstream project "beam_PostCommit_Java_Version_Test" build number 3 originally caused by: GitHub pull request

[jira] [Assigned] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1656: - Assignee: Thomas Groh (was: Kenneth Knowles) > DirectRunner should not call finalize

[jira] [Assigned] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1656: - Assignee: Kenneth Knowles (was: Thomas Groh) > DirectRunner should not call finalize

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only) #4

See Changes: [markliu] remove exclude python project in build due to Jenkins bug -- [...truncated 388.13 KB...]

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only) #5

See -- [...truncated 475.76 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.261 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),beam #8

See -- [...truncated 478.73 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.359 sec - in

[jira] [Commented] (BEAM-1666) Add language-neutral overview content for Pipeline I/O authoring docs

[ https://issues.apache.org/jira/browse/BEAM-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902291#comment-15902291 ] Stephen Sisk commented on BEAM-1666: I've published a draft at:

[jira] [Commented] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902397#comment-15902397 ] Kenneth Knowles commented on BEAM-1656: --- Let's actually change the spec so finalize is idempotent. >

[jira] [Assigned] (BEAM-1660) withCoder() error in JdbcIO JavaDoc example

[ https://issues.apache.org/jira/browse/BEAM-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1660: -- Assignee: Jean-Baptiste Onofré (was: Xu Mingmin) > withCoder() error in JdbcIO

[jira] [Created] (BEAM-1672) Extract interface MetricData

Aviem Zur created BEAM-1672: --- Summary: Extract interface MetricData Key: BEAM-1672 URL: https://issues.apache.org/jira/browse/BEAM-1672 Project: Beam Issue Type: Improvement Components:

[2/2] beam git commit: [BEAM-1184] This closes #2177

[BEAM-1184] This closes #2177 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7954896a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7954896a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7954896a Branch:

[GitHub] beam pull request #2177: [BEAM-1184] Add integration tests for Elasticsearch...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2177 --- 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 pull request #2206: [BEAM-775] Remove Aggregators from internal DoFn ru...

Github user pabloem closed the pull request at: https://github.com/apache/beam/pull/2206 --- 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-775) Remove Aggregators from the Java SDK

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

[jira] [Commented] (BEAM-775) Remove Aggregators from the Java SDK

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

[GitHub] beam pull request #2208: [BEAM-1671] Add `validate` argument to tfrecordio.R...

GitHub user N3da opened a pull request: https://github.com/apache/beam/pull/2208 [BEAM-1671] Add `validate` argument to tfrecordio.ReadFromTFRecord You can merge this pull request into a Git repository by running: $ git pull https://github.com/N3da/beam master Alternatively

[jira] [Commented] (BEAM-1671) Support bypassing `validate` flag when using tfrecordio

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

[jira] [Created] (BEAM-1671) Support bypassing `validate` flag when using tfrecordio

Neda Mirian created BEAM-1671: - Summary: Support bypassing `validate` flag when using tfrecordio Key: BEAM-1671 URL: https://issues.apache.org/jira/browse/BEAM-1671 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only) #6

See -- [...truncated 236.91 KB...] 2017-03-09\T\06:02:10.418 [INFO] Downloading:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest) #6

See -- [...truncated 236.57 KB...] 2017-03-09\T\06:02:33.292 [INFO] Downloading:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),beam #8

See -- [...truncated 477.43 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.302 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #8

See -- [...truncated 474.55 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.323 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only) #5

See -- [...truncated 239.18 KB...] 2017-03-09\T\05:53:23.281 [INFO] Downloading:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest) #5

See Changes: [markliu] Run Java postcommit test suite -- [...truncated 238.37 KB...] 2017-03-09\T\05:53:39.014 [INFO] Downloading:

[jira] [Created] (BEAM-1653) Error when using PubsubIO with the DirectRunner

Félix Mattrat created BEAM-1653: --- Summary: Error when using PubsubIO with the DirectRunner Key: BEAM-1653 URL: https://issues.apache.org/jira/browse/BEAM-1653 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-1658) DirectRunner should sometimes encode/decode checkpoints

Ben Chambers created BEAM-1658: -- Summary: DirectRunner should sometimes encode/decode checkpoints Key: BEAM-1658 URL: https://issues.apache.org/jira/browse/BEAM-1658 Project: Beam Issue Type:

[jira] [Commented] (BEAM-1649) Fix unresolved references in Python SDK

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

[1/2] beam git commit: [BEAM-1649] Fix unresolved references in Python SDK

Repository: beam Updated Branches: refs/heads/master 1d8be9743 -> 29d9bd3e6 [BEAM-1649] Fix unresolved references 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/e6ec2731 Tree:

[jira] [Updated] (BEAM-1648) Replace gsutil calls with Cloud Storage API

[ https://issues.apache.org/jira/browse/BEAM-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-1648: --- Component/s: (was: runner-dataflow) > Replace gsutil calls with Cloud Storage API >

[jira] [Assigned] (BEAM-1648) Replace gsutil calls with Cloud Storage API

[ https://issues.apache.org/jira/browse/BEAM-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1648: -- Assignee: Ahmet Altay (was: Davor Bonaci) > Replace gsutil calls with Cloud Storage API >

[jira] [Created] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

Ben Chambers created BEAM-1656: -- Summary: DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory Key: BEAM-1656 URL: https://issues.apache.org/jira/browse/BEAM-1656 Project: Beam

[jira] [Commented] (BEAM-1611) Stateful ParDo broken in Dataflow batch

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

[GitHub] beam pull request #2194: [BEAM-1649] Fix unresolved references in Python SDK

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

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

[jira] [Commented] (BEAM-1647) Dataflow RunnableOnService tests timing out reliably

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

[GitHub] beam pull request #2196: JDBC Performance Tests

GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/2196 JDBC Performance Tests 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 #2147: [BEAM-1611] Explicitly GBK before stateful ParDo in...

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

[3/3] beam git commit: This closes #2147: Explicitly GBK before stateful ParDo in Dataflow batch

This closes #2147: Explicitly GBK before stateful ParDo in Dataflow batch Upgrade Dataflow container version to beam-master-20170307 Explicitly GBK before stateful ParDo in Dataflow batch Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/3] beam git commit: Upgrade Dataflow container version to beam-master-20170307

Repository: beam Updated Branches: refs/heads/master 37c17f2bd -> 1d8be9743 Upgrade Dataflow container version to beam-master-20170307 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c7a06a61 Tree:

[jira] [Created] (BEAM-1657) DirectRunner should not call close twice in UnboundedSourceExecutorFactory

Ben Chambers created BEAM-1657: -- Summary: DirectRunner should not call close twice in UnboundedSourceExecutorFactory Key: BEAM-1657 URL: https://issues.apache.org/jira/browse/BEAM-1657 Project: Beam

[GitHub] beam pull request #2197: [BEAM-1647] Bump Dataflow ROS timeout to 120 minute...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2197 [BEAM-1647] Bump Dataflow ROS timeout to 120 minutes Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Created] (BEAM-1655) Evaluate the PubsubUnboundedSource

Ben Chambers created BEAM-1655: -- Summary: Evaluate the PubsubUnboundedSource Key: BEAM-1655 URL: https://issues.apache.org/jira/browse/BEAM-1655 Project: Beam Issue Type: Bug

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Apex #710

See

[jira] [Commented] (BEAM-1665) Update Beam site to reflect new Pipeline I/O docs structure

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

[jira] [Commented] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902452#comment-15902452 ] Kenneth Knowles commented on BEAM-1656: --- Haven't dropped into the code. But since the direct runner

[jira] [Updated] (BEAM-1657) DirectRunner should not call close twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-1657: -- Description: At the end of the processElement, in `finishRead` there is a 5% chance we decide to `close`

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #7

See -- [...truncated 476.74 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.296 sec - in

[1/2] beam git commit: [BEAM-1184] Add integration tests to ElasticsearchIO

Repository: beam Updated Branches: refs/heads/master c37e55080 -> 7954896a5 [BEAM-1184] Add integration tests to ElasticsearchIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d40f474c Tree:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),beam #7

See -- [...truncated 476.67 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.358 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),beam #7

See -- [...truncated 475.78 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.355 sec - in

[jira] [Resolved] (BEAM-1649) Fix unresolved references in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss resolved BEAM-1649. -- Resolution: Fixed Fix Version/s: First stable release Delivered with

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1867

See

[jira] [Updated] (BEAM-1629) Metrics/aggregators accumulators should be instantiated before traversing pipeline

[ https://issues.apache.org/jira/browse/BEAM-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1629: Summary: Metrics/aggregators accumulators should be instantiated before traversing pipeline (was: Init

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2853

See Changes: [jbonofre] [BEAM-1184] Add integration tests to ElasticsearchIO -- [...truncated 412.24 KB...] 2017-03-09T06:58:30.268 [INFO] Downloading:

[jira] [Created] (BEAM-1659) Improve UnboundedSourceShard structure

Thomas Groh created BEAM-1659: - Summary: Improve UnboundedSourceShard structure Key: BEAM-1659 URL: https://issues.apache.org/jira/browse/BEAM-1659 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-1646) Duplicated google-cloud-bigquery in Python setup.py

[ https://issues.apache.org/jira/browse/BEAM-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu resolved BEAM-1646. Resolution: Fixed Fix Version/s: 0.6.0 > Duplicated google-cloud-bigquery in Python setup.py >

[jira] [Commented] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901835#comment-15901835 ] Thomas Groh commented on BEAM-1656: --- Removing the call to {{finalizeCheckpoint}} in {{getReader}} should

[jira] [Closed] (BEAM-1646) Duplicated google-cloud-bigquery in Python setup.py

[ https://issues.apache.org/jira/browse/BEAM-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu closed BEAM-1646. -- > Duplicated google-cloud-bigquery in Python setup.py > --- > >

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #1863

See

[jira] [Commented] (BEAM-1544) Move Java cross-JDK tests from Travis to Jenkins

[ https://issues.apache.org/jira/browse/BEAM-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901919#comment-15901919 ] Mark Liu commented on BEAM-1544: Thank you [~jbonofre][~davor]. Jenkins DSL supports matrix job which is

[jira] [Comment Edited] (BEAM-1544) Move Java cross-JDK tests from Travis to Jenkins

[ https://issues.apache.org/jira/browse/BEAM-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901919#comment-15901919 ] Mark Liu edited comment on BEAM-1544 at 3/8/17 8:20 PM: Thank you [~jbonofre] and

[jira] [Updated] (BEAM-1660) withCoder() error in JdbcIO JavaDoc example

[ https://issues.apache.org/jira/browse/BEAM-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1660: - Summary: withCoder() error in JdbcIO JavaDoc example (was: does JdbcIO need withCoder() mandately) >

[jira] [Resolved] (BEAM-1611) Stateful ParDo broken in Dataflow batch

[ https://issues.apache.org/jira/browse/BEAM-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1611. --- Resolution: Fixed > Stateful ParDo broken in Dataflow batch >

[GitHub] beam pull request #2200: Cherry pick master changes to release-0.6.0 branch

Github user aaltay closed the pull request at: https://github.com/apache/beam/pull/2200 --- 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 pull request #2199: Update archetypes

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2199 Update archetypes R: @davorbonaci You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam relfix Alternatively you can review and apply

[GitHub] beam pull request #2200: Cherry pick master changes to release-0.6.0 branch

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2200 Cherry pick master changes to release-0.6.0 branch You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam relfixb Alternatively you can

[GitHub] beam pull request #2201: [BEAM-1328] Fixup typo in WindowingStrategies

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2201 [BEAM-1328] Fixup typo in WindowingStrategies Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Created] (BEAM-1660) does JdbcIO need withCoder() mandately

Xu Mingmin created BEAM-1660: Summary: does JdbcIO need withCoder() mandately Key: BEAM-1660 URL: https://issues.apache.org/jira/browse/BEAM-1660 Project: Beam Issue Type: Improvement

[GitHub] beam pull request #2198: [BEAM-1611] Explicitly GBK before stateful ParDo in...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2198 [BEAM-1611] Explicitly GBK before stateful ParDo in Dataflow batch Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Commented] (BEAM-1611) Stateful ParDo broken in Dataflow batch

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

[GitHub] beam pull request #2193: Add Elasticsearch and Cassandra tests in HadoopInpu...

GitHub user diptikul opened a pull request: https://github.com/apache/beam/pull/2193 Add Elasticsearch and Cassandra tests in HadoopInputFormatIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Created] (BEAM-1651) Add IntelliJ code style xml to the project repository

Aviem Zur created BEAM-1651: --- Summary: Add IntelliJ code style xml to the project repository Key: BEAM-1651 URL: https://issues.apache.org/jira/browse/BEAM-1651 Project: Beam Issue Type: Sub-task

[jira] [Resolved] (BEAM-1635) TypeError in AfterWatermark class's __repr__ method

[ https://issues.apache.org/jira/browse/BEAM-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss resolved BEAM-1635. -- Resolution: Fixed Fix Version/s: First stable release Resolved with commit

[jira] [Updated] (BEAM-1633) Move .tox/ directory under target/ in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss updated BEAM-1633: - Fix Version/s: First stable release > Move .tox/ directory under target/ in Python SDK >

[jira] [Updated] (BEAM-1635) TypeError in AfterWatermark class's __repr__ method

[ https://issues.apache.org/jira/browse/BEAM-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss updated BEAM-1635: - Affects Version/s: 0.6.0 > TypeError in AfterWatermark class's __repr__ method >

[jira] [Created] (BEAM-1650) Add IntelliJ code style xml to the project repo and website

Aviem Zur created BEAM-1650: --- Summary: Add IntelliJ code style xml to the project repo and website Key: BEAM-1650 URL: https://issues.apache.org/jira/browse/BEAM-1650 Project: Beam Issue Type:

[GitHub] beam pull request #2195: [BEAM-1651] Add IntelliJ code style xml to the proj...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2195 [BEAM-1651] Add IntelliJ code style xml to the project repository Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Resolved] (BEAM-1633) Move .tox/ directory under target/ in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss resolved BEAM-1633. -- Resolution: Fixed Resolved with commit 6cc80daf745cc77d779ee5a8494e97552fe02c0a. > Move .tox/ directory

[GitHub] beam pull request #2194: [BEAM-1649] Fix unresolved references in Python SDK

GitHub user tibkiss opened a pull request: https://github.com/apache/beam/pull/2194 [BEAM-1649] Fix unresolved references in Python SDK Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

  1   2   >