Using zeppelin directly in binary distribution mode will occasionally encounter a timeout error, but it appears less frequently than in the docker environment. I found a property in aether called “aether.connector.connectTimeout”, which seems helpful in such an issue. Where should I put this property? In zeppelin-site.xml?
Fyi https://maven.apache.org/resolver/apidocs/org/eclipse/aether/ConfigurationProperties.html#CONNECT_TIMEOUT From: Jeff Zhang <zjf...@gmail.com> Reply-To: "users@zeppelin.apache.org" <users@zeppelin.apache.org> Date: Monday, July 19, 2021 at 10:43 PM To: users <users@zeppelin.apache.org> Subject: Re: java.net.SocketTimeoutException: connect timed out when download jars from maven repo Have you tried using zeppelin binary distribution instead of docker ? Chenyu Zheng <chenyu.zh...@hulu.com<mailto: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/<https://urldefense.com/v3/__https:/repo1.maven.org/maven2/__;!!PA7sDg!TVMxeIp8EWrU7Z-uxIlY7Eibbe6nSBQj0J0EbUW37STJFNNrXglCnEIKsyJVFVR3OQ$> 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://urldefense.com/v3/__https:/repo1.maven.org/maven2/__;!!PA7sDg!TVMxeIp8EWrU7Z-uxIlY7Eibbe6nSBQj0J0EbUW37STJFNNrXglCnEIKsyJVFVR3OQ$>): 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://urldefense.com/v3/__https:/repo1.maven.org/maven2/__;!!PA7sDg!TVMxeIp8EWrU7Z-uxIlY7Eibbe6nSBQj0J0EbUW37STJFNNrXglCnEIKsyJVFVR3OQ$>): 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://urldefense.com/v3/__https:/repo1.maven.org/maven2/__;!!PA7sDg!TVMxeIp8EWrU7Z-uxIlY7Eibbe6nSBQj0J0EbUW37STJFNNrXglCnEIKsyJVFVR3OQ$>): 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
