Hello
I wanted to check in on the status and timeline for the OpenSearch connector
compatible with Flink 2.0. I noticed that the current latest versions of Flink
Opensearch Connector 2.0.0-1.19 are built for Flink 1.19, and as Flink 2.0
introduces breaking changes in the API, those aren’t compat
Hi all
Trying to stitch together the below.
I first create a table in flink, backed by a hive catalog, data sourced
from kafka, as per below,
The below create table worked...
First, for reference ts is a bigint value representing the timestamp of the
event.
CREATE OR REPLACE TABLE hive_catalog.
bye
