scala - Dataflow with Cloud Spanner: java.lang.IllegalArgumentException: Jetty ALPN/NPN has not been properly configured -


i have dataflow job writes results cloud spanner table. works fine when run job locally running on dataflow gives following error -

java.lang.illegalargumentexception: jetty alpn/npn has not been configured.     io.grpc.netty.grpcsslcontexts.selectapplicationprotocolconfig(grpcsslcontexts.java:174)     io.grpc.netty.grpcsslcontexts.configure(grpcsslcontexts.java:151)     io.grpc.netty.grpcsslcontexts.configure(grpcsslcontexts.java:139)     io.grpc.netty.grpcsslcontexts.forclient(grpcsslcontexts.java:109)     com.google.cloud.spanner.spanneroptions$nettyrpcchannelfactory.newsslcontext(spanneroptions.java:289)     com.google.cloud.spanner.spanneroptions$nettyrpcchannelfactory.newchannel(spanneroptions.java:278)     com.google.cloud.spanner.spanneroptions.createchannel(spanneroptions.java:252)     com.google.cloud.spanner.spanneroptions.createchannels(spanneroptions.java:239)     com.google.cloud.spanner.spanneroptions.<init>(spanneroptions.java:88)     com.google.cloud.spanner.spanneroptions.<init>(spanneroptions.java:43)     com.google.cloud.spanner.spanneroptions$builder.build(spanneroptions.java:179) 

i error when trying create spanneroptions instance -

val options: spanneroptions = spanneroptions.newbuilder().build() 

i saw this question excluding netty-all below not help.

librarydependencies ++= libraries(   apache_beam,   circe,   scalatest % test,   junit % test,   hamcrest % test ).map(_.exclude("io.netty", "netty-all")) 

what can fix this?

fixed matching google-cloud-spanner version 1 specified in apache beam's pom.xml.


Comments

Popular posts from this blog

android - InAppBilling registering BroadcastReceiver in AndroidManifest -

python Tkinter Capturing keyboard events save as one single string -

sql server - Why does Linq-to-SQL add unnecessary COUNT()? -