Re: Add Bucket File System Table Sink

Hi, Kurt Thank you very much for your suggestion. I have studied the design documentation of FLIP-63. I have no comments here. With your suggestion from the previous few days, I am writing a design documentation about the Bucket FileSystem Table Sink and considering how to support the

Re: [SURVEY] How many people are using customized RestartStrategy(s)

Zhu Zhu, Flink fullRestart metric is a Gauge, which is not good for alerting on. We publish an equivalent Counter metric for alerting purpose. Thanks, Steven On Thu, Sep 19, 2019 at 7:45 PM Zhu Zhu wrote: > Thanks Steven for the feedback! > Could you share more information about the metrics

[jira] [Created] (FLINK-14161) wrong description of state

gaofeilong created FLINK-14161: -- Summary: wrong description of state Key: FLINK-14161 URL: https://issues.apache.org/jira/browse/FLINK-14161 Project: Flink Issue Type: Bug Components:

non-deserializable root cause in DeclineCheckpoint

JIRA ticket: https://issues.apache.org/jira/browse/FLINK-14076 I'm on Flink v1.9 with the Kafka connector and a standalone JM. If FlinkKafkaProducer fails while checkpointing, it throws a KafkaException which gets wrapped in a CheckpointException which is sent to the JM as a DeclineCheckpoint.

[jira] [Created] (FLINK-14160) Extend Operations Playground with --backpressure option

David Anderson created FLINK-14160: -- Summary: Extend Operations Playground with --backpressure option Key: FLINK-14160 URL: https://issues.apache.org/jira/browse/FLINK-14160 Project: Flink

Re: [DISCUSS] FLIP-60: Restructure the Table API & SQL documentation

Hi all, sorry for joining late. Looking at the target structure of our documentation as discussed in FLIP-42 [1] we will have some sections, which cover both APIs (SQL/Table and DataStream). These include * Getting Started * Concepts * Deployments * Operations * Connectors * Libraries (CEP, ML)