[
https://issues.apache.org/jira/browse/HUDI-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Xu updated HUDI-3052:
-----------------------------
Labels: hudi-subtask pull-request-available sev:critical (was:
pull-request-available sev:critical)
> Flaky TestJsonKafkaSource in CI runs
> -------------------------------------
>
> Key: HUDI-3052
> URL: https://issues.apache.org/jira/browse/HUDI-3052
> Project: Apache Hudi
> Issue Type: Task
> Components: Testing
> Reporter: sivabalan narayanan
> Assignee: Raymond Xu
> Priority: Major
> Labels: hudi-subtask, pull-request-available, sev:critical
> Fix For: 0.11.0, 0.10.1
>
>
> TestJsonKafkaSource.testJsonKafkaSourceResetStrategy
> Reference:
> [https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_apis/build/builds/4441/logs/26]
>
>
> {code:java}
> 2021-12-17T16:46:09.3127345Z 1401494 [controller-event-thread] ERROR
> kafka.controller.ControllerEventManager$ControllerEventThread -
> [ControllerEventThread controllerId=0] Error processing event Startup
> 2021-12-17T16:46:09.3128803Z
> org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode
> = Session expired for /controller
> 2021-12-17T16:46:09.3131970Z at
> org.apache.zookeeper.KeeperException.create(KeeperException.java:127)
> 2021-12-17T16:46:09.3133297Z at
> org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
> 2021-12-17T16:46:09.3134202Z at
> kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:492)
> 2021-12-17T16:46:09.3135241Z at
> kafka.zk.KafkaZkClient.registerZNodeChangeHandlerAndCheckExistence(KafkaZkClient.scala:1222)
> 2021-12-17T16:46:09.3135907Z at
> kafka.controller.KafkaController$Startup$.process(KafkaController.scala:1147)
> 2021-12-17T16:46:09.3139892Z at
> kafka.controller.ControllerEventManager$ControllerEventThread$$anonfun$doWork$1.apply$mcV$sp(ControllerEventManager.scala:86)
> 2021-12-17T16:46:09.3140738Z at
> kafka.controller.ControllerEventManager$ControllerEventThread$$anonfun$doWork$1.apply(ControllerEventManager.scala:86)
> 2021-12-17T16:46:09.3146511Z at
> kafka.controller.ControllerEventManager$ControllerEventThread$$anonfun$doWork$1.apply(ControllerEventManager.scala:86)
> 2021-12-17T16:46:09.3147294Z at
> kafka.metrics.KafkaTimer.time(KafkaTimer.scala:31)
> 2021-12-17T16:46:09.3150920Z at
> kafka.controller.ControllerEventManager$ControllerEventThread.doWork(ControllerEventManager.scala:85)
> 2021-12-17T16:46:09.3155198Z at
> kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
> 2021-12-17T16:46:09.3347969Z 1401510 [main] ERROR kafka.server.KafkaServer -
> [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown
> 2021-12-17T16:46:09.3351046Z
> org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode
> = Session expired for /brokers/topics/__consumer_offsets
> 2021-12-17T16:46:09.3352565Z at
> org.apache.zookeeper.KeeperException.create(KeeperException.java:127)
> 2021-12-17T16:46:09.3353401Z at
> org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
> 2021-12-17T16:46:09.3354446Z at
> kafka.zookeeper.AsyncResponse.resultException(ZooKeeperClient.scala:492)
> 2021-12-17T16:46:09.3355088Z at
> kafka.zk.KafkaZkClient$$anonfun$getReplicaAssignmentForTopics$1.apply(KafkaZkClient.scala:468)
> 2021-12-17T16:46:09.3355763Z at
> kafka.zk.KafkaZkClient$$anonfun$getReplicaAssignmentForTopics$1.apply(KafkaZkClient.scala:463)
> 2021-12-17T16:46:09.3356500Z at
> scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
> 2021-12-17T16:46:09.3357124Z at
> scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
> 2021-12-17T16:46:09.3357956Z at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> 2021-12-17T16:46:09.3358502Z at
> scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> 2021-12-17T16:46:09.3359069Z at
> scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
> 2021-12-17T16:46:09.3359627Z at
> scala.collection.AbstractTraversable.flatMap(Traversable.scala:104)
> 2021-12-17T16:46:09.3360171Z at
> kafka.zk.KafkaZkClient.getReplicaAssignmentForTopics(KafkaZkClient.scala:463)
> 2021-12-17T16:46:09.3360744Z at
> kafka.zk.KafkaZkClient.getTopicPartitionCount(KafkaZkClient.scala:513)
> 2021-12-17T16:46:09.3361394Z at
> kafka.coordinator.group.GroupMetadataManager.getGroupMetadataTopicPartitionCount(GroupMetadataManager.scala:870)
> 2021-12-17T16:46:09.3362046Z at
> kafka.coordinator.group.GroupMetadataManager.<init>(GroupMetadataManager.scala:74)
> 2021-12-17T16:46:09.3362646Z at
> kafka.coordinator.group.GroupCoordinator$.apply(GroupCoordinator.scala:906)
> 2021-12-17T16:46:09.3363588Z at
> kafka.coordinator.group.GroupCoordinator$.apply(GroupCoordinator.scala:879)
> 2021-12-17T16:46:09.3364062Z at
> kafka.server.KafkaServer.startup(KafkaServer.scala:274)
> 2021-12-17T16:46:09.3364654Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils$$anonfun$setupEmbeddedKafkaServer$2.apply(KafkaTestUtils.scala:113)
> 2021-12-17T16:46:09.3365366Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils$$anonfun$setupEmbeddedKafkaServer$2.apply(KafkaTestUtils.scala:109)
> 2021-12-17T16:46:09.3366017Z at
> org.apache.spark.util.Utils$$anonfun$startServiceOnPort$1.apply$mcVI$sp(Utils.scala:2269)
> 2021-12-17T16:46:09.3366535Z at
> scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:160)
> 2021-12-17T16:46:09.3367034Z at
> org.apache.spark.util.Utils$.startServiceOnPort(Utils.scala:2261)
> 2021-12-17T16:46:09.3367607Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setupEmbeddedKafkaServer(KafkaTestUtils.scala:109)
> 2021-12-17T16:46:09.3368190Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setup(KafkaTestUtils.scala:131)
> 2021-12-17T16:46:09.3368766Z at
> org.apache.hudi.utilities.sources.TestJsonKafkaSource.setup(TestJsonKafkaSource.java:84)
> 2021-12-17T16:46:09.3369272Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-12-17T16:46:09.3369733Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-12-17T16:46:09.3370296Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-12-17T16:46:09.3370805Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-12-17T16:46:09.3371288Z at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2021-12-17T16:46:09.3371867Z at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2021-12-17T16:46:09.3372528Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2021-12-17T16:46:09.3373195Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2021-12-17T16:46:09.3373791Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:126)
> 2021-12-17T16:46:09.3374527Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeEachMethod(TimeoutExtension.java:76)
> 2021-12-17T16:46:09.3375236Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2021-12-17T16:46:09.3375898Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2021-12-17T16:46:09.3376581Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2021-12-17T16:46:09.3377282Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2021-12-17T16:46:09.3377959Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2021-12-17T16:46:09.3378608Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2021-12-17T16:46:09.3379231Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2021-12-17T16:46:09.3379817Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2021-12-17T16:46:09.3380452Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeMethodInExtensionContext(ClassBasedTestDescriptor.java:481)
> 2021-12-17T16:46:09.3381216Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$synthesizeBeforeEachMethodAdapter$18(ClassBasedTestDescriptor.java:466)
> 2021-12-17T16:46:09.3381982Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeEachMethods$2(TestMethodTestDescriptor.java:169)
> 2021-12-17T16:46:09.3382855Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$5(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:09.3383578Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3384305Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:09.3385070Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachMethods(TestMethodTestDescriptor.java:166)
> 2021-12-17T16:46:09.3385746Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:133)
> 2021-12-17T16:46:09.3386370Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:71)
> 2021-12-17T16:46:09.3387030Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
> 2021-12-17T16:46:09.3387688Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3388319Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:09.3388922Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:09.3389522Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:09.3390177Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3390793Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:09.3391405Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:09.3391917Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:09.3392529Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:09.3393281Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:09.3393996Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3394659Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:09.3395238Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:09.3395840Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:09.3396490Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3397109Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:09.3397901Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:09.3398595Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:09.3399252Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:09.3400064Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:09.3400770Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3401473Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:09.3402097Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:09.3402826Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:09.3403533Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:09.3404199Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:09.3404865Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:09.3405627Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
> 2021-12-17T16:46:09.3406436Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
> 2021-12-17T16:46:09.3407143Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
> 2021-12-17T16:46:09.3407864Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2021-12-17T16:46:09.3408570Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:87)
> 2021-12-17T16:46:09.3409279Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:53)
> 2021-12-17T16:46:09.3410037Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:66)
> 2021-12-17T16:46:09.3410782Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:51)
> 2021-12-17T16:46:09.3411439Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:87)
> 2021-12-17T16:46:09.3412023Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:66)
> 2021-12-17T16:46:09.3412797Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2021-12-17T16:46:09.3413458Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:127)
> 2021-12-17T16:46:09.3414047Z at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:377)
> 2021-12-17T16:46:09.3414689Z at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:138)
> 2021-12-17T16:46:09.3415232Z at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:465)
> 2021-12-17T16:46:09.3415761Z at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:451)
> 2021-12-17T16:46:09.3615998Z 1401543 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:09.4680846Z 1401649 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:09.5680925Z 1401750 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:09.6689464Z 1401850 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:09.7714380Z 1401951 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:09.8708807Z 1402052 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:09.9718378Z 1402153 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:10.0731635Z 1402254 [Controller-0-to-broker-0-send-thread]
> WARN org.apache.kafka.clients.NetworkClient - [Controller id=0,
> targetBrokerId=0] Connection to node 0 could not be established. Broker may
> not be available.
> 2021-12-17T16:46:12.6850467Z 1404862 [main] WARN
> org.apache.spark.sql.SparkSession$Builder - Using an existing SparkSession;
> some configuration may not take effect.
> 2021-12-17T16:46:12.7013457Z 1404883 [main] WARN
> org.apache.zookeeper.jmx.MBeanRegistry - Failed to register MBean
> StandaloneServer_port-1
> 2021-12-17T16:46:12.7042532Z 1404883 [main] WARN
> org.apache.zookeeper.server.ZooKeeperServer - Failed to register with JMX
> 2021-12-17T16:46:12.7044004Z javax.management.InstanceAlreadyExistsException:
> org.apache.ZooKeeperService:name0=StandaloneServer_port-1
> 2021-12-17T16:46:12.7045375Z at
> com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
> 2021-12-17T16:46:12.7046285Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
> 2021-12-17T16:46:12.7047275Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
> 2021-12-17T16:46:12.7048284Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
> 2021-12-17T16:46:12.7049868Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
> 2021-12-17T16:46:12.7050556Z at
> com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
> 2021-12-17T16:46:12.7051149Z at
> org.apache.zookeeper.jmx.MBeanRegistry.register(MBeanRegistry.java:96)
> 2021-12-17T16:46:12.7051739Z at
> org.apache.zookeeper.server.ZooKeeperServer.registerJMX(ZooKeeperServer.java:377)
> 2021-12-17T16:46:12.7052336Z at
> org.apache.zookeeper.server.ZooKeeperServer.startup(ZooKeeperServer.java:410)
> 2021-12-17T16:46:12.7052944Z at
> org.apache.zookeeper.server.NIOServerCnxnFactory.startup(NIOServerCnxnFactory.java:123)
> 2021-12-17T16:46:12.7053800Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils$EmbeddedZookeeper.<init>(KafkaTestUtils.scala:314)
> 2021-12-17T16:46:12.7054503Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setupEmbeddedZookeeper(KafkaTestUtils.scala:97)
> 2021-12-17T16:46:12.7055128Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setup(KafkaTestUtils.scala:130)
> 2021-12-17T16:46:12.7055749Z at
> org.apache.hudi.utilities.sources.TestJsonKafkaSource.setup(TestJsonKafkaSource.java:84)
> 2021-12-17T16:46:12.7056293Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-12-17T16:46:12.7056786Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-12-17T16:46:12.7057391Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-12-17T16:46:12.7057942Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-12-17T16:46:12.7058461Z at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2021-12-17T16:46:12.7059089Z at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2021-12-17T16:46:12.7059797Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2021-12-17T16:46:12.7060621Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2021-12-17T16:46:12.7061215Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:126)
> 2021-12-17T16:46:12.7061858Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeEachMethod(TimeoutExtension.java:76)
> 2021-12-17T16:46:12.7062558Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2021-12-17T16:46:12.7063313Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2021-12-17T16:46:12.7063996Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2021-12-17T16:46:12.7064694Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2021-12-17T16:46:12.7065368Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2021-12-17T16:46:12.7066016Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2021-12-17T16:46:12.7066633Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2021-12-17T16:46:12.7067214Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2021-12-17T16:46:12.7067854Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeMethodInExtensionContext(ClassBasedTestDescriptor.java:481)
> 2021-12-17T16:46:12.7068613Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$synthesizeBeforeEachMethodAdapter$18(ClassBasedTestDescriptor.java:466)
> 2021-12-17T16:46:12.7069385Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeEachMethods$2(TestMethodTestDescriptor.java:169)
> 2021-12-17T16:46:12.7070186Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$5(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:12.7070905Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7071685Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:12.7072449Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachMethods(TestMethodTestDescriptor.java:166)
> 2021-12-17T16:46:12.7073128Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:133)
> 2021-12-17T16:46:12.7073828Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:71)
> 2021-12-17T16:46:12.7074688Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
> 2021-12-17T16:46:12.7075396Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7076100Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:12.7076723Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:12.7077584Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:12.7078308Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7078994Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:12.7079641Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:12.7080190Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:12.7080868Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:12.7081650Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:12.7082360Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7083065Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:12.7083785Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:12.7084437Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:12.7085136Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7085818Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:12.7086530Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:12.7087038Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:12.7087662Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:12.7088391Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:12.7089038Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7089693Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:12.7090291Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:12.7090865Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:12.7091515Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:12.7092150Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:12.7092740Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:12.7093445Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
> 2021-12-17T16:46:12.7094255Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
> 2021-12-17T16:46:12.7094939Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
> 2021-12-17T16:46:12.7095579Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2021-12-17T16:46:12.7096229Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:87)
> 2021-12-17T16:46:12.7096906Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:53)
> 2021-12-17T16:46:12.7101101Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:66)
> 2021-12-17T16:46:12.7101849Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:51)
> 2021-12-17T16:46:12.7102504Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:87)
> 2021-12-17T16:46:12.7103117Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:66)
> 2021-12-17T16:46:12.7103755Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2021-12-17T16:46:12.7104460Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:127)
> 2021-12-17T16:46:12.7105113Z at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:377)
> 2021-12-17T16:46:12.7105694Z at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:138)
> 2021-12-17T16:46:12.7106266Z at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:465)
> 2021-12-17T16:46:12.7107389Z at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:451)
> 2021-12-17T16:46:13.1299616Z 1405311 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:13.1302507Z 1405311 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:13.1303614Z 1405311 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-a011313d-a2ee-4a6b-8f95-e6223305e8b0
> 2021-12-17T16:46:13.1304592Z 1405311 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:13.4238950Z 1405606 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:13.4240159Z 1405606 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:13.4241524Z 1405606 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-a011313d-a2ee-4a6b-8f95-e6223305e8b0
> 2021-12-17T16:46:13.4242613Z 1405606 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:13.7149254Z 1405897 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:13.7166066Z 1405898 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:13.7167511Z 1405898 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-a011313d-a2ee-4a6b-8f95-e6223305e8b0
> 2021-12-17T16:46:13.7168748Z 1405898 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:13.7657894Z 1405947 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:13.7659495Z 1405947 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:13.7662824Z 1405947 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-a011313d-a2ee-4a6b-8f95-e6223305e8b0
> 2021-12-17T16:46:13.7664142Z 1405948 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:13.8183035Z 1406000 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:13.8184506Z 1406000 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:13.8188260Z 1406000 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-a011313d-a2ee-4a6b-8f95-e6223305e8b0
> 2021-12-17T16:46:13.8189686Z 1406000 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:16.8633376Z 1409045 [main] WARN
> org.apache.spark.sql.SparkSession$Builder - Using an existing SparkSession;
> some configuration may not take effect.
> 2021-12-17T16:46:16.8767755Z 1409059 [main] WARN
> org.apache.zookeeper.jmx.MBeanRegistry - Failed to register MBean
> StandaloneServer_port-1
> 2021-12-17T16:46:16.8807961Z 1409059 [main] WARN
> org.apache.zookeeper.server.ZooKeeperServer - Failed to register with JMX
> 2021-12-17T16:46:16.8809721Z javax.management.InstanceAlreadyExistsException:
> org.apache.ZooKeeperService:name0=StandaloneServer_port-1
> 2021-12-17T16:46:16.8810652Z at
> com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
> 2021-12-17T16:46:16.8811545Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
> 2021-12-17T16:46:16.8812889Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
> 2021-12-17T16:46:16.8814178Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
> 2021-12-17T16:46:16.8815747Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
> 2021-12-17T16:46:16.8816388Z at
> com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
> 2021-12-17T16:46:16.8817061Z at
> org.apache.zookeeper.jmx.MBeanRegistry.register(MBeanRegistry.java:96)
> 2021-12-17T16:46:16.8817651Z at
> org.apache.zookeeper.server.ZooKeeperServer.registerJMX(ZooKeeperServer.java:377)
> 2021-12-17T16:46:16.8818250Z at
> org.apache.zookeeper.server.ZooKeeperServer.startup(ZooKeeperServer.java:410)
> 2021-12-17T16:46:16.8818860Z at
> org.apache.zookeeper.server.NIOServerCnxnFactory.startup(NIOServerCnxnFactory.java:123)
> 2021-12-17T16:46:16.8819509Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils$EmbeddedZookeeper.<init>(KafkaTestUtils.scala:314)
> 2021-12-17T16:46:16.8820202Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setupEmbeddedZookeeper(KafkaTestUtils.scala:97)
> 2021-12-17T16:46:16.8820852Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setup(KafkaTestUtils.scala:130)
> 2021-12-17T16:46:16.8821456Z at
> org.apache.hudi.utilities.sources.TestJsonKafkaSource.setup(TestJsonKafkaSource.java:84)
> 2021-12-17T16:46:16.8822099Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-12-17T16:46:16.8822585Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-12-17T16:46:16.8823122Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-12-17T16:46:16.8823625Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-12-17T16:46:16.8824131Z at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2021-12-17T16:46:16.8824713Z at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2021-12-17T16:46:16.8825353Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2021-12-17T16:46:16.8826211Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2021-12-17T16:46:16.8826841Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:126)
> 2021-12-17T16:46:16.8827469Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeEachMethod(TimeoutExtension.java:76)
> 2021-12-17T16:46:16.8828171Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2021-12-17T16:46:16.8828854Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2021-12-17T16:46:16.8829540Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2021-12-17T16:46:16.8830224Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2021-12-17T16:46:16.8830899Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2021-12-17T16:46:16.8831573Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2021-12-17T16:46:16.8832170Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2021-12-17T16:46:16.8832757Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2021-12-17T16:46:16.8833421Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeMethodInExtensionContext(ClassBasedTestDescriptor.java:481)
> 2021-12-17T16:46:16.8834182Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$synthesizeBeforeEachMethodAdapter$18(ClassBasedTestDescriptor.java:466)
> 2021-12-17T16:46:16.8835007Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeEachMethods$2(TestMethodTestDescriptor.java:169)
> 2021-12-17T16:46:16.8835815Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$5(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:16.8836559Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8837444Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:16.8838220Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachMethods(TestMethodTestDescriptor.java:166)
> 2021-12-17T16:46:16.8838900Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:133)
> 2021-12-17T16:46:16.8839549Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:71)
> 2021-12-17T16:46:16.8840186Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
> 2021-12-17T16:46:16.8840843Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8841503Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:16.8842084Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:16.8842684Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:16.8843344Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8843985Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:16.8844585Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:16.8845095Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:16.8845804Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:16.8846545Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:16.8847200Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8847854Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:16.8848455Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:16.8849042Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:16.8849832Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8850472Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:16.8851064Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:16.8851577Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:16.8852211Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:16.8852962Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:16.8853770Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8854570Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:16.8855221Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:16.8855851Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:16.8856558Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:16.8857243Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:16.8857900Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:16.8858628Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
> 2021-12-17T16:46:16.8862907Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
> 2021-12-17T16:46:16.8863754Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
> 2021-12-17T16:46:16.8868385Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2021-12-17T16:46:16.8869201Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:87)
> 2021-12-17T16:46:16.8869877Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:53)
> 2021-12-17T16:46:16.8870586Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:66)
> 2021-12-17T16:46:16.8871301Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:51)
> 2021-12-17T16:46:16.8871917Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:87)
> 2021-12-17T16:46:16.8872479Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:66)
> 2021-12-17T16:46:16.8873074Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2021-12-17T16:46:16.8873920Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:127)
> 2021-12-17T16:46:16.8874540Z at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:377)
> 2021-12-17T16:46:16.8875082Z at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:138)
> 2021-12-17T16:46:16.8875618Z at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:465)
> 2021-12-17T16:46:16.8876145Z at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:451)
> 2021-12-17T16:46:17.3658534Z 1409547 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:17.3660045Z 1409547 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:17.3661301Z 1409547 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-f386c256-4d1c-4f54-a8de-9b0c66ca22ed
> 2021-12-17T16:46:17.3662639Z 1409547 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:20.0484544Z 1412230 [main] WARN
> org.apache.spark.sql.SparkSession$Builder - Using an existing SparkSession;
> some configuration may not take effect.
> 2021-12-17T16:46:20.4718670Z 1412652 [main] WARN
> org.apache.zookeeper.jmx.MBeanRegistry - Failed to register MBean
> StandaloneServer_port-1
> 2021-12-17T16:46:20.4756134Z 1412652 [main] WARN
> org.apache.zookeeper.server.ZooKeeperServer - Failed to register with JMX
> 2021-12-17T16:46:20.4757189Z javax.management.InstanceAlreadyExistsException:
> org.apache.ZooKeeperService:name0=StandaloneServer_port-1
> 2021-12-17T16:46:20.4759907Z at
> com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
> 2021-12-17T16:46:20.4760728Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
> 2021-12-17T16:46:20.4761579Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
> 2021-12-17T16:46:20.4762363Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
> 2021-12-17T16:46:20.4763156Z at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
> 2021-12-17T16:46:20.4763881Z at
> com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
> 2021-12-17T16:46:20.4764531Z at
> org.apache.zookeeper.jmx.MBeanRegistry.register(MBeanRegistry.java:96)
> 2021-12-17T16:46:20.4765169Z at
> org.apache.zookeeper.server.ZooKeeperServer.registerJMX(ZooKeeperServer.java:377)
> 2021-12-17T16:46:20.4765957Z at
> org.apache.zookeeper.server.ZooKeeperServer.startup(ZooKeeperServer.java:410)
> 2021-12-17T16:46:20.4766559Z at
> org.apache.zookeeper.server.NIOServerCnxnFactory.startup(NIOServerCnxnFactory.java:123)
> 2021-12-17T16:46:20.4767204Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils$EmbeddedZookeeper.<init>(KafkaTestUtils.scala:314)
> 2021-12-17T16:46:20.4767868Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setupEmbeddedZookeeper(KafkaTestUtils.scala:97)
> 2021-12-17T16:46:20.4768495Z at
> org.apache.spark.streaming.kafka010.KafkaTestUtils.setup(KafkaTestUtils.scala:130)
> 2021-12-17T16:46:20.4769096Z at
> org.apache.hudi.utilities.sources.TestJsonKafkaSource.setup(TestJsonKafkaSource.java:84)
> 2021-12-17T16:46:20.4769647Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-12-17T16:46:20.4770168Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-12-17T16:46:20.4770766Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-12-17T16:46:20.4771745Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-12-17T16:46:20.4772386Z at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2021-12-17T16:46:20.4773261Z at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2021-12-17T16:46:20.4774212Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2021-12-17T16:46:20.4774941Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2021-12-17T16:46:20.4775591Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:126)
> 2021-12-17T16:46:20.4776290Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeEachMethod(TimeoutExtension.java:76)
> 2021-12-17T16:46:20.4777047Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2021-12-17T16:46:20.4777801Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2021-12-17T16:46:20.4778525Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2021-12-17T16:46:20.4779285Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2021-12-17T16:46:20.4780009Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2021-12-17T16:46:20.4780707Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2021-12-17T16:46:20.4781371Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2021-12-17T16:46:20.4782006Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2021-12-17T16:46:20.4782826Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeMethodInExtensionContext(ClassBasedTestDescriptor.java:481)
> 2021-12-17T16:46:20.4783639Z at
> org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$synthesizeBeforeEachMethodAdapter$18(ClassBasedTestDescriptor.java:466)
> 2021-12-17T16:46:20.4784467Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeEachMethods$2(TestMethodTestDescriptor.java:169)
> 2021-12-17T16:46:20.4785506Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$5(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:20.4786159Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4786775Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:197)
> 2021-12-17T16:46:20.4787446Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachMethods(TestMethodTestDescriptor.java:166)
> 2021-12-17T16:46:20.4788040Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:133)
> 2021-12-17T16:46:20.4788717Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:71)
> 2021-12-17T16:46:20.4789608Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
> 2021-12-17T16:46:20.4790263Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4790914Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:20.4791495Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:20.4792099Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:20.4792756Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4793440Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:20.4794237Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:20.4794888Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:20.4795498Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:20.4796251Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:20.4796909Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4797684Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:20.4798265Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:20.4798871Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:20.4799525Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4800141Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:20.4800755Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:20.4801267Z at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-12-17T16:46:20.4801900Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-12-17T16:46:20.4802716Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-12-17T16:46:20.4803372Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4804409Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-12-17T16:46:20.4804991Z at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-12-17T16:46:20.4805592Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-12-17T16:46:20.4806249Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-12-17T16:46:20.4806887Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-12-17T16:46:20.4807479Z at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-12-17T16:46:20.4808187Z at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
> 2021-12-17T16:46:20.4808942Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
> 2021-12-17T16:46:20.4809598Z at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
> 2021-12-17T16:46:20.4810259Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2021-12-17T16:46:20.4811092Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:87)
> 2021-12-17T16:46:20.4811773Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:53)
> 2021-12-17T16:46:20.4812456Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:66)
> 2021-12-17T16:46:20.4813148Z at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:51)
> 2021-12-17T16:46:20.4813831Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:87)
> 2021-12-17T16:46:20.4814383Z at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:66)
> 2021-12-17T16:46:20.4815000Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2021-12-17T16:46:20.4815650Z at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:127)
> 2021-12-17T16:46:20.4816259Z at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:377)
> 2021-12-17T16:46:20.4816805Z at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:138)
> 2021-12-17T16:46:20.4817339Z at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:465)
> 2021-12-17T16:46:20.4817872Z at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:451)
> 2021-12-17T16:46:21.0414418Z 1413223 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:21.0415541Z 1413223 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:21.0416545Z 1413223 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-c2bc905c-7db1-4e04-8c4b-72272d8d8da2
> 2021-12-17T16:46:21.0421740Z 1413223 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:21.1548741Z 1413337 [main] WARN
> org.apache.kafka.clients.consumer.ConsumerConfig - The configuration
> 'hoodie.deltastreamer.kafka.source.maxEvents' was supplied but isn't a known
> config.
> 2021-12-17T16:46:21.1550628Z 1413337 [main] WARN
> org.apache.kafka.clients.consumer.ConsumerConfig - The configuration
> 'hoodie.deltastreamer.source.kafka.topic' was supplied but isn't a known
> config.
> 2021-12-17T16:46:21.1559387Z 1413337 [main] WARN
> org.apache.kafka.clients.consumer.ConsumerConfig - The configuration
> 'hoodie.deltastreamer.source.kafka.enable.commit.offset' was supplied but
> isn't a known config.
> 2021-12-17T16:46:21.2689968Z 1413451 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> enable.auto.commit to false for executor
> 2021-12-17T16:46:21.2692346Z 1413451 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> auto.offset.reset to none for executor
> 2021-12-17T16:46:21.2699406Z 1413451 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding executor
> group.id to spark-executor-c2bc905c-7db1-4e04-8c4b-72272d8d8da2
> 2021-12-17T16:46:21.2700701Z 1413451 [main] WARN
> org.apache.spark.streaming.kafka010.KafkaUtils - overriding
> receive.buffer.bytes to 65536 see KAFKA-3135
> 2021-12-17T16:46:23.5574272Z 1415739 [main] WARN
> org.apache.hadoop.hdfs.server.datanode.DirectoryScanner - DirectoryScanner:
> shutdown has been called
> 2021-12-17T16:46:23.6749001Z 1415854 [DataNode:
> [[[DISK]file:/tmp/temp1018508977849153348/dfs/data/data1/,
> [DISK]file:/tmp/temp1018508977849153348/dfs/data/data2/]] heartbeating to
> localhost/127.0.0.1:46745] WARN
> org.apache.hadoop.hdfs.server.datanode.DataNode - BPOfferService for Block
> pool BP-696835616-10.1.0.49-1639759544078 (Datanode Uuid
> 8667f08c-273e-46b0-ab54-1bc798c7af49) service to localhost/127.0.0.1:46745
> interrupted
> 2021-12-17T16:46:23.6753717Z 1415854 [DataNode:
> [[[DISK]file:/tmp/temp1018508977849153348/dfs/data/data1/,
> [DISK]file:/tmp/temp1018508977849153348/dfs/data/data2/]] heartbeating to
> localhost/127.0.0.1:46745] WARN
> org.apache.hadoop.hdfs.server.datanode.DataNode - Ending block pool service
> for: Block pool BP-696835616-10.1.0.49-1639759544078 (Datanode Uuid
> 8667f08c-273e-46b0-ab54-1bc798c7af49) service to localhost/127.0.0.1:46745
> 2021-12-17T16:46:23.9843943Z [ERROR] Tests run: 7, Failures: 0, Errors: 1,
> Skipped: 0, Time elapsed: 39.745 s <<< FAILURE! - in
> org.apache.hudi.utilities.sources.TestJsonKafkaSource
> 2021-12-17T16:46:23.9845548Z [ERROR]
> org.apache.hudi.utilities.sources.TestJsonKafkaSource.testJsonKafkaSourceResetStrategy
> Time elapsed: 15.907 s <<< ERROR!
> 2021-12-17T16:46:23.9846745Z
> org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode
> = Session expired for /brokers/topics/__consumer_offsets {code}
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
