![]() ![]() ![]() Senior Wireless Operator Aboard The RMS Titanic config(".default-database", "mydatabase")Ĭom.: Issue while inserting csv data into the tableĪt .(ETLCSVExtract.java:107)Īt .(OverwriteByKeyTest2.java:276)Īt java.base/.invoke0(Native Method)Īt java.base/.invoke(NativeMethodAccessorImpl.java:62)Īt java.base/.invoke(DelegatingMethodAccessorImpl.java:43)Īt java.base/.invoke(Method.java:566)Īt .(ReflectionUtils.java:725)Īt .(MethodInvocation.java:60)Īt .execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)Īt .(TimeoutExtension.java:149)Īt .(TimeoutExtension.java:140)Īt .(TimeoutExtension.java:84)Īt .execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)Īt .$invoke$0(ExecutableInvoker.java:105)Īt .execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)Īt .(InvocationInterceptorChain.java:64)Īt .(InvocationInterceptorChain.java:45)Īt .(InvocationInterceptorChain.java:37)Īt .(ExecutableInvoker.java:104)Īt .(ExecutableInvoker.java:98)Īt .$invokeTestMethod$7(TestMethodTestDescriptor.java:214)Īt .(ThrowableCollector.java:73)Īt .(TestMethodTestDescriptor.java:210)Īt .(TestMethodTestDescriptor.java:135)Īt .(TestMethodTestDescriptor.java:66)Īt .$executeRecursively$6(NodeTestTask.java:151)Īt .$executeRecursively$8(NodeTestTask.java:141)Īt .(Node.java:137)Īt .$executeRecursively$9(NodeTestTask.java:139)Īt .(NodeTestTask.java:138)Īt .(NodeTestTask.java:95)Īt java.base/(ArrayList.java:1541)Īt .(SameThreadHierarchicalTestExecutorService.java:41)Īt .$executeRecursively$6(NodeTestTask.java:155)Īt .(SameThreadHierarchicalTestExecutorService.java:35)Īt .(HierarchicalTestExecutor.java:57)Īt .(HierarchicalTestEngine.java:54)Īt .(EngineExecutionOrchestrator.java:107)Īt .(EngineExecutionOrchestrator.java:88)Īt .$execute$0(EngineExecutionOrchestrator.java:54)Īt .(EngineExecutionOrchestrator.java:67)Īt .(EngineExecutionOrchestrator.java:52)Īt .(DefaultLauncher.java:114)Īt .(DefaultLauncher.java:86)Īt .core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)Īt .(SessionPerRequestLauncher.java:53)Īt 5IdeaTestRunner.startRunnerWithArgs(JUnit5IdeaTestRunner.java:71)Īt .junit.IdeaTestRunner$Repeater$1.execute(IdeaTestRunner.java:38)Īt .(TestsRepeater.java:11)Īt .junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:35)Īt .(JUnitStarter.java:235)Īt .(JUnitStarter.java:54)Ĭaused by: .UncheckedSQLException: Cannot initialize JDBC catalogĪt .JdbcCatalog.initialize(JdbcCatalog.java:112)Īt .loadCatalog(CatalogUtil.java:237)Īt .buildIcebergCatalog(CatalogUtil.java:282)Īt .SparkCatalog.buildIcebergCatalog(SparkCatalog.java:129)Īt .SparkCatalog.initialize(SparkCatalog.java:519)Īt .$.load(Catalogs.scala:60)Īt .$anonfun$catalog$1(CatalogManager.scala:53)Īt .getOrElseUpdate(HashMap.scala:86)Īt .(CatalogManager.scala:53)Īt .(CatalogManager.scala:122)Īt .(CatalogManager.scala:93)Īt .(finishAnalysis.scala:109)Īt .(finishAnalysis.scala:106)Īt .$FinishAnalysis$.North Atlantic Ocean (either onboard or near the site of the sinking of the RMS Titanic (111 Years Ago) config(".url", "MY JDBC H2 URI that is used wuth iceberg JDBCATALOG") config("", ".extensions.IcebergSparkSessionExtensions") I have set the configuration properties for spark session to use. When I create a spark session in the same class, it is unable to use the JdbcCatalog already created using iceberg API, it either sets up its own catalog or errors out initializing JdbcCatalog saying ICEBERG_TABLES exists ( which is expected as iceberg jdbc catalog already would have the meta tables ) It is able to create iceberg tables with proper schema and partition spec. I have a JdbcCatalog initialized with H2 database in my local java code.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |