Created
June 26, 2019 10:09
-
-
Save yjshen/7ef5ae19144c006344633b7be4ce8122 to your computer and use it in GitHub Desktop.
streaming - write atomic types'
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Failed to create schema for persistent://public/default/topic-27: Too many open files | |
| java.lang.RuntimeException: Failed to create schema for persistent://public/default/topic-27: Too many open files | |
| at org.apache.spark.sql.pulsar.PulsarTest$$anonfun$createPulsarSchema$2.apply(PulsarTest.scala:282) | |
| at org.apache.spark.sql.pulsar.PulsarTest$$anonfun$createPulsarSchema$2.apply(PulsarTest.scala:276) | |
| at org.apache.spark.util.Utils$.tryWithResource(Utils.scala:2543) | |
| at org.apache.spark.sql.pulsar.PulsarTest$class.createPulsarSchema(PulsarTest.scala:276) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite.createPulsarSchema(PulsarSinkSuite.scala:33) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite$$anonfun$6.check$2(PulsarSinkSuite.scala:265) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite$$anonfun$6.apply$mcV$sp(PulsarSinkSuite.scala:308) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite$$anonfun$6.apply(PulsarSinkSuite.scala:259) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite$$anonfun$6.apply(PulsarSinkSuite.scala:259) | |
| at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85) | |
| at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104) | |
| at org.scalatest.Transformer.apply(Transformer.scala:22) | |
| at org.scalatest.Transformer.apply(Transformer.scala:20) | |
| at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:186) | |
| at org.apache.spark.SparkFunSuite.withFixture(SparkFunSuite.scala:103) | |
| at org.scalatest.FunSuiteLike$class.invokeWithFixture$1(FunSuiteLike.scala:183) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:196) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:196) | |
| at org.scalatest.SuperEngine.runTestImpl(Engine.scala:289) | |
| at org.scalatest.FunSuiteLike$class.runTest(FunSuiteLike.scala:196) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite.org$scalatest$BeforeAndAfterEach$$super$runTest(PulsarSinkSuite.scala:33) | |
| at org.scalatest.BeforeAndAfterEach$class.runTest(BeforeAndAfterEach.scala:221) | |
| at org.apache.spark.sql.pulsar.PulsarSinkSuite.runTest(PulsarSinkSuite.scala:33) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:229) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:229) | |
| at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:396) | |
| at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:384) | |
| at scala.collection.immutable.List.foreach(List.scala:392) | |
| at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:384) | |
| at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:379) | |
| at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:461) | |
| at org.scalatest.FunSuiteLike$class.runTests(FunSuiteLike.scala:229) | |
| at org.scalatest.FunSuite.runTests(FunSuite.scala:1560) | |
| at org.scalatest.Suite$class.run(Suite.scala:1147) | |
| at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1560) | |
| at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:233) | |
| at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:233) | |
| at org.scalatest.SuperEngine.runImpl(Engine.scala:521) | |
| at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:233) | |
| at org.apache.spark.SparkFunSuite.org$scalatest$BeforeAndAfterAll$$super$run(SparkFunSuite.scala:52) | |
| at org.scalatest.BeforeAndAfterAll$class.liftedTree1$1(BeforeAndAfterAll.scala:213) | |
| at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:210) | |
| at org.apache.spark.SparkFunSuite.run(SparkFunSuite.scala:52) | |
| at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:45) | |
| at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$1.apply(Runner.scala:1340) | |
| at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$1.apply(Runner.scala:1334) | |
| at scala.collection.immutable.List.foreach(List.scala:392) | |
| at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:1334) | |
| at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1011) | |
| at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1010) | |
| at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:1500) | |
| at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1010) | |
| at org.scalatest.tools.Runner$.run(Runner.scala:850) | |
| at org.scalatest.tools.Runner.run(Runner.scala) | |
| at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2(ScalaTestRunner.java:131) | |
| at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:28) | |
| Caused by: org.apache.pulsar.client.admin.PulsarAdminException: java.lang.IllegalStateException: failed to create a child event loop | |
| at org.apache.pulsar.client.admin.internal.BaseResource.getApiException(BaseResource.java:228) | |
| at org.apache.pulsar.client.admin.internal.SchemasImpl.createSchema(SchemasImpl.java:91) | |
| at org.apache.spark.sql.pulsar.PulsarTest$$anonfun$createPulsarSchema$2.apply(PulsarTest.scala:278) | |
| ... 55 more | |
| Caused by: java.lang.IllegalStateException: failed to create a child event loop | |
| at org.apache.pulsar.shade.io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:88) | |
| at org.apache.pulsar.shade.io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) | |
| at org.apache.pulsar.shade.io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) | |
| at org.apache.pulsar.shade.io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoopGroup.<init>(NioEventLoopGroup.java:77) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoopGroup.<init>(NioEventLoopGroup.java:72) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoopGroup.<init>(NioEventLoopGroup.java:59) | |
| at org.apache.pulsar.shade.org.asynchttpclient.netty.channel.ChannelManager.<init>(ChannelManager.java:129) | |
| at org.apache.pulsar.shade.org.asynchttpclient.DefaultAsyncHttpClient.<init>(DefaultAsyncHttpClient.java:89) | |
| at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.<init>(AsyncHttpConnector.java:119) | |
| at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.<init>(AsyncHttpConnector.java:75) | |
| at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnectorProvider.getConnector(AsyncHttpConnectorProvider.java:38) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.ClientConfig$State.initRuntime(ClientConfig.java:473) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.internal.util.collection.Values$LazyValueImpl.get(Values.java:341) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.ClientConfig.getRuntime(ClientConfig.java:826) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.ClientRequest.getConfiguration(ClientRequest.java:285) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation.validateHttpMethodAndEntity(JerseyInvocation.java:143) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation.<init>(JerseyInvocation.java:112) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation.<init>(JerseyInvocation.java:108) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation.<init>(JerseyInvocation.java:99) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation$Builder.method(JerseyInvocation.java:456) | |
| at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation$Builder.post(JerseyInvocation.java:357) | |
| at org.apache.pulsar.client.admin.internal.SchemasImpl.createSchema(SchemasImpl.java:89) | |
| ... 56 more | |
| Caused by: org.apache.pulsar.shade.io.netty.channel.ChannelException: failed to open a new selector | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.openSelector(NioEventLoop.java:168) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.<init>(NioEventLoop.java:142) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoopGroup.newChild(NioEventLoopGroup.java:127) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoopGroup.newChild(NioEventLoopGroup.java:36) | |
| at org.apache.pulsar.shade.io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) | |
| ... 78 more | |
| Caused by: java.io.IOException: Too many open files | |
| at sun.nio.ch.IOUtil.makePipe(Native Method) | |
| at sun.nio.ch.KQueueSelectorImpl.<init>(KQueueSelectorImpl.java:84) | |
| at sun.nio.ch.KQueueSelectorProvider.openSelector(KQueueSelectorProvider.java:42) | |
| at org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.openSelector(NioEventLoop.java:166) | |
| ... 82 more |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment