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