[
https://issues.apache.org/jira/browse/HUDI-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen closed HUDI-7803.
----------------------------
Reviewers: Y Ethan Guo
Resolution: Fixed
Fixed via master branch: 877387fdb95d531ed189cf796c7d5280811b7289
> Fix bundle validation on Flink 1.18
> -----------------------------------
>
> Key: HUDI-7803
> URL: https://issues.apache.org/jira/browse/HUDI-7803
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Ethan Guo (this is the old account; please use "yihua")
> Assignee: Danny Chen
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.0.2
>
>
> For Flink 1.18 when the bundle validation is enabled
> (https://github.com/apache/hudi/pull/11142#discussion_r1615718745), we're
> seeing this error
> {code:java}
> SLF4J: Class path contains multiple SLF4J bindings.
> 2385SLF4J: Found binding in
> [jar:file:/opt/bundle-validation/flink-1.18.0/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> 2386SLF4J: Found binding in
> [jar:file:/opt/bundle-validation/hadoop-3.3.5/share/hadoop/common/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> 2387SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an
> explanation.
> 2388SLF4J: Actual binding is of type
> [org.apache.logging.slf4j.Log4jLoggerFactory]
> 2389May 27, 2024 12:11:29 AM org.jline.utils.Log logr
> 2390WARNING: Unable to create a system terminal, creating a dumb terminal
> (enable debug logging for more information)
> 2391[INFO] Executing SQL from file.
> 2392
> 2393Command history file path: /root/.flink-sql-history
> 2394Flink SQL> /*
> 2395> * Licensed to the Apache Software Foundation (ASF) under one
> 2396> * or more contributor license agreements. See the NOTICE file
> 2397> * distributed with this work for additional information
> 2398> * regarding copyright ownership. The ASF licenses this file
> 2399> * to you under the Apache License, Version 2.0 (the
> 2400> * "License"); you may not use this file except in compliance
> 2401> * with the License. You may obtain a copy of the License at
> 2402> *
> 2403> * http://www.apache.org/licenses/LICENSE-2.0
> 2404> *
> 2405> * Unless required by applicable law or agreed to in writing,
> 2406> * software distributed under the License is distributed on an
> 2407> * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
> 2408> * KIND, either express or implied. See the License for the
> 2409> * specific language governing permissions and limitations
> 2410> * under the License.
> 2411> */
> 2412>
> 2413> CREATE TABLE t1
> 2414> (
> 2415> uuid VARCHAR(20) PRIMARY KEY NOT ENFORCED,
> 2416> name VARCHAR(10),
> 2417> age INT,
> 2418> ts TIMESTAMP(3),
> 2419> `partition` VARCHAR(20)
> 2420> ) PARTITIONED BY (`partition`)
> 2421> WITH (
> 2422> 'connector' = 'hudi',
> 2423> 'table.type' = 'MERGE_ON_READ',
> 2424> 'metadata.enabled' = 'false', -- avoid classloader issue, class HFile
> can not be found
> 2425> 'path' = '/tmp/hudi-flink-bundle-test'
> 2426> )
> 2427
> 2428Error: Exception in thread "main"
> org.apache.flink.table.client.SqlClientException: Unexpected exception. This
> is a bug. Please consider filing an issue.
> 2429 at
> org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:242)
> 2430 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:179)
> 2431Caused by: java.lang.NoClassDefFoundError: Could not initialize class
> org.apache.flink.table.client.config.SqlClientOptions
> 2432 at
> org.apache.flink.table.client.cli.CliClient.printExecutionException(CliClient.java:277)
> 2433 at
> org.apache.flink.table.client.cli.CliClient.executeFile(CliClient.java:245)
> 2434 at
> org.apache.flink.table.client.cli.CliClient.executeInNonInteractiveMode(CliClient.java:131)
> 2435 at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:171)
> 2436 at org.apache.flink.table.client.SqlClient.start(SqlClient.java:118)
> 2437 at
> org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:228)
> 2438 ... 1 more {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
