georgelza commented on PR #22:
URL:
https://github.com/apache/flink-connector-prometheus/pull/22#issuecomment-2888283804
@darenwkt No luck. does it make sense to to this rather off here...
`Flink SQL> CREATE TABLE hive_catalog.prometheus.PromTable (
> sensorid STRING,
> siteId STRING,
> deviceId STRING,
> measurement BIGINT,
> ts TIMESTAMP(3)
> )
> WITH (
> 'connector' = 'prometheus',
> 'metric.endpoint-url' = 'prometheus:9090/api/v1/write',
> 'metric.name' = 'sensorid',
> 'metric.label.keys' = '[siteId,deviceId]',
> 'metric.sample.key' = 'measurement',
> 'metric.sample.timestamp' = 'ts'
> );
[INFO] Execute statement succeeded.
Flink SQL> INSERT INTO hive_catalog.prometheus.PromTable VALUES ('10221',
'106', '1031', 60, TIMESTAMP '2025-05-15 08:21:00.000');
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not find any factory
for identifier 'prometheus' that implements
'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.
Available factory identifiers are:
blackhole
datagen
filesystem
kafka
paimon
print
python-input-format
upsert-kafka`
--
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...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
