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
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 do you mean by che
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 and
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
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 Type
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
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:
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: I
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
Issu
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: Q
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
11 matches
Mail list logo