[jira] [Commented] (BEAM-392) Update flink runner to use flink version 1.0.3

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

[GitHub] incubator-beam pull request #561: [BEAM-392] Update flink runner to use flin...

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

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

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

[1/3] incubator-beam git commit: [BEAM-392] Rename missing references to FlinkPipelineRunner

Repository: incubator-beam Updated Branches: refs/heads/master df1d5f61e -> b4c123cd4 [BEAM-392] Rename missing references to FlinkPipelineRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d8c01c8b T

[2/3] incubator-beam git commit: [BEAM-392] Update flink dependency to the most recent stable version

[BEAM-392] Update flink dependency to the most recent stable version Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2d3d0f4c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2d3d0f4c Diff: ht

[jira] [Closed] (BEAM-403) Support staging SDK packages from PyPI for remote execution

[ https://issues.apache.org/jira/browse/BEAM-403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-403. Resolution: Fixed Assignee: Silviu Calinoiu (was: Davor Bonaci) Fix Version/s: 0.2.0-i

[jira] [Updated] (BEAM-414) IntraBundleParallelization needs to be removed

[ https://issues.apache.org/jira/browse/BEAM-414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-414: - Labels: newbie starter (was: ) > IntraBundleParallelization needs to be removed > -

[jira] [Closed] (BEAM-411) Avoid calling BigQuery directly during validation.

[ https://issues.apache.org/jira/browse/BEAM-411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-411. Resolution: Fixed Fix Version/s: Not applicable > Avoid calling BigQuery directly during valida

[jira] [Closed] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

[ https://issues.apache.org/jira/browse/BEAM-395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-395. Resolution: Fixed Fix Version/s: Not applicable > KafkaIO tests should be marked 'NeedsRunner'

[jira] [Commented] (BEAM-411) Avoid calling BigQuery directly during validation.

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

[GitHub] incubator-beam pull request #555: [BEAM-411] Replacing BigQuery direct calls...

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

[1/2] incubator-beam git commit: Replacing BigQuery direct calls with BigQueryServices abstraction

Repository: incubator-beam Updated Branches: refs/heads/master e7418e2e8 -> df1d5f61e Replacing BigQuery direct calls with BigQueryServices abstraction Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/336b

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

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

[GitHub] incubator-beam pull request #571: Move Jenkins Python post commit script to ...

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

[jira] [Commented] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

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

[GitHub] incubator-beam pull request #568: [BEAM-395] KafkaIO tests should be marked ...

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

[GitHub] incubator-beam pull request #524: Add KafkaIO tests to Flink runner Runnable...

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

[2/2] incubator-beam git commit: Closes #568 and closes #524

Closes #568 and closes #524 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e7418e2e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e7418e2e Diff: http://git-wip-us.apache.org/repos/asf/incu

[1/2] incubator-beam git commit: KafkaIO tests : change category annotation from RunnableOnService to NeedsRunner

Repository: incubator-beam Updated Branches: refs/heads/master 75089c4d2 -> e7418e2e8 KafkaIO tests : change category annotation from RunnableOnService to NeedsRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-b

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

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

[1/2] incubator-beam git commit: Move Jenkins Python post commit script to the repository.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk fbe44ee83 -> df7ecd55f Move Jenkins Python post commit script to the repository. This is a copy of the script Jenkins post commit Python verify job is running (with some cosmetic changes, license and instructions.) Moving it to

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

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

[GitHub] incubator-beam pull request #563: Make PTransform.apply Abstract

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

[1/2] incubator-beam git commit: Make PTransform.apply Abstract

Repository: incubator-beam Updated Branches: refs/heads/master 31d4bde7a -> 75089c4d2 Make PTransform.apply Abstract Primitive PTransforms should create the appropriate primitive output type. Composite PTransforms should override apply. Project: http://git-wip-us.apache.org/repos/asf/incubat

[GitHub] incubator-beam pull request #564: Fix missing Override Annotations in the Di...

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

[jira] [Commented] (BEAM-191) Remove WindowedValue.valueInEmptyWindows

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

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

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

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

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

[1/2] incubator-beam git commit: Fix missing Override Annotations in the DirectRunner

Repository: incubator-beam Updated Branches: refs/heads/master 1a060f684 -> 31d4bde7a Fix missing Override Annotations in the DirectRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e37bffc6 Tree: ht

[2/3] incubator-beam git commit: Deprecate WindowedValue.valueInEmptyWindows

Deprecate WindowedValue.valueInEmptyWindows Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/81ad2a7b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/81ad2a7b Diff: http://git-wip-us.apache.or

[1/3] incubator-beam git commit: Make WindowedValue like an interface, allow external implementations

Repository: incubator-beam Updated Branches: refs/heads/master 61b9d723d -> 1a060f684 Make WindowedValue like an interface, allow external implementations Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d

[GitHub] incubator-beam pull request #523: [BEAM-191] Make WindowedValue extendable a...

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

[jira] [Created] (BEAM-415) Use AutoAnnotation for SDK Annotations

Thomas Groh created BEAM-415: Summary: Use AutoAnnotation for SDK Annotations Key: BEAM-415 URL: https://issues.apache.org/jira/browse/BEAM-415 Project: Beam Issue Type: Bug Components:

[GitHub] incubator-beam pull request #571: Move Jenkins Python post commit script to ...

GitHub user aaltay opened a pull request: https://github.com/apache/incubator-beam/pull/571 Move Jenkins Python post commit script to the repository. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR t

[2/4] incubator-beam git commit: Define GOOGLE_PACKAGE_NAME and use it everywhere

Define GOOGLE_PACKAGE_NAME and use it everywhere Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/33720ec4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/33720ec4 Diff: http://git-wip-us.apac

[1/4] incubator-beam git commit: Closes #569

Repository: incubator-beam Updated Branches: refs/heads/python-sdk bff980178 -> fbe44ee83 Closes #569 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fbe44ee8 Tree: http://git-wip-us.apache.org/repos/asf/

[3/4] incubator-beam git commit: Replace call() with check_call()

Replace call() with check_call() Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5fe6d7bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5fe6d7bf Diff: http://git-wip-us.apache.org/repos/asf

[4/4] incubator-beam git commit: Get current SDK package from PyPI instead of GitHub

Get current SDK package from PyPI instead of GitHub Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0bda677d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0bda677d Diff: http://git-wip-us.a

[jira] [Created] (BEAM-414) IntraBundleParallelization needs to be removed

Luke Cwik created BEAM-414: -- Summary: IntraBundleParallelization needs to be removed Key: BEAM-414 URL: https://issues.apache.org/jira/browse/BEAM-414 Project: Beam Issue Type: Bug Compone

[jira] [Updated] (BEAM-413) Mean$CountSum tests for floating point equality

[ https://issues.apache.org/jira/browse/BEAM-413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-413: -- Description: [FindBugs FE_FLOATING_POINT_EQUALITY|https://github.com/apache/incubator-beam/blob/58a029a06

[jira] [Created] (BEAM-413) Mean.CountSum tests for floating point inequality

Scott Wegner created BEAM-413: - Summary: Mean.CountSum tests for floating point inequality Key: BEAM-413 URL: https://issues.apache.org/jira/browse/BEAM-413 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-412) DisplayData is marked Serializable but contains non-serializable field

[ https://issues.apache.org/jira/browse/BEAM-412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-412: -- Description: [FindBugs SE_BAD_FIELD|https://github.com/apache/incubator-beam/blob/58a029a06aea1030279e5da

[jira] [Resolved] (BEAM-390) Update spark runner to use spark version 1.6.2

[ https://issues.apache.org/jira/browse/BEAM-390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-390. --- Resolution: Fixed > Update spark runner to use spark version 1.6.2 > ---

[jira] [Created] (BEAM-412) DisplayData is marked Serializable but contains non-serializable field

Scott Wegner created BEAM-412: - Summary: DisplayData is marked Serializable but contains non-serializable field Key: BEAM-412 URL: https://issues.apache.org/jira/browse/BEAM-412 Project: Beam Is

[jira] [Commented] (BEAM-390) Update spark runner to use spark version 1.6.2

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

[GitHub] incubator-beam pull request #560: [BEAM-390] Update spark runner to use spar...

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

[1/2] incubator-beam git commit: [BEAM-390] Update spark dependency to the most recent stable version

Repository: incubator-beam Updated Branches: refs/heads/master 38866cd55 -> 61b9d723d [BEAM-390] Update spark dependency to the most recent stable version Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9

[2/2] incubator-beam git commit: [BEAM-390] This closes #560

[BEAM-390] This closes #560 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/61b9d723 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/61b9d723 Diff: http://git-wip-us.apache.org/repos/asf/incu

[jira] [Updated] (BEAM-410) ApproximateQuantiles$QuantileBuffer defines compareTo but not equals

[ https://issues.apache.org/jira/browse/BEAM-410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-410: -- Description: [FindBugs EQ_COMPARETO_USE_OBJECT_EQUALS|https://github.com/apache/incubator-beam/blob/58a02

[jira] [Created] (BEAM-411) Avoid calling BigQuery directly during validation.

Pei He created BEAM-411: --- Summary: Avoid calling BigQuery directly during validation. Key: BEAM-411 URL: https://issues.apache.org/jira/browse/BEAM-411 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-410) ApproximateQuantiles$QuantileBuffer defines compareTo but not equals

Scott Wegner created BEAM-410: - Summary: ApproximateQuantiles$QuantileBuffer defines compareTo but not equals Key: BEAM-410 URL: https://issues.apache.org/jira/browse/BEAM-410 Project: Beam Issu

[jira] [Updated] (BEAM-409) Incorrect use of Math.ceil in ApproximateQuantiles

[ https://issues.apache.org/jira/browse/BEAM-409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-409: -- Description: [FindBugs ICAST_INT_CAST_TO_DOUBLE_PASSED_TO_CEIL|https://github.com/apache/incubator-beam/b

[jira] [Updated] (BEAM-409) Inconsistent synchronization in WindowSupplier.windows

[ https://issues.apache.org/jira/browse/BEAM-409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-409: -- Description: [FindBugs IS2_INCONSISTENT_SYNC|https://github.com/apache/incubator-beam/blob/58a029a06aea10

[jira] [Created] (BEAM-409) Inconsistent synchronization in WindowSupplier.windows

Scott Wegner created BEAM-409: - Summary: Inconsistent synchronization in WindowSupplier.windows Key: BEAM-409 URL: https://issues.apache.org/jira/browse/BEAM-409 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-390) Update spark runner to use spark version 1.6.2

[ https://issues.apache.org/jira/browse/BEAM-390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-390: -- Fix Version/s: 0.2.0-incubating > Update spark runner to use spark version 1.6.2 > ---

[jira] [Updated] (BEAM-408) ProxyInvocationHandler uses inefficient Math.random() for random int

[ https://issues.apache.org/jira/browse/BEAM-408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-408: -- Description: [FindBugs DM_NEXTINT_VIA_NEXTDOUBLE|https://github.com/apache/incubator-beam/blob/58a029a06a

[jira] [Created] (BEAM-408) ProxyInvocationHandler uses inefficient Math.random() for random int

Scott Wegner created BEAM-408: - Summary: ProxyInvocationHandler uses inefficient Math.random() for random int Key: BEAM-408 URL: https://issues.apache.org/jira/browse/BEAM-408 Project: Beam Issu

[jira] [Assigned] (BEAM-357) Build doesn't pass on windows

[ https://issues.apache.org/jira/browse/BEAM-357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-357: - Assignee: Jean-Baptiste Onofré (was: Romain Manni-Bucau) > Build doesn't pass on w

[jira] [Assigned] (BEAM-390) Update spark runner to use spark version 1.6.2

[ https://issues.apache.org/jira/browse/BEAM-390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-390: - Assignee: Jean-Baptiste Onofré (was: Amit Sela) > Update spark runner to use spark

[jira] [Updated] (BEAM-407) Inconsistent synchronization in OffsetRangeTracker.copy

[ https://issues.apache.org/jira/browse/BEAM-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-407: -- Description: [FindBugs IS2_INCONSISTENT_SYNC|https://github.com/apache/incubator-beam/blob/58a029a06aea10

[jira] [Created] (BEAM-407) Inconsistent synchronization in OffsetRangeTracker.copy

Scott Wegner created BEAM-407: - Summary: Inconsistent synchronization in OffsetRangeTracker.copy Key: BEAM-407 URL: https://issues.apache.org/jira/browse/BEAM-407 Project: Beam Issue Type: Bug

[jira] [Closed] (BEAM-406) Unused local variable in Write$Bound

[ https://issues.apache.org/jira/browse/BEAM-406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner closed BEAM-406. - Resolution: Incomplete Fix Version/s: Not applicable > Unused local variable in Write$Bound > ---

[GitHub] incubator-beam pull request #570: Enables unused-import and used-before-assi...

GitHub user aaltay opened a pull request: https://github.com/apache/incubator-beam/pull/570 Enables unused-import and used-before-assignment rules Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR titl

[jira] [Created] (BEAM-406) Unused local variable in Write$Bound

Scott Wegner created BEAM-406: - Summary: Unused local variable in Write$Bound Key: BEAM-406 URL: https://issues.apache.org/jira/browse/BEAM-406 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-405) BigQueryIO$StreamingWriteFn uses inefficient keySet iterator

[ https://issues.apache.org/jira/browse/BEAM-405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-405: -- Description: [FindBugs WMI_WRONG_MAP_ITERATOR|https://github.com/apache/incubator-beam/blob/58a029a06aea1

[jira] [Created] (BEAM-405) BigQueryIO$StreamingWriteFn uses inefficient keySet iterator

Scott Wegner created BEAM-405: - Summary: BigQueryIO$StreamingWriteFn uses inefficient keySet iterator Key: BEAM-405 URL: https://issues.apache.org/jira/browse/BEAM-405 Project: Beam Issue Type:

[jira] [Updated] (BEAM-402) StructuralByteArray exposes mutable internal byte array

[ https://issues.apache.org/jira/browse/BEAM-402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-402: -- Description: [FindBugs EI_EXPOSE_REP|https://github.com/apache/incubator-beam/blob/58a029a06aea1030279e5d

[jira] [Created] (BEAM-404) PubsubIO should have a mode that supports maintaining message attributes.

Daniel Halperin created BEAM-404: Summary: PubsubIO should have a mode that supports maintaining message attributes. Key: BEAM-404 URL: https://issues.apache.org/jira/browse/BEAM-404 Project: Beam

[jira] [Updated] (BEAM-403) Support staging SDK packages from PyPI for remote execution

[ https://issues.apache.org/jira/browse/BEAM-403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-403: - Component/s: sdk-py > Support staging SDK packages from PyPI for remote execution >

[jira] [Commented] (BEAM-403) Support staging SDK packages from PyPI for remote execution

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

[GitHub] incubator-beam pull request #569: [BEAM-403] Get current SDK package from Py...

GitHub user silviulica opened a pull request: https://github.com/apache/incubator-beam/pull/569 [BEAM-403] Get current SDK package from PyPI instead of GitHub With this change we support (in the DataflowPipelineRunner) getting the SDK package from PyPI where we will release Google p

[jira] [Created] (BEAM-403) Support staging SDK packages from PyPI for remote execution

Silviu Calinoiu created BEAM-403: Summary: Support staging SDK packages from PyPI for remote execution Key: BEAM-403 URL: https://issues.apache.org/jira/browse/BEAM-403 Project: Beam Issue T

[jira] [Closed] (BEAM-355) Update to Bigtable version 0.3.0

[ https://issues.apache.org/jira/browse/BEAM-355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-355. Resolution: Fixed Fix Version/s: 0.2.0-incubating > Update to Bigtable version 0.3.0 >

[1/2] incubator-beam git commit: Update to bigtable-client-core-0.3.0 and use bulk writes

Repository: incubator-beam Updated Branches: refs/heads/master 4a0e426a8 -> 38866cd55 Update to bigtable-client-core-0.3.0 and use bulk writes Generally more stable, plus bulk writes bring 5x write throughput in batch jobs by more efficiently using the network. Project: http://git-wip-us.apa

[jira] [Commented] (BEAM-355) Update to Bigtable version 0.3.0

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

[GitHub] incubator-beam pull request #481: [BEAM-355] Update to Bigtable version 0.3....

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

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

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

[jira] [Updated] (BEAM-401) StandardCoder uses inefficient string concatenation

[ https://issues.apache.org/jira/browse/BEAM-401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-401: -- Description: [FindBugs SBSC_USE_STRINGBUFFER_CONCATENATION|https://github.com/apache/incubator-beam/blob/

[jira] [Created] (BEAM-402) StructuralByteArray exposes mutable internal byte array

Scott Wegner created BEAM-402: - Summary: StructuralByteArray exposes mutable internal byte array Key: BEAM-402 URL: https://issues.apache.org/jira/browse/BEAM-402 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-401) StandardCoder uses inefficient string concatenation

Scott Wegner created BEAM-401: - Summary: StandardCoder uses inefficient string concatenation Key: BEAM-401 URL: https://issues.apache.org/jira/browse/BEAM-401 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-400) Direct/InProcess runner should use Pubsub publish time timestamp if timestampLabel is not set

Daniel Mills created BEAM-400: - Summary: Direct/InProcess runner should use Pubsub publish time timestamp if timestampLabel is not set Key: BEAM-400 URL: https://issues.apache.org/jira/browse/BEAM-400 Pro

[jira] [Updated] (BEAM-399) SerializableCoder.equals does not handle null

[ https://issues.apache.org/jira/browse/BEAM-399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-399: -- Description: [FindBugs NP_EQUALS_SHOULD_HANDLE_NULL_ARGUMENT|https://github.com/apache/incubator-beam/blo

[jira] [Created] (BEAM-399) SerializableCoder.equals does not handle null

Scott Wegner created BEAM-399: - Summary: SerializableCoder.equals does not handle null Key: BEAM-399 URL: https://issues.apache.org/jira/browse/BEAM-399 Project: Beam Issue Type: Bug Co

[jira] [Commented] (BEAM-398) JAXBCoder uses incorrect Double-Checked Locking

[ https://issues.apache.org/jira/browse/BEAM-398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15357621#comment-15357621 ] Scott Wegner commented on BEAM-398: --- When this is fixed, it should also fix the [IS2_INCON

[jira] [Updated] (BEAM-398) JAXBCoder uses incorrect Double-Checked Locking

[ https://issues.apache.org/jira/browse/BEAM-398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-398: -- Description: [FindBugs DC_DOUBLECHECK|https://github.com/apache/incubator-beam/blob/58a029a06aea1030279e5

[jira] [Created] (BEAM-398) JAXBCoder uses Double-Checked Locking

Scott Wegner created BEAM-398: - Summary: JAXBCoder uses Double-Checked Locking Key: BEAM-398 URL: https://issues.apache.org/jira/browse/BEAM-398 Project: Beam Issue Type: Bug Components

[jira] [Updated] (BEAM-397) Format string uses \n rather than %n

[ https://issues.apache.org/jira/browse/BEAM-397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-397: -- Description: [FindBugs VA_FORMAT_STRING_USES_NEWLINE|https://github.com/apache/incubator-beam/blob/58a029

[jira] [Created] (BEAM-397) Format string uses \n rather than %n

Scott Wegner created BEAM-397: - Summary: Format string uses \n rather than %n Key: BEAM-397 URL: https://issues.apache.org/jira/browse/BEAM-397 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-396) Coder.NonDeterministicException doesn't inherit from Exception

[ https://issues.apache.org/jira/browse/BEAM-396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-396: -- Description: [FindBugs NM_CLASS_NOT_EXCEPTION|https://github.com/apache/incubator-beam/blob/58a029a06aea1

[jira] [Created] (BEAM-396) Coder.NonDeterministicException doesn't inherit from Exception

Scott Wegner created BEAM-396: - Summary: Coder.NonDeterministicException doesn't inherit from Exception Key: BEAM-396 URL: https://issues.apache.org/jira/browse/BEAM-396 Project: Beam Issue Type

[GitHub] incubator-beam pull request #568: [BEAM-395] KafkaIO tests should be marked ...

GitHub user rangadi opened a pull request: https://github.com/apache/incubator-beam/pull/568 [BEAM-395] KafkaIO tests should be marked 'NeedsRunner' KafkaIO Tests are currently marked as 'RunnableOnService', which implies the tests can run on any beam runner. This is not correc

[jira] [Commented] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

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

[jira] [Created] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

Raghu Angadi created BEAM-395: - Summary: KafkaIO tests should be marked 'NeedsRunner' Key: BEAM-395 URL: https://issues.apache.org/jira/browse/BEAM-395 Project: Beam Issue Type: Bug Com

Jenkins build is back to stable : beam_PostCommit_MavenVerify #772

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #772

See

[GitHub] incubator-beam pull request #566: Fix expression-not-assigned and unused-var...

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

[1/2] incubator-beam git commit: Fix expression-not-assigned and unused-variable lint warnings.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 5434e599b -> bff980178 Fix expression-not-assigned and unused-variable lint warnings. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7be

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

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

Jenkins build became unstable: beam_PostCommit_MavenVerify #771

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #771

See

  1   2   >