[HUDI-3052] Flaky TestJsonKafkaSource in CI runs - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Task
Status: Closed
Priority: Major
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 0.10.1
Component/s: Testing, tests-ci
Labels:
- pull-request-available
- sev:critical

Epic Link:
CI Flakiness 2021-12

Description

TestJsonKafkaSource.testJsonKafkaSourceResetStrategy

Reference: https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_apis/build/builds/4441/logs/26

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

Attachments

Issue Links

links to

GitHub Pull Request #4381

GitHub Pull Request #4382

Activity

People

Assignee:: Raymond Xu

Reporter:: sivabalan narayanan

Votes:: 0 Vote for this issue

Watchers:: 1 Start watching this issue

Dates

Created:: 17/Dec/21 17:30

Updated:: 27/Mar/22 15:00

Resolved:: 19/Dec/21 04:47