[GitHub] klion26 opened a new pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

klion26 opened a new pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351 ## What is the purpose of the change [This patch](https://issues.apache.org/jira/browse/FLINK-11008) wants

[jira] [Updated] (FLINK-11008) Speed up upload checkpoint files using multi-thread

[ https://issues.apache.org/jira/browse/FLINK-11008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11008: --- Labels: pull-request-available (was: ) > Speed up upload checkpoint files using multi-threa

[GitHub] hequn8128 commented on issue #7241: [FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

hequn8128 commented on issue #7241: [FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 URL: https://github.com/apache/flink/pull/7241#issuecomment-449611355 Generate snapshots from release-1.7.1 --

[jira] [Updated] (FLINK-11189) Deprecated documentation for readSequenceFile function

[ https://issues.apache.org/jira/browse/FLINK-11189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11189: --- Labels: pull-request-available (was: ) > Deprecated documentation for readSequenceFile func

[GitHub] leesf opened a new pull request #7350: [FLINK-11189] Deprecated documentation for readSequenceFile function

leesf opened a new pull request #7350: [FLINK-11189] Deprecated documentation for readSequenceFile function URL: https://github.com/apache/flink/pull/7350 ## What is the purpose of the change Remove deprecated readSequenceFile function and provide an correct example for read

[jira] [Commented] (FLINK-11071) Dynamic proxy classes cannot be resolved when deserializing job graph

[ https://issues.apache.org/jira/browse/FLINK-11071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727580#comment-16727580 ] Oleg Zhukov commented on FLINK-11071: - Stephan, not immediately. The current workaro

[jira] [Resolved] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-4582. - Resolution: Fixed Fix Version/s: 1.8.0 > Allow FlinkKinesisConsumer to adapt for AWS Dynam

[GitHub] tweise closed pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

tweise closed pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[GitHub] tweise commented on issue #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

tweise commented on issue #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#issuecomment-449581213 @yxu-valleytider thanks for the contribution! This is

[jira] [Created] (FLINK-11211) ReinterpretDataStreamAsKeyedStreamITCase failed on Travis

Chesnay Schepler created FLINK-11211: Summary: ReinterpretDataStreamAsKeyedStreamITCase failed on Travis Key: FLINK-11211 URL: https://issues.apache.org/jira/browse/FLINK-11211 Project: Flink

[jira] [Comment Edited] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727431#comment-16727431 ] Hequn Cheng edited comment on FLINK-11188 at 12/22/18 1:41 PM: ---

[jira] [Created] (FLINK-11210) Enable auto state cleanup strategy for RANGE OVER

Hequn Cheng created FLINK-11210: --- Summary: Enable auto state cleanup strategy for RANGE OVER Key: FLINK-11210 URL: https://issues.apache.org/jira/browse/FLINK-11210 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727431#comment-16727431 ] Hequn Cheng commented on FLINK-11188: - [~fhueske] Thanks for your suggestions. I wi

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727408#comment-16727408 ] Fabian Hueske commented on FLINK-11188: --- Agreed! * OVER RANGE should automaticall

[jira] [Created] (FLINK-11209) Provide more complete guidance for the log usage documentation

vinoyang created FLINK-11209: Summary: Provide more complete guidance for the log usage documentation Key: FLINK-11209 URL: https://issues.apache.org/jira/browse/FLINK-11209 Project: Flink Issue

[jira] [Commented] (FLINK-10724) Refactor failure handling in check point coordinator

[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727290#comment-16727290 ] vinoyang commented on FLINK-10724: --  [~StephanEwen] [~till.rohrmann] Can you look at th

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727294#comment-16727294 ] Zhenqiu Huang commented on FLINK-10868: --- I like this idea. It is pretty clean. Aft