[jira] [Created] (FLINK-8528) Bucket MapState of TimeBoundedStreamJoinOperator for improved performance

Florian Schmidt created FLINK-8528: -- Summary: Bucket MapState of TimeBoundedStreamJoinOperator for improved performance Key: FLINK-8528 URL: https://issues.apache.org/jira/browse/FLINK-8528 Project:

[jira] [Created] (FLINK-8527) Making stopping of Flip-6 components non-blocking

Till Rohrmann created FLINK-8527: Summary: Making stopping of Flip-6 components non-blocking Key: FLINK-8527 URL: https://issues.apache.org/jira/browse/FLINK-8527 Project: Flink Issue Type:

[jira] [Created] (FLINK-8529) Let Yarn entry points use YarnConfigOptions#APPLICATION_MASTER_PORT

Till Rohrmann created FLINK-8529: Summary: Let Yarn entry points use YarnConfigOptions#APPLICATION_MASTER_PORT Key: FLINK-8529 URL: https://issues.apache.org/jira/browse/FLINK-8529 Project: Flink

[jira] [Created] (FLINK-8530) Enable detached job submission for RestClusterClient

Till Rohrmann created FLINK-8530: Summary: Enable detached job submission for RestClusterClient Key: FLINK-8530 URL: https://issues.apache.org/jira/browse/FLINK-8530 Project: Flink Issue

[jira] [Created] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state

Stephan Ewen created FLINK-8531: --- Summary: Support separation of "Exclusive", "Shared" and "Task owned" state Key: FLINK-8531 URL: https://issues.apache.org/jira/browse/FLINK-8531 Project: Flink

Re: Kinesis consumer shard skew - FLINK-8516

I created a PR for further discussion: https://github.com/apache/flink/pull/5393 There are a few TODOs where I think improvements can be made. Let me know if you agree with the overall direction. Thanks, Thomas On Mon, Jan 29, 2018 at 3:01 PM, Thomas Weise wrote: > >> What

[jira] [Created] (FLINK-8524) Incorrect JavaDoc in TypeExtractor.getBinaryOperatorReturnType

Florian Schmidt created FLINK-8524: -- Summary: Incorrect JavaDoc in TypeExtractor.getBinaryOperatorReturnType Key: FLINK-8524 URL: https://issues.apache.org/jira/browse/FLINK-8524 Project: Flink

Re: [DISCUSS] FLIP-23 Model Serving

OK, I think there was plenty of time to comment on this FLIP. I'll move it to the ACCEPTED status. @Stavros, please consider the feedback regarding the metrics. I agree with Chesnay that metrics should be primarily exposed via the metrics system. Storing them in state makes them fault-tolerant

[jira] [Created] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

Yuta Morisawa created FLINK-8532: Summary: RebalancePartitioner should use Random value for its first partition Key: FLINK-8532 URL: https://issues.apache.org/jira/browse/FLINK-8532 Project: Flink

[jira] [Created] (FLINK-8525) How to query state in flink 1.4.0?

jia liu created FLINK-8525: -- Summary: How to query state in flink 1.4.0? Key: FLINK-8525 URL: https://issues.apache.org/jira/browse/FLINK-8525 Project: Flink Issue Type: Test Components:

[jira] [Created] (FLINK-8526) When use some parallelism, the program will stuck in some setting.

zhu.qing created FLINK-8526: --- Summary: When use some parallelism, the program will stuck in some setting. Key: FLINK-8526 URL: https://issues.apache.org/jira/browse/FLINK-8526 Project: Flink