Hi,
Problem: Watermark does not move within Dynamic Alert Function
Implementing ideas (as is) from this article -
https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html
Code: https://github.com/afedulov/fraud-detection-demo
Pipeline: Kafka -> Dynamic Key Function -> Dynamic Alert Func
Hi,
I am attempting the following:
String sql = "INSERT INTO table3 "
+ "SELECT col1, col2, window_start_time , window_end_time ,
MAX(col3), MAX(col4), MAX(col5) FROM "
+ "(SELECT col1,col2, "
+ "TUMBLE_START(ts, INTERVAL '1' MINUTE) as
window_start_time, "
Jun 3, 2019 at 12:02 AM Pramit Vamsi wrote:
> Hi,
>
> I am working with nested JSON e.g.
>
> {
> "document": {
> "_id": "qwery",
> "meetingstatus": 3,
> "city": 100,
> "users": {
> "created": &qu
Hi,
I am working with nested JSON e.g.
{
"document": {
"_id": "qwery",
"meetingstatus": 3,
"city": 100,
"users": {
"created": "5c9243033eee61a14e5b",
"assigned": "5c9496ad1e91f10f44f"
}
},
"operation": "update"
}
Code usage:
tableEnv.connect(new Kafka()
.version("0.11")
