[jira] [Created] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

shuai.xu created FLINK-8399: --- Summary: Use independent configurations for the different timeouts in slot manager Key: FLINK-8399 URL: https://issues.apache.org/jira/browse/FLINK-8399 Project: Flink

[jira] [Created] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests

Tzu-Li (Gordon) Tai created FLINK-8398: -- Summary: Stabilize flaky KinesisDataFetcherTests Key: FLINK-8398 URL: https://issues.apache.org/jira/browse/FLINK-8398 Project: Flink Issue Type:

Re: [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric

I had an offline discussion with @zentol, he said: "I hope to get this change in for 1.5; the core implementation is done but some details must be ironed out first.". Best. 2018-01-03 11:25 GMT+08:00 Marvin777 : > Hi, all: > > I have some question about LatencyGauge change to histogram metric.

[jira] [Created] (FLINK-8397) Support ROW type in CassandraOutputFormat

Shuyi Chen created FLINK-8397: - Summary: Support ROW type in CassandraOutputFormat Key: FLINK-8397 URL: https://issues.apache.org/jira/browse/FLINK-8397 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8396) Create (derived) duplicate Buffer class

Nico Kruber created FLINK-8396: -- Summary: Create (derived) duplicate Buffer class Key: FLINK-8396 URL: https://issues.apache.org/jira/browse/FLINK-8396 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8395) Create (derived) sliced Buffer class

Nico Kruber created FLINK-8395: -- Summary: Create (derived) sliced Buffer class Key: FLINK-8395 URL: https://issues.apache.org/jira/browse/FLINK-8395 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown

Ted Yu created FLINK-8394: - Summary: Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown Key: FLINK-8394 URL: https://issues.apache.org/jira/browse/FLINK-8394 Project: Flink

[jira] [Created] (FLINK-8393) Reconnect to last known JobMaster when connection is lost

Till Rohrmann created FLINK-8393: Summary: Reconnect to last known JobMaster when connection is lost Key: FLINK-8393 URL: https://issues.apache.org/jira/browse/FLINK-8393 Project: Flink Issue

Re: aggregate stream of logs

Hi, First of all, your question is more suited for the Flink user mailing list (this is the dev mailing list). I think you can use a GlobalWindow [1] with a custom trigger. A global window assigns all elements with the same key to the same window, and will not perform any computation unless trigg

[jira] [Created] (FLINK-8392) Simplify termination future completion

Till Rohrmann created FLINK-8392: Summary: Simplify termination future completion Key: FLINK-8392 URL: https://issues.apache.org/jira/browse/FLINK-8392 Project: Flink Issue Type: Sub-task

Issues to work on for newbie to the Flink project

Hello Flink Commiters, I have been reading Flink documentation for some time now, and want to contribute as a developer to the project, however unlike other projects I could not find tags on issues that suggest it suitable for newbies to pick up. I would really appreciate if you could suggest few

Re: [DISCUSS] FLIP-24 - SQL Client

Hi Fabian, thank you for your feedback. I extended the "Implementation Plan" by 3 subsections. Regarding the proposed changes, I looked into the code of the ClusterClient and talked to Till Rohrmann about it. By now, I could not identify features that are missing on existing components. It mig

[jira] [Created] (FLINK-8391) Improve dependency documentation for queryable state

Fabian Hueske created FLINK-8391: Summary: Improve dependency documentation for queryable state Key: FLINK-8391 URL: https://issues.apache.org/jira/browse/FLINK-8391 Project: Flink Issue Type