[jira] [Created] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer

Thomas Weise created FLINK-9188: --- Summary: Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer Key: FLINK-9188 URL: https://issues.apache.org/jira/browse/FLINK-9188 Project:

[jira] [Created] (FLINK-9187) add prometheus pushgateway reporter

lamber-ken created FLINK-9187: - Summary: add prometheus pushgateway reporter Key: FLINK-9187 URL: https://issues.apache.org/jira/browse/FLINK-9187 Project: Flink Issue Type: New Feature

Re: Validating markdown doc files before creating a PR

You can serve the documentation locally as described here . On 16.04.2018 21:17, Ken Krugler wrote: Hi all, I’m curious how devs check that their .md file edits are correct. I've tried a few different plugins and command line

Validating markdown doc files before creating a PR

Hi all, I’m curious how devs check that their .md file edits are correct. I've tried a few different plugins and command line utilities, but the mix of HTML and markdown has meant none of them render properly. Thanks, — Ken -- Ken Krugler http://www.scaleunlimited.com

Re: Kinesis getRecords read timeout and retry

Hi Gordon, This is indeed a discussion necessary to have! The purpose of previous PRs wasn't to provide solutions to the original identified issues, but rather to enable solve those through customization. What those customizations would be was also communicated, along with the intent to

[jira] [Created] (FLINK-9186) Enable dependency convergence for flink-libraries

Chesnay Schepler created FLINK-9186: --- Summary: Enable dependency convergence for flink-libraries Key: FLINK-9186 URL: https://issues.apache.org/jira/browse/FLINK-9186 Project: Flink Issue

[jira] [Created] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

Ted Yu created FLINK-9185: - Summary: Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives Key: FLINK-9185 URL: https://issues.apache.org/jira/browse/FLINK-9185

[jira] [Created] (FLINK-9184) Remove warning from kafka consumer docs

Juho Autio created FLINK-9184: - Summary: Remove warning from kafka consumer docs Key: FLINK-9184 URL: https://issues.apache.org/jira/browse/FLINK-9184 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9183) Kafka consumer docs to warn about idle partitions

Juho Autio created FLINK-9183: - Summary: Kafka consumer docs to warn about idle partitions Key: FLINK-9183 URL: https://issues.apache.org/jira/browse/FLINK-9183 Project: Flink Issue Type:

Re: Flink 1.3.2 with CEP Pattern, Memory usage increases results in OOM

Hi Abiramalakshmi, Thanks for reporting this! As a starting point I would recommend: 1) use RocksDB as your backend, so that state is not accumulated in memory 2) enable incremental checkpoints 3) the “new IterativeCondition() {…}” can become “new SimpleCondition() {}”, as this is more

[jira] [Created] (FLINK-9182) async checkpoints for timer service

makeyang created FLINK-9182: --- Summary: async checkpoints for timer service Key: FLINK-9182 URL: https://issues.apache.org/jira/browse/FLINK-9182 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9181) Add SQL Client documentation page

Timo Walther created FLINK-9181: --- Summary: Add SQL Client documentation page Key: FLINK-9181 URL: https://issues.apache.org/jira/browse/FLINK-9181 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9180) Remove REST_ prefix from rest options

Chesnay Schepler created FLINK-9180: --- Summary: Remove REST_ prefix from rest options Key: FLINK-9180 URL: https://issues.apache.org/jira/browse/FLINK-9180 Project: Flink Issue Type:

[jira] [Created] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

Chesnay Schepler created FLINK-9179: --- Summary: Deduplicate WebOptions.PORT and RestOptions.REST_PORT Key: FLINK-9179 URL: https://issues.apache.org/jira/browse/FLINK-9179 Project: Flink

[jira] [Created] (FLINK-9178) Add rate control for kafka source

buptljy created FLINK-9178: -- Summary: Add rate control for kafka source Key: FLINK-9178 URL: https://issues.apache.org/jira/browse/FLINK-9178 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9177) Link under Installing Mesos goes to a 404 page

Arunan Sugunakumar created FLINK-9177: - Summary: Link under Installing Mesos goes to a 404 page Key: FLINK-9177 URL: https://issues.apache.org/jira/browse/FLINK-9177 Project: Flink Issue