beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mairbek Khadikov (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner
Date Wed, 05 Apr 2017 22:41:41 GMT

    [ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15957937#comment-15957937
] 

Mairbek Khadikov commented on BEAM-1542:
----------------------------------------

Hi Guy, I work on Cloud Spanner at Google. Let us know if you need any help with the Sink.
I'm going to leave few comments in the PR as well.

If you are hitting the following exception
Exception in thread "main" com.google.common.util.concurrent.UncheckedExecutionException:
org.apache.beam.sdk.util.UserCodeException: java.lang.NoClassDefFoundError: Could not initialize
class com.google.cloud.spanner.spi.SpannerErrorInterceptor
    at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2214)
    at com.google.common.cache.LocalCache.get(LocalCache.java:4053)
    at com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
    at com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
    at org.apache.beam.runners.direct.DoFnLifecycleManager.get(DoFnLifecycleManager.java:61)
    at org.apache.beam.runners.direct.ParDoEvaluatorFactory.createEvaluator(ParDoEvaluatorFactory.java:124)
    at org.apache.beam.runners.direct.ParDoEvaluatorFactory.forApplication(ParDoEvaluatorFactory.java:77)
    at org.apache.beam.runners.direct.TransformEvaluatorRegistry.forApplication(TransformEvaluatorRegistry.java:96)
    at org.apache.beam.runners.direct.TransformExecutor.run(TransformExecutor.java:100)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)


It should be resolved with https://github.com/apache/beam/pull/2377

> Need Source/Sink for Spanner
> ----------------------------
>
>                 Key: BEAM-1542
>                 URL: https://issues.apache.org/jira/browse/BEAM-1542
>             Project: Beam
>          Issue Type: New Feature
>          Components: sdk-java-gcp
>            Reporter: Guy Molinari
>            Assignee: Guy Molinari
>
> Is there a source/sink for Spanner in the works?   If not I would gladly give this a
shot.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message