You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/05/24 02:19:00 UTC
[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally
[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488314#comment-16488314 ]
mingleizhang commented on FLINK-9429:
-------------------------------------
Hi, [~till.rohrmann]. Have you build flink again ? I tested on my local machine. Looks good. Below are the result .
{code:java}
Success: There are no flink core classes are contained in the jar.
Success: Elasticsearch5SinkExample.class and other user classes are included in the jar.
Downloading Elasticsearch from https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-5.1.2.tar.gz ...
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
100 31.7M 100 31.7M 0 0 234k 0 0:02:18 0:02:18 --:--:-- 280k
Elasticsearch node is running.
Starting cluster.
Starting standalonesession daemon on host zhangmingleideMacBook-Pro.local.
[2018-05-24T10:10:42,017][INFO ][o.e.n.Node ] [] initializing ...
[2018-05-24T10:10:42,166][INFO ][o.e.e.NodeEnvironment ] [tmBMe7q] using [1] data paths, mounts [[/ (/dev/disk1)]], net usable_space [286.6gb], net total_space [464.6gb], spins? [unknown], types [hfs]
[2018-05-24T10:10:42,167][INFO ][o.e.e.NodeEnvironment ] [tmBMe7q] heap size [1.9gb], compressed ordinary object pointers [true]
[2018-05-24T10:10:42,171][INFO ][o.e.n.Node ] node name [tmBMe7q] derived from node ID [tmBMe7q8QHWuji0qmmKnAw]; set [node.name] to override
[2018-05-24T10:10:42,174][INFO ][o.e.n.Node ] version[5.1.2], pid[8378], build[c8c4c16/2017-01-11T20:18:39.146Z], OS[Mac OS X/10.12.3/x86_64], JVM[Oracle Corporation/Java HotSpot(TM) 64-Bit Server VM/1.8.0_161/25.161-b12]
Starting taskexecutor daemon on host zhangmingleideMacBook-Pro.local.
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
[2018-05-24T10:10:43,915][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [aggs-matrix-stats]
[2018-05-24T10:10:43,915][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [ingest-common]
[2018-05-24T10:10:43,915][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [lang-expression]
[2018-05-24T10:10:43,915][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [lang-groovy]
[2018-05-24T10:10:43,915][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [lang-mustache]
[2018-05-24T10:10:43,915][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [lang-painless]
[2018-05-24T10:10:43,916][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [percolator]
[2018-05-24T10:10:43,916][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [reindex]
[2018-05-24T10:10:43,916][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [transport-netty3]
[2018-05-24T10:10:43,916][INFO ][o.e.p.PluginsService ] [tmBMe7q] loaded module [transport-netty4]
[2018-05-24T10:10:43,917][INFO ][o.e.p.PluginsService ] [tmBMe7q] no plugins loaded
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
[2018-05-24T10:10:49,112][INFO ][o.e.n.Node ] initialized
[2018-05-24T10:10:49,113][INFO ][o.e.n.Node ] [tmBMe7q] starting ...
Dispatcher REST endpoint is up.
[2018-05-24T10:10:49,716][INFO ][o.e.t.TransportService ] [tmBMe7q] publish_address {127.0.0.1:9300}, bound_addresses {[fe80::1]:9300}, {[::1]:9300}, {127.0.0.1:9300}
Starting execution of program
[2018-05-24T10:10:52,873][INFO ][o.e.c.s.ClusterService ] [tmBMe7q] new_master {tmBMe7q}{tmBMe7q8QHWuji0qmmKnAw}{bo3RSiiLQuGOwWNXFx6QMA}{127.0.0.1}{127.0.0.1:9300}, reason: zen-disco-elected-as-master ([0] nodes joined)
[2018-05-24T10:10:52,899][INFO ][o.e.h.HttpServer ] [tmBMe7q] publish_address {127.0.0.1:9200}, bound_addresses {[fe80::1]:9200}, {[::1]:9200}, {127.0.0.1:9200}
[2018-05-24T10:10:52,899][INFO ][o.e.n.Node ] [tmBMe7q] started
[2018-05-24T10:10:52,904][INFO ][o.e.g.GatewayService ] [tmBMe7q] recovered [0] indices into cluster_state
[2018-05-24T10:10:53,616][INFO ][o.e.c.m.MetaDataCreateIndexService] [tmBMe7q] [index] creating index, cause [auto(bulk api)], templates [], shards [5]/[1], mappings []
[2018-05-24T10:10:53,917][INFO ][o.e.c.m.MetaDataMappingService] [tmBMe7q] [index/84rcQ1-OQ6-pUE6djxuxTw] create_mapping [type]
Program execution finished
Job with JobID 574e9c30fd1d86ce6848cd72c103cb55 has finished.
Job Runtime: 2484 ms
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
100 194 100 194 0 0 958 0 --:--:-- --:--:-- --:--:-- 960
Waiting for Elasticsearch records ...
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
100 3997 100 3997 0 0 104k 0 --:--:-- --:--:-- --:--:-- 105k
Elasticsearch end to end test pass.
Stopping taskexecutor daemon (pid: 9093) on host zhangmingleideMacBook-Pro.local.
Stopping standalonesession daemon (pid: 8801) on host zhangmingleideMacBook-Pro.local.
./common.sh: line 171: 8378 Killed: 9 $elasticsearchDir/bin/elasticsearch
No zookeeper daemon to stop on host zhangmingleideMacBook-Pro.local.
All tests PASS
{code}
> Quickstart E2E not working locally
> ----------------------------------
>
> Key: FLINK-9429
> URL: https://issues.apache.org/jira/browse/FLINK-9429
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 1.5.0, 1.6.0
> Reporter: Till Rohrmann
> Assignee: mingleizhang
> Priority: Critical
> Labels: test-stability
>
> The quickstart e2e test is not working locally. It seems as if the job does not produce anything into Elasticsearch. Furthermore, the test does not terminate with control-C.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)