You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
How to import Parquet files, and how to ingest from AMQP and MQTT.
Demonstrate PyFlink with CrateDB.
Because CrateDB does not have a CDC interface, the CDC Connectors for Apache Flink can't be used. So, at least demonstrate how to use the GetInData CDC by JDBC Connector, which allows to read data from SQL databases by periodically reading data from tables, see Change Data Capture by JDBC with FlinkSQL.
More
Follow up with the Flink JDBC Connector » CrateDB support patch. PR has been merged. When a new version including the support for CrateDB is merged, use static version, instead of jitpack dependency on main branch.
Currently, the test harness for the runJob examples need to spin up a CrateDB instance using Docker, both locally and on CI. What about using the new "testcontainer"-based implementation? PR to support CrateDB has been merged, follow: https://github.com/testcontainers/testcontainers-java/releases for the next release which contains it.
Question: Should the infrastructure from kafka-flink be just hosted within this repository instead?
The text was updated successfully, but these errors were encountered:
Maintenance
crate-jdbc
: Address Dependabot updates at https://github.com/crate/crate-jdbc/pulls.crate-jdbc
: Update to recent pgJDBC, see https://github.com/crate/crate-jdbc/tree/master/pg.Documentation
Examples
runJob
examples, with CrateDB Cloud.datagen
andflink-faker
connectors.More
main
branch.runJob
examples need to spin up a CrateDB instance using Docker, both locally and on CI. What about using the new "testcontainer"-based implementation? PR to support CrateDB has been merged, follow: https://github.com/testcontainers/testcontainers-java/releases for the next release which contains it.kafka-flink
be just hosted within this repository instead?The text was updated successfully, but these errors were encountered: