[jira] [Resolved] (BEAM-4061) Chaining SpannerIO#write() transforms

2018-07-11 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov resolved BEAM-4061. Resolution: Fixed > Chaining SpannerIO#write() transfo

[jira] [Updated] (BEAM-4061) Chaining SpannerIO#write() transforms

2018-07-11 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov updated BEAM-4061: --- Fix Version/s: (was: 2.6.0) 2.5.0 > Chaining SpannerIO#wr

[jira] [Commented] (BEAM-4061) Chaining SpannerIO#write() transforms

2018-07-11 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540667#comment-16540667 ] Mairbek Khadikov commented on BEAM-4061: It was fixed with Beam 2.5.0 > Chaining SpannerIO#wr

[jira] [Commented] (BEAM-3973) Allow to disable batch API in SpannerIO

2018-05-17 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16479727#comment-16479727 ] Mairbek Khadikov commented on BEAM-3973: Fixed with [https://github.com/apache/beam/pull/4946

[jira] [Resolved] (BEAM-3973) Allow to disable batch API in SpannerIO

2018-05-17 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov resolved BEAM-3973. Resolution: Fixed > Allow to disable batch API in Spanne

[jira] [Resolved] (BEAM-4264) Java PostCommit Spanner tests are failing due to "Instance not found"

2018-05-17 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov resolved BEAM-4264. Resolution: Fixed > Java PostCommit Spanner tests are failing due to "Instance n

[jira] [Reopened] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure

2018-04-17 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov reopened BEAM-2837: > Writing To Spanner From Google Cloud DataFlow - Fail

[jira] [Commented] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure

2018-04-17 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441299#comment-16441299 ] Mairbek Khadikov commented on BEAM-2837: It seems like it is still possible to run into the version

[jira] [Created] (BEAM-4061) Chaining SpannerIO#write() transforms

2018-04-12 Thread Mairbek Khadikov (JIRA)
Mairbek Khadikov created BEAM-4061: -- Summary: Chaining SpannerIO#write() transforms Key: BEAM-4061 URL: https://issues.apache.org/jira/browse/BEAM-4061 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-3973) Allow to disable batch API in SpannerIO

2018-03-29 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov updated BEAM-3973: --- Description: In 2.4.0, SpannerIO#read has been migrated to use batch API. The batch API

[jira] [Created] (BEAM-3973) Allow to disable batch API in SpannerIO

2018-03-29 Thread Mairbek Khadikov (JIRA)
Mairbek Khadikov created BEAM-3973: -- Summary: Allow to disable batch API in SpannerIO Key: BEAM-3973 URL: https://issues.apache.org/jira/browse/BEAM-3973 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-3932) Spanner MutationSizeEstimator doesn't handle null array values

2018-03-26 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mairbek Khadikov updated BEAM-3932: --- Description: More details here https://stackoverflow.com/questions/49484770/dataflow-spanner

[jira] [Created] (BEAM-3932) Spanner MutationSizeEstimator doesn't handle null array values

2018-03-26 Thread Mairbek Khadikov (JIRA)
Mairbek Khadikov created BEAM-3932: -- Summary: Spanner MutationSizeEstimator doesn't handle null array values Key: BEAM-3932 URL: https://issues.apache.org/jira/browse/BEAM-3932 Project: Beam

[GitHub] beam pull request #4139: Update cloud spanner library to 0.29.0

2017-11-15 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/4139 Update cloud spanner library to 0.29.0 R: @jkff You can merge this pull request into a Git repository by running: $ git pull https://github.com/mairbek/beam depsupdate Alternatively you can

[GitHub] beam pull request #4014: [BEAM-1542] SpannerIO: mutation encoding and size e...

2017-10-18 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/4014 [BEAM-1542] SpannerIO: mutation encoding and size estimation improvements #4013 must be reviewed merged first You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] beam pull request #4013: [BEAM-1542] A transform for reading the Spanner sch...

2017-10-18 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/4013 [BEAM-1542] A transform for reading the Spanner schema A part of https://github.com/apache/beam/pull/3729. Ideally, spanner schema should be an introspection part of the Cloud Spanner

[GitHub] beam pull request #3925: [BEAM-2837] OrderedCode library

2017-09-29 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3925 [BEAM-2837] OrderedCode library provides encoding a sequence of typed entities into a byte array that can be lexicographically sorted. R: @chamikaramj You can merge this pull request

[GitHub] beam pull request #3907: [BEAM-2837] Allows to set a Cloud Spanner host.

2017-09-26 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3907 [BEAM-2837] Allows to set a Cloud Spanner host. Allows to set a Cloud Spanner host. https://batch-spanner.googleapis.com/ is set as a default host name. You can merge this pull request

[GitHub] beam pull request #3862: [BEAM-2837] Exclude grpc-google-common-protos:0.1.0...

2017-09-18 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3862 [BEAM-2837] Exclude grpc-google-common-protos:0.1.0 dependency Exclude grpc-google-common-protos:0.1.0 dependency that comes from grpc-google-pubsub-v1. R: @jkff You can merge

[jira] [Commented] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure

2017-09-18 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170773#comment-16170773 ] Mairbek Khadikov commented on BEAM-2837: As a workaround, you could exclude _grpc-google-common

[jira] [Commented] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure

2017-09-06 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155916#comment-16155916 ] Mairbek Khadikov commented on BEAM-2837: This is likely grpc-google-common-protos dependency coming

[GitHub] beam pull request #3729: [BEAM-1542] Added a preprocessing step to the Cloud...

2017-08-17 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3729 [BEAM-1542] Added a preprocessing step to the Cloud Spanner sink. The general intuition we follow here: if mutations are presorted by the primary key before batching, it is more likely

