Hi,
I have *flink 1.19 *installation and start *sql-client locally*, like this:
*./bin/sql-client.sh*
then execute *SET 'table.sql-dialect' = 'hive'*;
and have this exception:
*[ERROR] Could not execute SQL statement.
Reason:java.lang.ClassNotFoundException: org.antlr.runtime.tree.Tree*
I'm pretty sure that* i do have antlr in classpath*, because i found it
there using `ps` command (see text in *bold*):
ps -Af | grep java | grep client | grep antlr
501 1131 993 0 11:30PM ttys000 0:03.27 java
-XX:+IgnoreUnrecognizedVMOptions
--add-exports=java.base/sun.net.util=ALL-UNNAMED
--add-exports=java.rmi/sun.rmi.registry=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED
--add-exports=java.security.jgss/sun.security.krb5=ALL-UNNAMED
--add-opens=java.base/java.lang=ALL-UNNAMED
--add-opens=java.base/java.net=ALL-UNNAMED
--add-opens=java.base/java.io=ALL-UNNAMED
--add-opens=java.base/java.nio=ALL-UNNAMED
--add-opens=java.base/sun.nio.ch=ALL-UNNAMED
--add-opens=java.base/java.lang.reflect=ALL-UNNAMED
--add-opens=java.base/java.text=ALL-UNNAMED
--add-opens=java.base/java.time=ALL-UNNAMED
--add-opens=java.base/java.util=ALL-UNNAMED
--add-opens=java.base/java.util.concurrent=ALL-UNNAMED
--add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED
--add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED
-Dlog.file=/Users/ilyakarpov/Downloads/flink-1.19.0/log/flink-ilyakarpov-sql-client-192.168.1.8.log
-Dlog4j.configuration=file:/Users/ilyakarpov/Downloads/flink-1.19.0/conf/log4j-cli.properties
-Dlog4j.configurationFile=file:/Users/ilyakarpov/Downloads/flink-1.19.0/conf/log4j-cli.properties
-Dlogback.configurationFile=file:/Users/ilyakarpov/Downloads/flink-1.19.0/conf/logback.xml
-classpath
*/Users/ilyakarpov/Downloads/flink-1.19.0/lib/antlr-runtime-3.5.2.jar*:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-cep-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-connector-files-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-connector-hive_2.12-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-csv-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-json-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-scala_2.12-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-table-api-java-uber-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-table-planner-loader-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-table-runtime-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/hive-exec-3.1.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/libfb303-0.9.3.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/log4j-1.2-api-2.17.1.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/log4j-api-2.17.1.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/log4j-core-2.17.1.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/log4j-slf4j-impl-2.17.1.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/lib/flink-dist-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/opt/flink-python-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/opt/flink-sql-gateway-1.19.0.jar:/Users/ilyakarpov/Downloads/flink-1.19.0/opt/flink-sql-client-1.19.0.jar:::
org.apache.flink.table.client.SqlClient --jar
/Users/ilyakarpov/Downloads/flink-1.19.0/opt/flink-sql-client-1.19.0.jar
i double checked my lib folder:
ll ~/Downloads/flink-1.19.0/lib
total 502784
drwxr-xr-x@ 19 ilyakarpov staff 608 Apr 21 23:09 .
drwxr-xr-x@ 13 ilyakarpov staff 416 Mar 7 08:49 ..
*-rw-r--r--@ 1 ilyakarpov staff 167761 Apr 21 23:06
antlr-runtime-3.5.2.jar*
-rw-r--r--@ 1 ilyakarpov staff 198148 Mar 7 08:35
flink-cep-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 558298 Mar 7 08:38
flink-connector-files-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 8945307 Apr 21 23:05
flink-connector-hive_2.12-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 102375 Mar 7 08:42
flink-csv-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 125658127 Mar 7 08:49
flink-dist-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 202905 Mar 7 08:42
flink-json-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 21060379 Mar 7 08:47
flink-scala_2.12-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 15621700 Mar 7 08:48
flink-table-api-java-uber-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 38130033 Mar 7 08:47
flink-table-planner-loader-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 3514238 Mar 7 08:36
flink-table-runtime-1.19.0.jar
-rw-r--r--@ 1 ilyakarpov staff 40603464 Apr 21 23:09 hive-exec-3.1.0.jar
-rw-r--r--@ 1 ilyakarpov staff 313702 Apr 21 23:08 libfb303-0.9.3.jar
-rw-r--r--@ 1 ilyakarpov staff 208006 Mar 4 18:46
log4j-1.2-api-2.17.1.jar
-rw-r--r--@ 1 ilyakarpov staff 301872 Mar 4 18:46
log4j-api-2.17.1.jar
-rw-r--r--@ 1 ilyakarpov staff 1790452 Mar 4 18:46
log4j-core-2.17.1.jar
-rw-r--r--@ 1 ilyakarpov staff 24279 Mar 4 18:46
log4j-slf4j-impl-2.17.1.jar
I looked inside *antlr-runtime-3.5.2 * and found that class:
unzip -l lib/antlr-runtime-3.5.2.jar | grep Tree.class
1674 03-25-2014 07:04
org/antlr/runtime/debug/RemoteDebugEventSocketListener$ProxyTree.class
7427 03-25-2014 07:04 org/antlr/runtime/tree/BaseTree.class
3380 03-25-2014 07:04 org/antlr/runtime/tree/CommonTree.class
2502 03-25-2014 07:04 org/antlr/runtime/tree/ParseTree.class
* 1346 03-25-2014 07:04 org/antlr/runtime/tree/Tree.class*
So I guess I'm having some classloading issue, but can't find what it is.
I've even* tried to switch classloading order from child to parent first* -
no luck.
Some logs:
2024-04-21 23:38:16,273 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Using standard YAML
parser to load flink configuration file from
/Users/ilyakarpov/Downloads/flink-1.19.0/conf/config.yaml.
2024-04-21 23:38:16,290 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.memory.process.size, 1728m
2024-04-21 23:38:16,290 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.bind-host, localhost
2024-04-21 23:38:16,290 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.execution.failover-strategy, region
2024-04-21 23:38:16,290 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.rpc.address, localhost
2024-04-21 23:38:16,290 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.memory.process.size, 1600m
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.rpc.port, 6123
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: rest.bind-address, localhost
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.bind-host, localhost
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.host, localhost
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: parallelism.default, 1
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: rest.address, localhost
2024-04-21 23:38:16,291 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: env.java.opts.all, --add-exports=java.base/sun.
net.util=ALL-UNNAMED --add-exports=java.rmi/sun.rmi.registry=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED
--add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED
--add-exports=java.security.jgss/sun.security.krb5=ALL-UNNAMED
--add-opens=java.base/java.lang=ALL-UNNAMED
--add-opens=java.base/java.net=ALL-UNNAMED
--add-opens=java.base/java.io=ALL-UNNAMED
--add-opens=java.base/java.nio=ALL-UNNAMED
--add-opens=java.base/sun.nio.ch=ALL-UNNAMED
--add-opens=java.base/java.lang.reflect=ALL-UNNAMED
--add-opens=java.base/java.text=ALL-UNNAMED
--add-opens=java.base/java.time=ALL-UNNAMED
--add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.base/java.
util.concurrent=ALL-UNNAMED --add-opens=java.base/java.
util.concurrent.atomic=ALL-UNNAMED --add-opens=java.base/java.
util.concurrent.locks=ALL-UNNAMED
2024-04-21 23:38:16,299 INFO org.apache.flink.client.cli.CliFrontend [] -
Loading FallbackYarnSessionCli
2024-04-21 23:38:16,308 INFO org.apache.flink.core.fs.FileSystem [] -
Hadoop is not in the classpath/dependencies. The extended set of supported
File Systems via Hadoop is not available.
2024-04-21 23:38:16,314 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-statsd
2024-04-21 23:38:16,315 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-prometheus
2024-04-21 23:38:16,315 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-graphite
2024-04-21 23:38:16,316 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: external-resource-gpu
2024-04-21 23:38:16,316 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-jmx
2024-04-21 23:38:16,316 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-influx
2024-04-21 23:38:16,316 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-slf4j
2024-04-21 23:38:16,316 INFO
org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with
ID not found, creating it: metrics-datadog
2024-04-21 23:38:16,326 INFO
org.apache.flink.table.gateway.service.context.DefaultContext [] -
Execution config: {execution.savepoint.ignore-unclaimed-state=false,
execution.attached=true, execution.savepoint-restore-mode=NO_CLAIM,
execution.shutdown-on-attached-exit=false, pipeline.jars
=[file:/Users/ilyakarpov/Downloads/flink-1.19.0/opt/flink-
sql-client-1.19.0.jar], pipeline.classpaths=[], execution.target=remote}
2024-04-21 23:38:16,519 INFO org.apache.flink.configuration.Configuration
[] - Config uses fallback configuration key 'rest.port' instead of key
'rest.bind-port'
2024-04-21 23:38:16,530 INFO
org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Starting
rest endpoint.
2024-04-21 23:38:16,625 INFO
org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Rest
endpoint listening at localhost:49826
2024-04-21 23:38:16,625 INFO org.apache.flink.table.client.SqlClient [] -
Start embedded gateway on port 49826
2024-04-21 23:38:16,687 INFO
org.apache.flink.table.client.gateway.ExecutorImpl [] - Open session to
http://localhost:49826 with connection version: V2.
2024-04-21 23:38:16,799 INFO org.apache.flink.table.client.cli.CliClient []
- Command history file path: /Users/ilyakarpov/.flink-sql-history
2024-04-21 23:38:18,292 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlCreateCatalog does not contain a setter
for field catalogName
2024-04-21 23:38:18,292 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlCreateCatalog cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,292 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlCreateView does not contain a setter for
field viewName
2024-04-21 23:38:18,293 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlCreateView cannot be used as a POJO type
because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,293 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlAlterViewRename does not contain a
getter for field newViewIdentifier
2024-04-21 23:38:18,293 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlAlterViewRename does not contain a
setter for field newViewIdentifier
2024-04-21 23:38:18,293 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlAlterViewRename cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,293 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlAlterViewProperties does not contain a
setter for field propertyList
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlAlterViewProperties cannot be used as a
POJO type because not all fields are valid POJO fields, and must be
processed as GenericType. Please read the Flink documentation on "Data
Types & Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlAlterViewAs does not contain a setter
for field newQuery
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlAlterViewAs cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlAddPartitions does not contain a setter
for field ifPartitionNotExists
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlAddPartitions cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlDropPartitions does not contain a setter
for field ifExists
2024-04-21 23:38:18,294 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlDropPartitions cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dql.SqlShowPartitions does not contain a getter
for field tableIdentifier
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dql.SqlShowPartitions does not contain a setter
for field tableIdentifier
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.dql.SqlShowPartitions cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dml.SqlTruncateTable does not contain a getter
for field tableNameIdentifier
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dml.SqlTruncateTable does not contain a setter
for field tableNameIdentifier
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.dml.SqlTruncateTable cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dql.SqlShowFunctions does not contain a setter
for field requireUser
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.dql.SqlShowFunctions cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dql.SqlShowProcedures does not contain a getter
for field databaseName
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dql.SqlShowProcedures does not contain a setter
for field databaseName
2024-04-21 23:38:18,295 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.dql.SqlShowProcedures cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,296 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.ddl.SqlReplaceTableAs does not contain a setter
for field tableName
2024-04-21 23:38:18,296 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.ddl.SqlReplaceTableAs cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,296 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - class
org.apache.flink.sql.parser.dql.SqlShowDatabases does not contain a setter
for field preposition
2024-04-21 23:38:18,296 INFO
org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class
org.apache.flink.sql.parser.dql.SqlShowDatabases cannot be used as a POJO
type because not all fields are valid POJO fields, and must be processed as
GenericType. Please read the Flink documentation on "Data Types &
Serialization" for details of the effect on performance and schema
evolution.
2024-04-21 23:38:18,304 ERROR
org.apache.flink.table.gateway.service.operation.OperationManager [] -
Failed to execute the operation 768f5aca-e0f9-4d88-a788-aba7b03aae24.
java.lang.NoClassDefFoundError: org/antlr/runtime/tree/Tree
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:52)
~[flink-connector-hive_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:165)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1261)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:196)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.<init>(AbstractStreamTableEnvironmentImpl.java:89)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:93)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.createStreamTableEnvironment(OperationExecutor.java:430)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:370)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:346)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.context.SessionContext.set(SessionContext.java:170)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callSetOperation(OperationExecutor.java:525)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:453)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.ClassNotFoundException: org.antlr.runtime.tree.Tree
at java.net.URLClassLoader.findClass(URLClassLoader.java:445) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:587) ~[?:?]
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:150)
~[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:113)
~[flink-dist-1.19.0.jar:1.19.0]
at java.lang.ClassLoader.loadClass(ClassLoader.java:520) ~[?:?]
... 23 more
2024-04-21 23:38:18,383 ERROR
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl [] - Failed to
fetchResults.
org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed
to execute the operation 768f5aca-e0f9-4d88-a788-aba7b03aae24.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.NoClassDefFoundError: org/antlr/runtime/tree/Tree
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:52)
~[flink-connector-hive_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:165)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1261)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:196)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.<init>(AbstractStreamTableEnvironmentImpl.java:89)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:93)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.createStreamTableEnvironment(OperationExecutor.java:430)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:370)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:346)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.context.SessionContext.set(SessionContext.java:170)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callSetOperation(OperationExecutor.java:525)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:453)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
... 7 more
Caused by: java.lang.ClassNotFoundException: org.antlr.runtime.tree.Tree
at java.net.URLClassLoader.findClass(URLClassLoader.java:445) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:587) ~[?:?]
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:150)
~[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:113)
~[flink-dist-1.19.0.jar:1.19.0]
at java.lang.ClassLoader.loadClass(ClassLoader.java:520) ~[?:?]
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:52)
~[flink-connector-hive_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:165)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1261)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:196)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.<init>(AbstractStreamTableEnvironmentImpl.java:89)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:93)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.createStreamTableEnvironment(OperationExecutor.java:430)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:370)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:346)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.context.SessionContext.set(SessionContext.java:170)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callSetOperation(OperationExecutor.java:525)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:453)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
... 7 more
2024-04-21 23:38:18,385 ERROR
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler
[] - Unhandled exception.
org.apache.flink.table.gateway.api.utils.SqlGatewayException:
org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to
fetchResults.
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:91)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:84)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:52)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:196)
~[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:88)
~[flink-dist-1.19.0.jar:1.19.0]
at java.util.Optional.ifPresent(Optional.java:178) [?:?]
at
org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:85)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:50)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:208)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:69)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[flink-dist-1.19.0.jar:1.19.0]
at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException:
Failed to fetchResults.
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:89)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
... 48 more
Caused by:
org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed
to execute the operation 768f5aca-e0f9-4d88-a788-aba7b03aae24.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
... 1 more
Caused by: java.lang.NoClassDefFoundError: org/antlr/runtime/tree/Tree
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:52)
~[flink-connector-hive_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:165)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1261)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:196)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.<init>(AbstractStreamTableEnvironmentImpl.java:89)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:93)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.createStreamTableEnvironment(OperationExecutor.java:430)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:370)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:346)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.context.SessionContext.set(SessionContext.java:170)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callSetOperation(OperationExecutor.java:525)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:453)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
... 1 more
Caused by: java.lang.ClassNotFoundException: org.antlr.runtime.tree.Tree
at java.net.URLClassLoader.findClass(URLClassLoader.java:445) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:587) ~[?:?]
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:150)
~[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:113)
~[flink-dist-1.19.0.jar:1.19.0]
at java.lang.ClassLoader.loadClass(ClassLoader.java:520) ~[?:?]
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:52)
~[flink-connector-hive_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:165)
~[?:?]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1261)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:196)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.<init>(AbstractStreamTableEnvironmentImpl.java:89)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:93)
~[flink-table-api-java-uber-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.createStreamTableEnvironment(OperationExecutor.java:430)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:370)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:346)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.context.SessionContext.set(SessionContext.java:170)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callSetOperation(OperationExecutor.java:525)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:453)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
~[flink-sql-gateway-1.19.0.jar:1.19.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
... 1 more
2024-04-21 23:38:18,403 WARN org.apache.flink.table.client.cli.CliClient []
- Could not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Failed to get
response for the operation 768f5aca-e0f9-4d88-a788-aba7b03aae24.
at
org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:489)
~[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.gateway.ExecutorImpl.fetchUtilResultsReady(ExecutorImpl.java:449)
~[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.gateway.ExecutorImpl.executeStatement(ExecutorImpl.java:310)
~[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.cli.parser.SqlMultiLineParser.parse(SqlMultiLineParser.java:114)
~[flink-sql-client-1.19.0.jar:1.19.0]
at
org.jline.reader.impl.LineReaderImpl.acceptLine(LineReaderImpl.java:2964)
~[flink-sql-client-1.19.0.jar:1.19.0]
at org.jline.reader.impl.LineReaderImpl$1.apply(LineReaderImpl.java:3778)
~[flink-sql-client-1.19.0.jar:1.19.0]
at org.jline.reader.impl.LineReaderImpl.readLine(LineReaderImpl.java:679)
~[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.cli.CliClient.getAndExecuteStatements(CliClient.java:194)
[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:179)
[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:121)
[flink-sql-client-1.19.0.jar:1.19.0]
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:114)
[flink-sql-client-1.19.0.jar:1.19.0]
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:169)
[flink-sql-client-1.19.0.jar:1.19.0]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:118)
[flink-sql-client-1.19.0.jar:1.19.0]
at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:228)
[flink-sql-client-1.19.0.jar:1.19.0]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:179)
[flink-sql-client-1.19.0.jar:1.19.0]
Caused by: org.apache.flink.runtime.rest.util.RestClientException:
[Internal server error., <Exception on server side:
org.apache.flink.table.gateway.api.utils.SqlGatewayException:
org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to
fetchResults.
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:91)
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:84)
at
org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:52)
at
org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:196)
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:88)
at java.base/java.util.Optional.ifPresent(Optional.java:178)
at
org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:85)
at
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:50)
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)
at
org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:208)
at
org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:69)
at
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
at
org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
at
org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at
org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException:
Failed to fetchResults.
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229)
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:89)
... 48 more
Caused by:
org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed
to execute the operation 768f5aca-e0f9-4d88-a788-aba7b03aae24.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
... 1 more
Caused by: java.lang.NoClassDefFoundError: org/antlr/runtime/tree/Tree
at
org.apache.flink.table.planner.delegation.hive.HiveParserFactory.create(HiveParserFactory.java:52)
at
org.apache.flink.table.planner.delegation.PlannerBase.getParser(PlannerBase.scala:165)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.getParser(TableEnvironmentImpl.java:1261)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.<init>(TableEnvironmentImpl.java:196)
at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.<init>(AbstractStreamTableEnvironmentImpl.java:89)
at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.<init>(StreamTableEnvironmentImpl.java:93)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.createStreamTableEnvironment(OperationExecutor.java:430)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:370)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.getTableEnvironment(OperationExecutor.java:346)
at
org.apache.flink.table.gateway.service.context.SessionContext.set(SessionContext.java:170)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.callSetOperation(OperationExecutor.java:525)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:453)
at
org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:234)
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
at
org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
... 7 more
Caused by: java.lang.ClassNotFoundException: org.antlr.runtime.tree.Tree
at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:445)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:587)
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:150)
at
org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:113)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
... 23 more
End of exception on server side>]
at
org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:644)
~[flink-dist-1.19.0.jar:1.19.0]
at
org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:628)
~[flink-dist-1.19.0.jar:1.19.0]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150)
~[?:?]
at
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at java.lang.Thread.run(Thread.java:833) ~[?:?]
2024-04-21 23:38:20,323 INFO
org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Shutting
down rest endpoint.
2024-04-21 23:38:20,327 INFO
org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Shut down
complete.
2024-04-21 23:38:21,327 INFO
org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Shutting
down rest endpoint.
Can anyone say what I'm doing wrong?
