Alibaba-HZY opened a new pull request, #771:
URL: https://github.com/apache/incubator-paimon/pull/771
Purpose
LogStoreTableFactory should not implements DynamicTableFactory.if there is
no kafka jar in flink/lib, the kafka identifier will find KafkaLogStoreFactory
in paimon, and throw KafkaLogStoreFactory is not a DynamicTableSourceFactory
exception, which is very confused.so we define the PaimonFactory
,LogStoreTableFactory implements it.
if there is no kafka jar in flink/lib, it will throw
org.apache.flink.table.api.ValidationException: Could not find any factory for
identifier 'kafka' that implements
'org.apache.flink.table.factories.DynamicTableFactory' in the classpath
Fix #705
Tests
LogSystemITCase
API and Format
Documentation
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
