[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722394#comment-16722394 ] vinoyang commented on FLINK-11103: -- Hi [~NicoK] I analyzed the source code and I found

[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=16722390#comment-16722390 ] vinoyang commented on FLINK-10724: -- Hi [~azagrebin] I have attached a design document i

[jira] [Updated] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-4810: Description: The Checkpoint coordinator should track the number of consecutive unsuccessful checkpoints.

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

[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10724: - Description: At the moment failure handling of asynchronously triggered checkpoint in check point coord

[GitHub] leesf commented on issue #5376: [FLINK-6214] WindowAssigners do not allow negative offsets

leesf commented on issue #5376: [FLINK-6214] WindowAssigners do not allow negative offsets URL: https://github.com/apache/flink/pull/5376#issuecomment-447618218 @jelmerk hi jelmerk, could you tell what is the progress of the pr? If you are busy, I am glad to take over this pr. ---

[GitHub] kezhuw commented on a change in pull request #7300: [FLINK-11151][rest] Create parent directories in FileUploadHandler

kezhuw commented on a change in pull request #7300: [FLINK-11151][rest] Create parent directories in FileUploadHandler URL: https://github.com/apache/flink/pull/7300#discussion_r241967901 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-7991: Fix Version/s: (was: 1.5.6) > Cleanup kafka example jar filters > -

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9010: Fix Version/s: (was: 1.5.6) > NoResourceAvailableException with FLIP-6 > -

[jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9253: Fix Version/s: (was: 1.5.6) > Make buffer count per InputGate always #channels*buffersPerChanne

[jira] [Updated] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10251: - Fix Version/s: (was: 1.5.6) > Handle oversized response messages in AkkaRpcActor > -

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722166#comment-16722166 ] sunjincheng commented on FLINK-9555: [~Zentol] Why don't we solve it by file a new ji

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722161#comment-16722161 ] Jeff Zhang commented on FLINK-9555: --- [~Zentol] Do you mean the bug of FLINK-11161 ? >

[jira] [Commented] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722146#comment-16722146 ] Maximilian Michels commented on FLINK-11168: How slow is Travis? On my machi

[GitHub] klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241949427 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/ma

[jira] [Assigned] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-11168: -- Assignee: Maximilian Michels > LargePlanTest times out on Travis > --

[jira] [Commented] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722142#comment-16722142 ] Maximilian Michels commented on FLINK-11168: Thanks for reporting. I'll look

[GitHub] hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API

hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209#discussion_r241948966 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/tab

[GitHub] hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API

hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209#discussion_r241948943 ## File path: flink-libraries/flink-table-common/src/main/java/org/apache/fli

[GitHub] hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API

hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209#discussion_r241948931 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/tab

[GitHub] hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API

hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209#discussion_r241948923 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/tab

[GitHub] hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API

hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209#discussion_r241948923 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/tab

[jira] [Assigned] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11

[ https://issues.apache.org/jira/browse/FLINK-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9700: --- Assignee: leesf (was: vinoyang) > Document FlinkKafkaProducer behaviour for Kafka versions > 0.11 >

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241815671 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/

[GitHub] hequn8128 commented on issue #7289: [FLINK-11001][table] Fix window rowtime attribute can't be renamed bug in Java

hequn8128 commented on issue #7289: [FLINK-11001][table] Fix window rowtime attribute can't be renamed bug in Java URL: https://github.com/apache/flink/pull/7289#issuecomment-44761 @twalthr Thanks a lot for your remind. It seems there are no places need to be updated in the docs. Howev

[GitHub] imamitsehgal edited a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal edited a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-447552703 @klion26 I have not added any additional test case around this because this is very specific for Windo

[GitHub] imamitsehgal removed a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal removed a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-447552703 @klion26 I have not added any additional test case around this because this is very specific for Wind

[GitHub] imamitsehgal edited a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal edited a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-447552684 @klion26 I have not added any additional test case around this because this is very specific for Windo

[GitHub] imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-447552703 > @imamitsehgal thank you for your contribution. Could you please add a test to verify this? (Before the patch

[GitHub] imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-447552684 I have not added any additional test case around this because this is very specific for Windows OS and runs fi

[GitHub] azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241812506 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Executio

[jira] [Comment Edited] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722013#comment-16722013 ] boshu Zheng edited comment on FLINK-9717 at 12/15/18 8:54 AM: -