[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668547#comment-16668547 ] ASF GitHub Bot commented on FLINK-10074: yanghua closed pull request #6567: [FLINK-10074]

[GitHub] yanghua closed pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

2018-10-30 Thread GitBox
yanghua closed pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567 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: As this is

[GitHub] yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

2018-10-30 Thread GitBox
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-434257204 @azagrebin OK, agree. This is an automated message from the Apache

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668540#comment-16668540 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[GitHub] azagrebin commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

2018-10-30 Thread GitBox
azagrebin commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-434255898 I created FLINK-10724 to refactor failure handling in checkpoint coordinator where I believe we should firstly prepare it for

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668533#comment-16668533 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668538#comment-16668538 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668535#comment-16668535 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668532#comment-16668532 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668542#comment-16668542 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668534#comment-16668534 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668529#comment-16668529 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668530#comment-16668530 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668537#comment-16668537 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668531#comment-16668531 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668543#comment-16668543 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on issue #6567: [FLINK-10074]

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668541#comment-16668541 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668536#comment-16668536 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668539#comment-16668539 ] ASF GitHub Bot commented on FLINK-9635: --- tillrohrmann commented on a change in pull request #6961:

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229257454 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/FailoverRegionTest.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229258079 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotInfo.java ## @@

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229255838 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229259226 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229250999 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229250625 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229251157 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229253693 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229257277 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229251102 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229257342 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229257170 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionTest.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229250429 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java

[GitHub] tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#discussion_r229258870 ## File path:

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668527#comment-16668527 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434255369 @pnowojski We cannot add `set -e` to top of the modified files. This action would cause the test to fail.

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-10-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668520#comment-16668520 ] Andrey Zagrebin commented on FLINK-10074: - I created an issue FLINK-10074 to revisit failure

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

2018-10-30 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10724: --- Summary: Refactor failure handling in check point coordinator Key: FLINK-10724 URL: https://issues.apache.org/jira/browse/FLINK-10724 Project: Flink

[jira] [Assigned] (FLINK-10628) Add end-to-end test for REST communication encryption

2018-10-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10628: --- Assignee: Andrey Zagrebin > Add end-to-end test for REST communication encryption

[jira] [Resolved] (FLINK-10687) Make flink-formats Scala-free

2018-10-30 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10687. -- Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0:

[jira] [Commented] (FLINK-10714) java.lang.IndexOutOfBoundsException when creating a heap backend snapshot

2018-10-30 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668486#comment-16668486 ] Stefan Richter commented on FLINK-10714: [~cmick] Can you share the part of your job that

[jira] [Commented] (FLINK-10669) Exceptions & errors are not properly checked in logs in e2e tests

2018-10-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668481#comment-16668481 ] Gary Yao commented on FLINK-10669: -- Are we not backporting this? After all it is a bug. > Exceptions &

[jira] [Commented] (FLINK-9697) Provide connector for modern Kafka

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668476#comment-16668476 ] ASF GitHub Bot commented on FLINK-9697: --- pnowojski commented on issue #6703: [FLINK-9697] Provide

[GitHub] pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-30 Thread GitBox
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-434244534 Let's not do it know, but at some point of time we probably should do it. Unless we drop all of the connectors except of 2.0 - but in

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668471#comment-16668471 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull request #6924:

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r229245803 ## File path: flink-end-to-end-tests/test-scripts/kafka-common.sh ## @@

[GitHub] pnowojski commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
pnowojski commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434241140 I would guess "group" from here: ``` kafka-common.sh: $KAFKA_DIR/bin/kafka-consumer-groups.sh --describe

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668459#comment-16668459 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on issue #6924: [FLINK-10600]

[jira] [Created] (FLINK-10723) Upgrade MapSerializer for state evolution

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10723: --- Summary: Upgrade MapSerializer for state evolution Key: FLINK-10723 URL: https://issues.apache.org/jira/browse/FLINK-10723 Project: Flink

[jira] [Commented] (FLINK-5770) Flink yarn session stop in non-detached model

2018-10-30 Thread wgcn (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668448#comment-16668448 ] wgcn commented on FLINK-5770: - your client maybe shutdown   you can use the arg -d  > Flink yarn session

[jira] [Commented] (FLINK-10687) Make flink-formats Scala-free

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668417#comment-16668417 ] ASF GitHub Bot commented on FLINK-10687: twalthr commented on issue #6958: [FLINK-10687] [table]

[GitHub] twalthr commented on issue #6958: [FLINK-10687] [table] Make flink-formats Scala-free

2018-10-30 Thread GitBox
twalthr commented on issue #6958: [FLINK-10687] [table] Make flink-formats Scala-free URL: https://github.com/apache/flink/pull/6958#issuecomment-434230605 Thanks everyone. I will merge this now... This is an automated

[jira] [Commented] (FLINK-9697) Provide connector for modern Kafka

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668395#comment-16668395 ] ASF GitHub Bot commented on FLINK-9697: --- yanghua commented on issue #6703: [FLINK-9697] Provide

[GitHub] yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-30 Thread GitBox
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-434224603 The base module does not currently remove the dependency on kafka. We seem to have discussed it when implementing the kafka 1.0 version

[GitHub] pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-30 Thread GitBox
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-434222942 Yes I know about this issue with our connectors for kafka `[0.9, 0.11]`, but I had an impression that it was supposed to be fixed for

[jira] [Commented] (FLINK-9697) Provide connector for modern Kafka

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668388#comment-16668388 ] ASF GitHub Bot commented on FLINK-9697: --- pnowojski commented on issue #6703: [FLINK-9697] Provide

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668376#comment-16668376 ] ASF GitHub Bot commented on FLINK-10357: azagrebin commented on a change in pull request #6907:

[GitHub] azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229220979 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ##

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668375#comment-16668375 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on issue #6907: [FLINK-10357][tests]

[GitHub] GJL commented on issue #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on issue #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#issuecomment-434220428 Thanks for reviewing @azagrebin. Merging as soon as build is green.

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668373#comment-16668373 ] ASF GitHub Bot commented on FLINK-10074: yanghua commented on issue #6567: [FLINK-10074]

[GitHub] yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

2018-10-30 Thread GitBox
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-434220095 Hi @azagrebin I am currently busy with several other PRs and hope it will be merged into Flink 1.7.0. When those PRs are fixed, I

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668367#comment-16668367 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on issue #6567: [FLINK-10074]

[GitHub] azagrebin commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

2018-10-30 Thread GitBox
azagrebin commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-434217958 Hi @yanghua, can this PR be closed for now and we come back to it when we have design in the Jira issue? We might

[jira] [Closed] (FLINK-10722) Document MATCH_RECOGNIZE

2018-10-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10722. Resolution: Duplicate > Document MATCH_RECOGNIZE > > >

[jira] [Created] (FLINK-10722) Document MATCH_RECOGNIZE

2018-10-30 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10722: Summary: Document MATCH_RECOGNIZE Key: FLINK-10722 URL: https://issues.apache.org/jira/browse/FLINK-10722 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668346#comment-16668346 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull request #6907:

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668345#comment-16668345 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull request #6907:

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668344#comment-16668344 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull request #6907:

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668343#comment-16668343 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull request #6907:

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229213320 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229213320 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229213320 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229213320 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668340#comment-16668340 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull request #6907:

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668338#comment-16668338 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull request #6907:

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229213320 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-30 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r229213214 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668310#comment-16668310 ] ASF GitHub Bot commented on FLINK-10704: yanghua opened a new pull request #6963: [FLINK-10704]

[jira] [Updated] (FLINK-10704) Fix sql client end to end test failure

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10704: --- Labels: pull-request-available (was: ) > Fix sql client end to end test failure >

[GitHub] yanghua opened a new pull request #6963: [FLINK-10704] Fix sql client end to end test failure

2018-10-30 Thread GitBox
yanghua opened a new pull request #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963 ## What is the purpose of the change *This pull request fixes sql client end to end test failure* ## Brief change log -

[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

2018-10-30 Thread zhaoshijie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoshijie updated FLINK-10721: --- Description: In FlinkKafkaConsumerBase run method on line 721(master branch), if

[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

2018-10-30 Thread zhaoshijie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoshijie updated FLINK-10721: --- Description: In FlinkKafkaConsumerBase run method on line 721(master branch), if

[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

2018-10-30 Thread zhaoshijie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoshijie updated FLINK-10721: --- Description: In FlinkKafkaConsumerBase run method on line 721(master branch), if

[jira] [Created] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

2018-10-30 Thread zhaoshijie (JIRA)
zhaoshijie created FLINK-10721: -- Summary: kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method Key: FLINK-10721 URL:

[jira] [Updated] (FLINK-10168) support reading files whose modification time is after a given timestamp

2018-10-30 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10168: - Fix Version/s: (was: 1.7.0) 1.8.0 > support reading files whose modification

[jira] [Updated] (FLINK-10168) support reading files whose modification time is after a given timestamp

2018-10-30 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10168: - Summary: support reading files whose modification time is after a given timestamp (was: support

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668243#comment-16668243 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434190482 @tzulitai shell function `get_partition_end_offset` in kafka-common.sh : ```

[jira] [Commented] (FLINK-10668) Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668212#comment-16668212 ] ASF GitHub Bot commented on FLINK-10668: hequn8128 commented on issue #6950: [FLINK-10668][e2e]

[jira] [Commented] (FLINK-10668) Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668213#comment-16668213 ] ASF GitHub Bot commented on FLINK-10668: hequn8128 closed pull request #6950: [FLINK-10668][e2e]

[GitHub] hequn8128 closed pull request #6950: [FLINK-10668][e2e] Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-30 Thread GitBox
hequn8128 closed pull request #6950: [FLINK-10668][e2e] Streaming File Sink E2E test fails because not all legitimate exceptions are excluded URL: https://github.com/apache/flink/pull/6950 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[GitHub] hequn8128 commented on issue #6950: [FLINK-10668][e2e] Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-30 Thread GitBox
hequn8128 commented on issue #6950: [FLINK-10668][e2e] Streaming File Sink E2E test fails because not all legitimate exceptions are excluded URL: https://github.com/apache/flink/pull/6950#issuecomment-434185595 Thanks. That is more general. I will close this.

<    1   2   3