[GitHub] beam pull request #3696: [BEAM-1542] Make AbstractSpannerFn public

2017-08-07 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3696 [BEAM-1542] Make AbstractSpannerFn public Make AbstractSpannerFn public to support custom user defined functions that use Cloud Spanner. R: @jkff You can merge this pull request

[GitHub] beam pull request #3591: [BEAM-1542] Introduced `SpannerIO.readFn`

2017-07-18 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3591 [BEAM-1542] Introduced `SpannerIO.readFn` `SpannerIO.readFn` allows to pipe reading from Cloud Spanner to other computations. The motivating use case is exporting data from a Spanner database, when

[GitHub] beam pull request #3574: [BEAM-1542] Specifies a User Agent in Spanner Clien...

2017-07-17 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3574 [BEAM-1542] Specifies a User Agent in Spanner Client R: @jkff You can merge this pull request into a Git repository by running: $ git pull https://github.com/mairbek/beam useragent

[jira] [Commented] (BEAM-2538) Spanner IO ITs failing

2017-07-13 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086459#comment-16086459 ] Mairbek Khadikov commented on BEAM-2538: Stephen, can we close this? > Spanner IO ITs fail

[GitHub] beam pull request #3472: Get rid of Apache Commons dependency

2017-06-29 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3472 Get rid of Apache Commons dependency 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

[jira] [Commented] (BEAM-2538) Spanner IO ITs failing

2017-06-28 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16067464#comment-16067464 ] Mairbek Khadikov commented on BEAM-2538: Should be fixed with https://github.com/apache/beam/pull

[GitHub] beam pull request #3395: [BEAM-1542] Cloud Spanner Source

2017-06-19 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3395 [BEAM-1542] Cloud Spanner Source Defines Cloud Spanner Source API, and a naive implementation, similar to JdbcIO. Also includes https://github.com/apache/beam/pull/3358 You can merge

[GitHub] beam pull request #3358: [BEAM-1542] Support ValueProviders in SpannerIO

2017-06-14 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3358 [BEAM-1542] Support ValueProviders in SpannerIO You can merge this pull request into a Git repository by running: $ git pull https://github.com/mairbek/beam providers Alternatively you can

[GitHub] beam pull request #3319: [BEAM-1542] SpannerIO: Introduced a MutationGroup.

2017-06-07 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3319 [BEAM-1542] SpannerIO: Introduced a MutationGroup. Allows to group together mutations in a logical bundle that is submitted in the same transaction. You can merge this pull request into a Git

[GitHub] beam pull request #3298: [BEAM-2394] Support concurrent execution of Spanner...

2017-06-05 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3298 [BEAM-2394] Support concurrent execution of SpannerWriteIT test Generate a random table name. Assume Spanner database exists. Run Java JDK Version Test You can merge this pull request

[jira] [Commented] (BEAM-2394) Postcommit_Java_JDK_Version_Test is broken since SpannerWriteIT failed

2017-06-05 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16037411#comment-16037411 ] Mairbek Khadikov commented on BEAM-2394: Got it. We need to use a random database name. Or even

[jira] [Commented] (BEAM-2394) Postcommit_Java_JDK_Version_Test is broken since SpannerWriteIT failed

2017-06-05 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16037391#comment-16037391 ] Mairbek Khadikov commented on BEAM-2394: Interesting, are these tests running concurrently

[GitHub] beam pull request #3259: [BEAM-2379] Avoid reading projectId from environmen...

2017-05-30 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3259 [BEAM-2379] Avoid reading projectId from environment variable in tests. SpannerOptions.Builder requires projectId to be not-null. Was green because I had GOOGLE_APPLICATION_CREDENTIALS

[jira] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029909#comment-16029909 ] Mairbek Khadikov commented on BEAM-2379: Will send a fix PR > SpannerIO tests are fail

[GitHub] beam pull request #3221: [BEAM-1542] SpannerIO sink updates

2017-05-26 Thread mairbek
Github user mairbek closed the pull request at: https://github.com/apache/beam/pull/3221 --- 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-1542) Need Source/Sink for Spanner

2017-05-24 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023881#comment-16023881 ] Mairbek Khadikov commented on BEAM-1542: Created https://github.com/apache/beam-site/pull/252

[GitHub] beam-site pull request #252: Added Cloud Spanner Connector

2017-05-24 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam-site/pull/252 Added Cloud Spanner Connector You can merge this pull request into a Git repository by running: $ git pull https://github.com/mairbek/beam-site patch-1 Alternatively you can review

[GitHub] beam pull request #3221: [BEAM-1542] SpannerIO sink updates

2017-05-24 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3221 [BEAM-1542] SpannerIO sink updates Unit and integration test. Logical mutation size estimation. Be sure to do all of the following to help us incorporate your contribution quickly

[GitHub] beam pull request #2555: BEAM-1542: Bump grpc-google-common-protos.version t...

2017-04-28 Thread mairbek
Github user mairbek closed the pull request at: https://github.com/apache/beam/pull/2555 --- 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] beam pull request #2555: BEAM-1542: Bump grpc-google-common-protos.version t...

2017-04-17 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/2555 BEAM-1542: Bump grpc-google-common-protos.version to support Cloud Spanner client. Be sure to do all of the following to help us incorporate your contribution quickly and easily

[jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner

2017-04-05 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957937#comment-15957937 ] Mairbek Khadikov commented on BEAM-1542: Hi Guy, I work on Cloud Spanner at Google. Let us know

[GitHub] beam-site pull request #171: Typo fix in "Reading Data Into Your Pipeline" e...

2017-03-06 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam-site/pull/171 Typo fix in "Reading Data Into Your Pipeline" example. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mairbek/beam-site fix Alt