Have you tried using zeppelin binary distribution instead of docker ?

Chenyu Zheng <chenyu.zh...@hulu.com> 于2021年7月19日周一 下午6:10写道:

> Hi contributors,
>
>
>
> I’m trying to setup zeppelin v0.9.0 on Kubernetes, however when I try to
> download jar using “flink.execution.packages”, I got an error like below.
> But I could connect to maven repo https://repo1.maven.org/maven2/ in
> zeppelin container and interpreter container.
>
>
>
> Could we set the timeout to a larger value? Can you give a hand on how to
> diagnose / fix this problem?
>
>
>
> Thx!
>
>
>
> *org.apache.zeppelin.interpreter.InterpreterException:
> org.apache.zeppelin.interpreter.InterpreterException:
> org.apache.zeppelin.shaded.org.eclipse.aether.RepositoryException: Cannot
> fetch dependencies for org.apache.flink:flink-connector-kafka_2.11:1.12.2
> at
> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76)
> at
> org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:836)
> at
> org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:744)
> at org.apache.zeppelin.scheduler.Job.run(Job.java:172) at
> org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:132)
> at
> org.apache.zeppelin.scheduler.ParallelScheduler.lambda$runJobInScheduler$0(ParallelScheduler.java:46)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748) Caused by:
> org.apache.zeppelin.interpreter.InterpreterException:
> org.apache.zeppelin.shaded.org.eclipse.aether.RepositoryException: Cannot
> fetch dependencies for org.apache.flink:flink-connector-kafka_2.11:1.12.2
> at
> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76)
> at
> org.apache.zeppelin.interpreter.Interpreter.getInterpreterInTheSameSessionByClassName(Interpreter.java:355)
> at
> org.apache.zeppelin.interpreter.Interpreter.getInterpreterInTheSameSessionByClassName(Interpreter.java:366)
> at
> org.apache.zeppelin.flink.FlinkStreamSqlInterpreter.open(FlinkStreamSqlInterpreter.java:47)
> at
> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)
> ... 8 more Caused by:
> org.apache.zeppelin.shaded.org.eclipse.aether.RepositoryException: Cannot
> fetch dependencies for org.apache.flink:flink-connector-kafka_2.11:1.12.2
> at
> org.apache.zeppelin.dep.DependencyResolver.getArtifactsWithDep(DependencyResolver.java:185)
> at
> org.apache.zeppelin.dep.DependencyResolver.loadFromMvn(DependencyResolver.java:133)
> at
> org.apache.zeppelin.dep.DependencyResolver.load(DependencyResolver.java:81)
> at
> org.apache.zeppelin.dep.DependencyResolver.load(DependencyResolver.java:68)
> at
> org.apache.zeppelin.flink.FlinkScalaInterpreter$$anonfun$10.apply(FlinkScalaInterpreter.scala:790)
> at
> org.apache.zeppelin.flink.FlinkScalaInterpreter$$anonfun$10.apply(FlinkScalaInterpreter.scala:790)
> at
> scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
> at
> scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
> at
> scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
> at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186) at
> scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
> at scala.collection.mutable.ArrayOps$ofRef.flatMap(ArrayOps.scala:186) at
> org.apache.zeppelin.flink.FlinkScalaInterpreter.getUserJarsExceptUdfJars(FlinkScalaInterpreter.scala:790)
> at
> org.apache.zeppelin.flink.FlinkScalaInterpreter.initFlinkConfig(FlinkScalaInterpreter.scala:191)
> at
> org.apache.zeppelin.flink.FlinkScalaInterpreter.open(FlinkScalaInterpreter.scala:112)
> at
> org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:65)
> at
> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)
> ... 12 more Caused by:
> org.apache.zeppelin.shaded.org.eclipse.aether.resolution.DependencyResolutionException:
> Failed to read artifact descriptor for
> org.apache.flink:flink-connector-kafka_2.11:jar:1.12.2 at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultRepositorySystem.resolveDependencies(DefaultRepositorySystem.java:353)
> at
> org.apache.zeppelin.dep.DependencyResolver.getArtifactsWithDep(DependencyResolver.java:182)
> ... 28 more Caused by:
> org.apache.zeppelin.shaded.org.eclipse.aether.collection.DependencyCollectionException:
> Failed to read artifact descriptor for
> org.apache.flink:flink-connector-kafka_2.11:jar:1.12.2 at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.collect.DefaultDependencyCollector.collectDependencies(DefaultDependencyCollector.java:206)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultRepositorySystem.resolveDependencies(DefaultRepositorySystem.java:309)
> ... 29 more Caused by:
> org.apache.zeppelin.shaded.org.eclipse.aether.resolution.ArtifactDescriptorException:
> Failed to read artifact descriptor for
> org.apache.flink:flink-connector-kafka_2.11:jar:1.12.2 at
> org.apache.zeppelin.shaded.org.apache.maven.repository.internal.DefaultArtifactDescriptorReader.loadPom(DefaultArtifactDescriptorReader.java:301)
> at
> org.apache.zeppelin.shaded.org.apache.maven.repository.internal.DefaultArtifactDescriptorReader.readArtifactDescriptor(DefaultArtifactDescriptorReader.java:171)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.collect.DefaultDependencyCollector.collectDependencies(DefaultDependencyCollector.java:200)
> ... 30 more Caused by:
> org.apache.zeppelin.shaded.org.apache.maven.model.resolution.UnresolvableModelException:
> Could not transfer artifact org.apache.flink:flink-connectors:pom:1.12.2
> from/to central (https://repo1.maven.org/maven2/
> <https://repo1.maven.org/maven2/>): connect timed out at
> org.apache.zeppelin.shaded.org.apache.maven.repository.internal.DefaultModelResolver.resolveModel(DefaultModelResolver.java:176)
> at
> org.apache.zeppelin.shaded.org.apache.maven.repository.internal.DefaultModelResolver.resolveModel(DefaultModelResolver.java:222)
> at
> org.apache.zeppelin.shaded.org.apache.maven.model.building.DefaultModelBuilder.readParentExternally(DefaultModelBuilder.java:1070)
> at
> org.apache.zeppelin.shaded.org.apache.maven.model.building.DefaultModelBuilder.readParent(DefaultModelBuilder.java:846)
> at
> org.apache.zeppelin.shaded.org.apache.maven.model.building.DefaultModelBuilder.build(DefaultModelBuilder.java:337)
> at
> org.apache.zeppelin.shaded.org.apache.maven.repository.internal.DefaultArtifactDescriptorReader.loadPom(DefaultArtifactDescriptorReader.java:292)
> ... 32 more Caused by:
> org.apache.zeppelin.shaded.org.eclipse.aether.resolution.ArtifactResolutionException:
> Could not transfer artifact org.apache.flink:flink-connectors:pom:1.12.2
> from/to central (https://repo1.maven.org/maven2/
> <https://repo1.maven.org/maven2/>): connect timed out at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultArtifactResolver.resolve(DefaultArtifactResolver.java:424)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultArtifactResolver.resolveArtifacts(DefaultArtifactResolver.java:229)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultArtifactResolver.resolveArtifact(DefaultArtifactResolver.java:207)
> at
> org.apache.zeppelin.shaded.org.apache.maven.repository.internal.DefaultModelResolver.resolveModel(DefaultModelResolver.java:172)
> ... 37 more Caused by:
> org.apache.zeppelin.shaded.org.eclipse.aether.transfer.ArtifactTransferException:
> Could not transfer artifact org.apache.flink:flink-connectors:pom:1.12.2
> from/to central (https://repo1.maven.org/maven2/
> <https://repo1.maven.org/maven2/>): connect timed out at
> org.apache.zeppelin.shaded.org.eclipse.aether.connector.basic.ArtifactTransportListener.transferFailed(ArtifactTransportListener.java:52)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.connector.basic.BasicRepositoryConnector$TaskRunner.run(BasicRepositoryConnector.java:369)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.util.concurrency.RunnableErrorForwarder$1.run(RunnableErrorForwarder.java:75)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.connector.basic.BasicRepositoryConnector$DirectExecutor.execute(BasicRepositoryConnector.java:644)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.connector.basic.BasicRepositoryConnector.get(BasicRepositoryConnector.java:262)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultArtifactResolver.performDownloads(DefaultArtifactResolver.java:499)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.internal.impl.DefaultArtifactResolver.resolve(DefaultArtifactResolver.java:401)
> ... 40 more Caused by: java.net.SocketTimeoutException: connect timed out
> at java.net.PlainSocketImpl.socketConnect(Native Method) at
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
> at
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
> at
> java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at
> java.net.Socket.connect(Socket.java:607) at
> sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:288) at
> org.apache.zeppelin.shaded.org.apache.http.conn.ssl.SSLSocketFactory.connectSocket(SSLSocketFactory.java:532)
> at
> org.apache.zeppelin.shaded.org.apache.http.conn.ssl.SSLSocketFactory.connectSocket(SSLSocketFactory.java:409)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:177)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:304)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:611)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:446)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:882)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:71)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:55)
> at
> org.apache.zeppelin.shaded.org.apache.http.impl.client.DecompressingHttpClient.execute(DecompressingHttpClient.java:158)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.transport.http.HttpTransporter.execute(HttpTransporter.java:290)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.transport.http.HttpTransporter.implGet(HttpTransporter.java:246)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.spi.connector.transport.AbstractTransporter.get(AbstractTransporter.java:67)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.connector.basic.BasicRepositoryConnector$GetTaskRunner.runTask(BasicRepositoryConnector.java:457)
> at
> org.apache.zeppelin.shaded.org.eclipse.aether.connector.basic.BasicRepositoryConnector$TaskRunner.run(BasicRepositoryConnector.java:364)
> ... 45 more*
>
>
>
>
>
>
>


-- 
Best Regards

Jeff Zhang

Reply via email to