Chenyu, Feel free to create a ticket and PR for this issue
Chenyu Zheng <chenyu.zh...@hulu.com> 于2021年7月20日周二 下午6:23写道： > OK. I’ll try to add this setting and rebuild the project. > > > > *From: *Jeff Zhang <zjf...@gmail.com> > *Reply-To: *"users@zeppelin.apache.org" <users@zeppelin.apache.org> > *Date: *Tuesday, July 20, 2021 at 1:09 PM > *To: *users <users@zeppelin.apache.org> > *Subject: *Re: java.net.SocketTimeoutException: connect timed out when > download jars from maven repo > > > > I am afraid zeppelin doesn't support to customize configuration of aether, > you can take a look at this class: DependencyResolver. > > > > > > > > Chenyu Zheng <chenyu.zh...@hulu.com> 于2021年7月20日周二 下午12:54写道： > > 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 > <https://urldefense.com/v3/__https:/maven.apache.org/resolver/apidocs/org/eclipse/aether/ConfigurationProperties.html*CONNECT_TIMEOUT__;Iw!!PA7sDg!SORn1znf7kxvcD3vbpY4QmjLbpG0xQnFhEv3f0h9sY7y992T7IFA34UL3pAgta9cCw$> > > > > *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> 于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 > > > > > -- > > Best Regards > > Jeff Zhang > -- Best Regards Jeff Zhang
