[
https://issues.apache.org/jira/browse/FLINK-26258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-26258.
----------------------------------
Resolution: Invalid
[~fuqiang8] Thanks for opening this ticket but it's the ticket has no clear
information to what's either missing or not working in Flink. I recommend that
you first reach out to the User mailing list with more information to determine
next steps. See https://flink.apache.org/community.html
> 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)
