You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 03:20:00 UTC
[jira] [Commented] (FLINK-8808) Enable RestClusterClient to submit
jobs to local Dispatchers
[ https://issues.apache.org/jira/browse/FLINK-8808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381456#comment-16381456 ]
ASF GitHub Bot commented on FLINK-8808:
---------------------------------------
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5599
I watched the code and think it is very good. But the travis says
```
Results :
Tests in error:
FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint:333 ยป TestTimedOut
Tests run: 42, Failures: 0, Errors: 1, Skipped: 0
18:43:11.642 [INFO] ------------------------------------------------------------------------
18:43:11.642 [INFO] Reactor Summary:
18:43:11.642 [INFO]
18:43:11.642 [INFO] flink-hadoop-fs .................................... SUCCESS [ 16.959 s]
18:43:11.642 [INFO] flink-mapr-fs ...................................... SUCCESS [ 5.138 s]
18:43:11.642 [INFO] flink-s3-fs-hadoop ................................. SUCCESS [ 30.410 s]
18:43:11.642 [INFO] flink-s3-fs-presto ................................. SUCCESS [ 31.165 s]
18:43:11.643 [INFO] flink-hadoop-compatibility ......................... SUCCESS [01:05 min]
18:43:11.643 [INFO] flink-avro ......................................... SUCCESS [ 23.859 s]
18:43:11.643 [INFO] flink-jdbc ......................................... SUCCESS [ 8.501 s]
18:43:11.643 [INFO] flink-hbase ........................................ SUCCESS [ 46.495 s]
18:43:11.643 [INFO] flink-hcatalog ..................................... SUCCESS [ 0.871 s]
18:43:11.643 [INFO] flink-connector-kafka-base ......................... SUCCESS [ 7.658 s]
18:43:11.643 [INFO] flink-connector-kafka-0.8 .......................... SUCCESS [02:32 min]
18:43:11.643 [INFO] flink-connector-kafka-0.9 .......................... SUCCESS [02:49 min]
18:43:11.643 [INFO] flink-connector-kafka-0.10 ......................... SUCCESS [02:49 min]
18:43:11.643 [INFO] flink-connector-kafka-0.11 ......................... FAILURE [10:49 min]
18:43:11.643 [INFO] flink-connector-elasticsearch-base ................. SKIPPED
18:43:11.643 [INFO] flink-connector-elasticsearch ...................... SKIPPED
18:43:11.643 [INFO] flink-connector-elasticsearch2 ..................... SKIPPED
18:43:11.643 [INFO] flink-connector-elasticsearch5 ..................... SKIPPED
18:43:11.643 [INFO] flink-connector-rabbitmq ........................... SKIPPED
18:43:11.643 [INFO] flink-connector-twitter ............................ SKIPPED
18:43:11.643 [INFO] flink-connector-nifi ............................... SKIPPED
18:43:11.643 [INFO] flink-connector-cassandra .......................... SKIPPED
18:43:11.643 [INFO] flink-connector-filesystem ......................... SKIPPED
18:43:11.643 [INFO] flink-connector-kinesis ............................ SKIPPED
18:43:11.643 [INFO] flink-connector-wikiedits .......................... SKIPPED
18:43:11.643 [INFO] ------------------------------------------------------------------------
18:43:11.643 [INFO] BUILD FAILURE
18:43:11.643 [INFO] ------------------------------------------------------------------------
18:43:11.643 [INFO] Total time: 23:00 min
18:43:11.643 [INFO] Finished at: 2018-02-28T18:43:11+00:00
18:43:12.101 [INFO] Final Memory: 117M/746M
```
> Enable RestClusterClient to submit jobs to local Dispatchers
> ------------------------------------------------------------
>
> Key: FLINK-8808
> URL: https://issues.apache.org/jira/browse/FLINK-8808
> Project: Flink
> Issue Type: Bug
> Components: REST
> Affects Versions: 1.5.0, 1.6.0
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
> Priority: Blocker
> Labels: flip-6
> Fix For: 1.5.0, 1.6.0
>
>
> The {{RestClusterClient}} should be able to submit a job to a {{Dispatcher}} which runs in a local {{ActorSystem}} on the same host as the {{RestClusterClient}}. This is the case for test cases.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)