[
https://issues.apache.org/jira/browse/FLINK-26258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fuqiang8 updated FLINK-26258:
-----------------------------
Component/s: Connectors / Common
(was: Tests)
Description:
1. New functions related to Pika 、Trigger 、Clickhouse and thrift RPC
2. Thrift RPC realizes the dynamic responsibility balance adjusted according to
the load of the server
3. Realize the function of Flink writing hive table and automatically adding
partitions
4. Support Kafka consumption current limit 。Monitoring: ① consumption delay
monitoring; ② Log full link delay monitoring; ③ Statistical input QPS; ④
Automatic alarm of data disconnection, etc
5. Support the following
5.1 Kafkainputs QPS input QPS alarm threshold: alarm when QPS continues to
be 0 within 10 minutes
5.2 Kafkainpredelay consumption upstream Kafka delay alarm threshold: alarm
when the delay exceeds 30% within 10 minutes and more than 10 seconds
5.3 Kafkainputalldelay full link delay (indicators are optional according
to XML configuration) alarm threshold: alarm when the delay exceeds 30% within
10 minutes and more than 10 seconds
6. HDFS reads data
It supports two file reading modes: stream mode (regularly scanning new data)
and batch mode (read only once)
Support recursive / non recursive scanning modes
was:test
Summary: flink new function (was: flink test)
> flink new function
> ------------------
>
> Key: FLINK-26258
> URL: https://issues.apache.org/jira/browse/FLINK-26258
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Common
> Reporter: fuqiang8
> Priority: Major
>
> 1. New functions related to Pika 、Trigger 、Clickhouse and thrift RPC
> 2. Thrift RPC realizes the dynamic responsibility balance adjusted according
> to the load of the server
> 3. Realize the function of Flink writing hive table and automatically adding
> partitions
> 4. Support Kafka consumption current limit 。Monitoring: ① consumption delay
> monitoring; ② Log full link delay monitoring; ③ Statistical input QPS; ④
> Automatic alarm of data disconnection, etc
> 5. Support the following
> 5.1 Kafkainputs QPS input QPS alarm threshold: alarm when QPS continues
> to be 0 within 10 minutes
> 5.2 Kafkainpredelay consumption upstream Kafka delay alarm threshold:
> alarm when the delay exceeds 30% within 10 minutes and more than 10 seconds
> 5.3 Kafkainputalldelay full link delay (indicators are optional according
> to XML configuration) alarm threshold: alarm when the delay exceeds 30%
> within 10 minutes and more than 10 seconds
> 6. HDFS reads data
> It supports two file reading modes: stream mode (regularly scanning new data)
> and batch mode (read only once)
> Support recursive / non recursive scanning modes
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
