flink1.16 sql gateway hive2

2023-03-25 文章 guanyq
本地启动了flink及hive在启动sql gateway时有以下异常,请问还需要其他什么操作么
./bin/sql-gateway.sh start-foreground -Dsql-gateway.endpoint.type=hiveserver2 
-Dsql-gateway.endpoint.hiveserver2.catalog.hive-conf-dir=/usr/local/app/apache-hive-3.1.2-bin/conf


异常信息

Available factory identifiers are:
rest
at 
org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:545)
 ~[flink-table-api-java-uber-1.16.0.jar:1.16.0]
at 
org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactoryUtils.createSqlGatewayEndpoint(SqlGatewayEndpointFactoryUtils.java:65)
 ~[flink-table-api-java-uber-1.16.0.jar:1.16.0]
at org.apache.flink.table.gateway.SqlGateway.start(SqlGateway.java:72) 
[flink-sql-gateway-1.16.0.jar:1.16.0]
at 
org.apache.flink.table.gateway.SqlGateway.startSqlGateway(SqlGateway.java:118) 
[flink-sql-gateway-1.16.0.jar:1.16.0]
at org.apache.flink.table.gateway.SqlGateway.main(SqlGateway.java:98) 
[flink-sql-gateway-1.16.0.jar:1.16.0]
Exception in thread "main" 
org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to start 
the endpoints.
at org.apache.flink.table.gateway.SqlGateway.start(SqlGateway.java:79)
at 
org.apache.flink.table.gateway.SqlGateway.startSqlGateway(SqlGateway.java:118)
at org.apache.flink.table.gateway.SqlGateway.main(SqlGateway.java:98)
Caused by: org.apache.flink.table.api.ValidationException: Could not find any 
factory for identifier 'hiveserver2' that implements 
'SqlGatewayEndpointFactory' in the classpath.
Available factory identifiers are:
rest
at 
org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:545)
at 
org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactoryUtils.createSqlGatewayEndpoint(SqlGatewayEndpointFactoryUtils.java:65)
at org.apache.flink.table.gateway.SqlGateway.start(SqlGateway.java:72)
... 2 more



Re: 项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 后启动报解析配置异常

2023-03-25 文章 Leonard Xu
flink-sql-connector-xx 都是uber jar, 不应该在项目中直接uber jar,你在项目中应该引入 
flink-connector-xx 依赖并自己管理。


Best,
Leonard

> On Mar 25, 2023, at 3:25 PM, casel.chen  wrote:
> 
> 项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 
> 后启动过程中报如下异常,查了一下该jar下有oracle.xml.jaxp.JXDocumentBuilderFactory类,有什么办法解决么?
> 
> 
> ERROR StatusLogger Caught javax.xml.parsers.ParserConfigurationException 
> setting feature http://xml.org/sax/features/external-general-entities to 
> false on DocumentBuilderFactory 
> oracle.xml.jaxp.JXDocumentBuilderFactory@68dc098b: 
> javax.xml.parsers.ParserConfigurationException
> javax.xml.parsers.ParserConfigurationException
> at 
> oracle.xml.jaxp.JXDocumentBuilderFactory.setFeature(JXDocumentBuilderFactory.java:374)
> at 
> org.apache.logging.log4j.core.config.xml.XmlConfiguration.setFeature(XmlConfiguration.java:204)
> at 
> org.apache.logging.log4j.core.config.xml.XmlConfiguration.disableDtdProcessing(XmlConfiguration.java:197)
> at 
> org.apache.logging.log4j.core.config.xml.XmlConfiguration.newDocumentBuilder(XmlConfiguration.java:186)
> at 
> org.apache.logging.log4j.core.config.xml.XmlConfiguration.(XmlConfiguration.java:89)
> at 
> org.apache.logging.log4j.core.config.xml.XmlConfigurationFactory.getConfiguration(XmlConfigurationFactory.java:46)
> at 
> org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:558)
> at 
> org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:482)
> at 
> org.apache.logging.log4j.core.config.ConfigurationFactory.getConfiguration(ConfigurationFactory.java:322)
> at 
> org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:695)
> 



Re: [ANNOUNCE] Apache Flink 1.17.0 released

2023-03-25 文章 Hang Ruan
Thanks for the great work ! Congrats all!

Best,
Hang

Panagiotis Garefalakis  于2023年3月25日周六 03:22写道:

> Congrats all! Well done!
>
> Cheers,
> Panagiotis
>
> On Fri, Mar 24, 2023 at 2:46 AM Qingsheng Ren  wrote:
>
> > I'd like to say thank you to all contributors of Flink 1.17. Your support
> > and great work together make this giant step forward!
> >
> > Also like Matthias mentioned, feel free to leave us any suggestions and
> > let's improve the releasing procedure together.
> >
> > Cheers,
> > Qingsheng
> >
> > On Fri, Mar 24, 2023 at 5:00 PM Etienne Chauchot 
> > wrote:
> >
> >> Congrats to all the people involved!
> >>
> >> Best
> >>
> >> Etienne
> >>
> >> Le 23/03/2023 à 10:19, Leonard Xu a écrit :
> >> > The Apache Flink community is very happy to announce the release of
> >> Apache Flink 1.17.0, which is the first release for the Apache Flink
> 1.17
> >> series.
> >> >
> >> > Apache Flink® is an open-source unified stream and batch data
> >> processing framework for distributed, high-performing, always-available,
> >> and accurate data applications.
> >> >
> >> > The release is available for download at:
> >> > https://flink.apache.org/downloads.html
> >> >
> >> > Please check out the release blog post for an overview of the
> >> improvements for this release:
> >> >
> >>
> https://flink.apache.org/2023/03/23/announcing-the-release-of-apache-flink-1.17/
> >> >
> >> > The full release notes are available in Jira:
> >> >
> >>
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351585
> >> >
> >> > We would like to thank all contributors of the Apache Flink community
> >> who made this release possible!
> >> >
> >> > Best regards,
> >> > Qingsheng, Martijn, Matthias and Leonard
> >>
> >
>


项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 后启动报解析配置异常

2023-03-25 文章 casel.chen
项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 
后启动过程中报如下异常,查了一下该jar下有oracle.xml.jaxp.JXDocumentBuilderFactory类,有什么办法解决么?


ERROR StatusLogger Caught javax.xml.parsers.ParserConfigurationException 
setting feature http://xml.org/sax/features/external-general-entities to false 
on DocumentBuilderFactory oracle.xml.jaxp.JXDocumentBuilderFactory@68dc098b: 
javax.xml.parsers.ParserConfigurationException
 javax.xml.parsers.ParserConfigurationException
at 
oracle.xml.jaxp.JXDocumentBuilderFactory.setFeature(JXDocumentBuilderFactory.java:374)
at 
org.apache.logging.log4j.core.config.xml.XmlConfiguration.setFeature(XmlConfiguration.java:204)
at 
org.apache.logging.log4j.core.config.xml.XmlConfiguration.disableDtdProcessing(XmlConfiguration.java:197)
at 
org.apache.logging.log4j.core.config.xml.XmlConfiguration.newDocumentBuilder(XmlConfiguration.java:186)
at 
org.apache.logging.log4j.core.config.xml.XmlConfiguration.(XmlConfiguration.java:89)
at 
org.apache.logging.log4j.core.config.xml.XmlConfigurationFactory.getConfiguration(XmlConfigurationFactory.java:46)
at 
org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:558)
at 
org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:482)
at 
org.apache.logging.log4j.core.config.ConfigurationFactory.getConfiguration(ConfigurationFactory.java:322)
at 
org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:695)