Handling JSON Serialization without Kryo

Hi all, I’m reaching out today for some suggestions (and hopefully a solution) for a Flink job that I’m working on. The job itself reads JSON strings from a Kafka topic and reads those into JSONObjects (currently via Gson), which are then operated against, before ultimately being written out t

Handling JSON Serialization without Kryo

Hi all, I’m reaching out today for some suggestions (and hopefully a solution) for a Flink job that I’m working on. The job itself reads JSON strings from a Kafka topic and reads those into JSONObjects (currently via Gson), which are then operated against, before ultimately being written out to

[jira] [Created] (FLINK-30807) State Processor API - Overwrite Support for Savepoints

Rion Williams created FLINK-30807: - Summary: State Processor API - Overwrite Support for Savepoints Key: FLINK-30807 URL: https://issues.apache.org/jira/browse/FLINK-30807 Project: Flink

[jira] [Created] (FLINK-21885) Minor Typo Fix in JDBC Connector Documentation

Rion Williams created FLINK-21885: - Summary: Minor Typo Fix in JDBC Connector Documentation Key: FLINK-21885 URL: https://issues.apache.org/jira/browse/FLINK-21885 Project: Flink Issue Type

[jira] [Created] (FLINK-23977) Add Support for Dynamic Elastic Index Routing

Rion Williams created FLINK-23977: - Summary: Add Support for Dynamic Elastic Index Routing Key: FLINK-23977 URL: https://issues.apache.org/jira/browse/FLINK-23977 Project: Flink Issue Type

[jira] [Created] (FLINK-24493) Introduce DemultiplexingSink

Rion Williams created FLINK-24493: - Summary: Introduce DemultiplexingSink Key: FLINK-24493 URL: https://issues.apache.org/jira/browse/FLINK-24493 Project: Flink Issue Type: New Feature