[ https://issues.apache.org/jira/browse/HUDI-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Raymond Xu closed HUDI-3052. ---------------------------- Resolution: Fixed > Flaky TestJsonKafkaSource in CI runs > ------------------------------------- > > Key: HUDI-3052 > URL: https://issues.apache.org/jira/browse/HUDI-3052 > Project: Apache Hudi > Issue Type: Sub-task > Components: Testing > Reporter: sivabalan narayanan > Assignee: Raymond Xu > Priority: Major > Labels: pull-request-available, sev:critical > > 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)