[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176997747 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@

[jira] [Resolved] (FLINK-8721) Client blocks indefinitely if job archiving fails

[ https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8721. -- Resolution: Fixed Fixed via master: a6a7623dd8a549f4a31bbc361b891c65b5feef07 1.5.0:

[GitHub] flink pull request #5737: [FLINK-8721][flip6] Handle archiving failures for ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5737 ---

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176997549 --- Diff: flink-end-to-end-tests/test-scripts/test_batch_wordcount.sh --- @@ -22,4 +22,4 @@ source "$(dirname "$0")"/common.sh start_cluster

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176997786 --- Diff: flink-end-to-end-tests/run-nightly-tests.sh --- @@ -47,5 +47,13 @@ EXIT_CODE=0 # EXIT_CODE=$? # fi +if [ $EXIT_CODE ==

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176998055 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413491#comment-16413491 ] ASF GitHub Bot commented on FLINK-8989: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176996113 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176996077 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413480#comment-16413480 ] ASF GitHub Bot commented on FLINK-8989: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176996131 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413477#comment-16413477 ] ASF GitHub Bot commented on FLINK-8989: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413474#comment-16413474 ] yuqi commented on FLINK-9056: - [~fhueske], Hello, I have test this problem with master branch and could not

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413476#comment-16413476 ] ASF GitHub Bot commented on FLINK-8989: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176995940 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/elasticsearch/Elasticsearch1Example.java --- @@ -37,20

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413475#comment-16413475 ] ASF GitHub Bot commented on FLINK-8989: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176995759 --- Diff: flink-end-to-end-tests/run-nightly-tests.sh --- @@ -47,5 +47,13 @@ EXIT_CODE=0 # EXIT_CODE=$? # fi +if [ $EXIT_CODE == 0

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413478#comment-16413478 ] ASF GitHub Bot commented on FLINK-8989: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413479#comment-16413479 ] ASF GitHub Bot commented on FLINK-8989: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1 end to end ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r176995662 --- Diff: flink-end-to-end-tests/test-scripts/test_batch_wordcount.sh --- @@ -22,4 +22,4 @@ source "$(dirname "$0")"/common.sh start_cluster

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413471#comment-16413471 ] Tzu-Li (Gordon) Tai commented on FLINK-8981: Hi [~suez1224]! Thanks for picking this issue up.

[jira] [Created] (FLINK-9074) End-to-end test: Resume from retained checkpoints

Tzu-Li (Gordon) Tai created FLINK-9074: -- Summary: End-to-end test: Resume from retained checkpoints Key: FLINK-9074 URL: https://issues.apache.org/jira/browse/FLINK-9074 Project: Flink

[jira] [Created] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends

Tzu-Li (Gordon) Tai created FLINK-9073: -- Summary: Resume from savepoint end-to-end tests should be extended for different state backends Key: FLINK-9073 URL: https://issues.apache.org/jira/browse/FLINK-9073

[jira] [Comment Edited] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413453#comment-16413453 ] Arvid Heise edited comment on FLINK-8715 at 3/26/18 6:58 AM: - I don't have an

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413453#comment-16413453 ] Arvid Heise commented on FLINK-8715: I don't have an overview for all the different use cases, so the

[jira] [Closed] (FLINK-8975) End-to-end test: Resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8975. -- > End-to-end test: Resume from savepoint > -- > >

[jira] [Closed] (FLINK-8976) End-to-end test: Resume with different parallelism

[ https://issues.apache.org/jira/browse/FLINK-8976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8976. -- > End-to-end test: Resume with different parallelism >

[jira] [Resolved] (FLINK-8976) End-to-end test: Resume with different parallelism

[ https://issues.apache.org/jira/browse/FLINK-8976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8976. Resolution: Fixed Merged, via 1.6.0: e231c5cd9b6923363255ca61837505a9618767e5

[jira] [Created] (FLINK-9072) Host name with "_" causes cluster exception

liuzhuo created FLINK-9072: -- Summary: Host name with "_" causes cluster exception Key: FLINK-9072 URL: https://issues.apache.org/jira/browse/FLINK-9072 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-8975) End-to-end test: Resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8975. Resolution: Fixed Merged, via 1.6.0: a0c17d94072ec6e127ea3cb3c507a595283b9b87

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413431#comment-16413431 ] Sihua Zhou commented on FLINK-9070: --- Hi [~kien_truong], this is interesting. I agree with you that the

[jira] [Commented] (FLINK-8975) End-to-end test: Resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413428#comment-16413428 ] ASF GitHub Bot commented on FLINK-8975: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5745: [FLINK-8976] [test] Add end-to-end test for resumi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5745 ---

[jira] [Commented] (FLINK-8976) End-to-end test: Resume with different parallelism

[ https://issues.apache.org/jira/browse/FLINK-8976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413429#comment-16413429 ] ASF GitHub Bot commented on FLINK-8976: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5733: [FLINK-8975] [test] Add resume from savepoint end-...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5733 ---

<    1   2   3