Jetty ALPN/NPN Ausnahme beim zu BigTable Spark verbindet, scala Code

Probleme, die bei dem Versuch, die BigTable Spark zu verbinden Unten ist der Fehler, den ich bin vor, während die Verbindung AusführungJetty ALPN/NPN Ausnahme beim zu BigTable Spark verbindet, scala Code

INFO grpc.BigtableSession: Bigtable options: BigtableOptions{dataHost=bigtable.googleapis.com, tableAdminHost=bigtableadmin.googleapis.com, instanceAdminHost=bigtableadmin.googleapis.com, projectId=ProjectID, instanceId=InstanceForBigTable, userAgent=hbase-1.2.5, credentialType=DefaultCredentials, port=443, dataChannelCount=20, retryOptions=RetryOptions{retriesEnabled=true, allowRetriesWithoutTimestamp=false, statusToRetryOn=[UNAVAILABLE, DEADLINE_EXCEEDED, UNAUTHENTICATED, INTERNAL, ABORTED], initialBackoffMillis=5, maxElapsedBackoffMillis=60000, backoffMultiplier=2.0, streamingBufferSize=60, readPartialRowTimeoutMillis=60000, maxScanTimeoutRetries=3}, bulkOptions=BulkOptions{asyncMutatorCount=2, useBulkApi=true, bulkMaxKeyCount=25, bulkMaxRequestSize=1048576, autoflushMs=0, maxInflightRpcs=1000, maxMemory=715862835, enableBulkMutationThrottling=false, bulkMutationRpcTargetMs=100}, callOptionsConfig=CallOptionsConfig{useTimeout=false, shortRpcTimeoutMs=60000, longRpcTimeoutMs=600000}, usePlaintextNegotiation=false}. 

Exception in thread "BigtableSession-startup-1" java.lang.IllegalArgumentException: Jetty ALPN/NPN has not been properly configured. 
    at com.google.bigtable.repackaged.io.grpc.netty.GrpcSslContexts.selectApplicationProtocolConfig(GrpcSslContexts.java:159) 
    at com.google.bigtable.repackaged.io.grpc.netty.GrpcSslContexts.configure(GrpcSslContexts.java:136) 
    at com.google.bigtable.repackaged.io.grpc.netty.GrpcSslContexts.configure(GrpcSslContexts.java:124) 
    at com.google.bigtable.repackaged.io.grpc.netty.GrpcSslContexts.forClient(GrpcSslContexts.java:94) 
    at com.google.bigtable.repackaged.com.google.cloud.bigtable.grpc.BigtableSession.createSslContext(BigtableSession.java:132) 
    at com.google.bigtable.repackaged.com.google.cloud.bigtable.grpc.BigtableSession.access$000(BigtableSession.java:84) 
    at com.google.bigtable.repackaged.com.google.cloud.bigtable.grpc.BigtableSession$2.run(BigtableSession.java:159) 
    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:748)

Code, ich versuche, Verbindung herzustellen

val tableDF: DataFrame = sqlContext.read.options(Map(HBaseTableCatalog.tableCatalog -> hbaseReadSchema)) 
     .format("org.apache.spark.sql.execution.datasources.hbase").load()

Kann jemand Gründe für den oben genannten Fehler liefern?

Quelle

2017-09-15 Pratik Barhate

Bitte entfernen Sie die PII aus der ersten Zeile. Wir haben auch ein funktionierendes Beispiel für SparkSQL über hortornworks-shc hier: https://github.com/GoogleCloudPlatform/cloud-bigtable-examples/tree/master/scala/bigtable-shc –

Dies ist höchstwahrscheinlich ein Abhängigkeitsproblem.

Die Verwendung von bigtable-hbase-1.x-hadoop:1.0.0-pre3 sollte die meisten möglichen Abhängigkeitsfehler beheben. Es schattiert alle bigtable Abhängigkeiten und ist so konzipiert, gut mit hadoop Umgebungen zu arbeiten.

Wie Solomon in seinem Kommentar darauf hingewiesen hat, modellieren Sie bitte Ihre Abhängigkeiten nach dem Beispiel auf github.

Quelle

2017-09-18 15:51:22

Jetty ALPN/NPN Ausnahme beim zu BigTable Spark verbindet, scala Code

Antwort

Verwandte Themen