Flink JobManager占用注册端口引起的小问题

继续超短流水账一篇。

今天午饭时间，一个向来非常稳定的Flink on YARN任务忽然持续报警。查看TaskManager日志均没有问题，但JobManager日志内报出大量Connection reset by peer信息，其中更夹杂着奇怪的错误，如下图所示。

但是作业是一直正常运行的。根据日志，可以凭直觉推测JobManager的REST endpoint出了问题（遭到了RST攻击？）

登录到JM container所在的机器，通过netstat和lsof命令找出其PID和监听的端口，发现端口号是4347。然后用tcpdump命令抓包：

tcpdump -i eth0 tcp port 4347 -XX -vv >> dump.out

抓出的一部分报文如下：

12:17:59.434870 IP (tos 0x0, ttl 61, id 34630, offset 0, flags [DF], proto TCP (6), length 60)
    172.16.200.34.36762 > ec-bigdata-flink-worker-040.lansurveyor: Flags [S], cksum 0xaa12 (correct), seq 611029849, win 64240, options [mss 1460,sackOK,TS val 285643676 ecr 0,nop,wscale 7], length 0
    0x0000:  0016 3e34 f380 eeff ffff ffff 0800 4500  ..>4..........E.
    0x0010:  003c 8746 4000 3d06 1076 ac10 c822 0a00  .<.F@.=..v..."..
    0x0020:  27cd 8f9a 10fb 246b 9359 0000 0000 a002  '.....$k.Y......
    0x0030:  faf0 aa12 0000 0204 05b4 0402 080a 1106  ................
    0x0040:  939c 0000 0000 0103 0307                 ..........
12:17:59.434890 IP (tos 0x0, ttl 64, id 0, offset 0, flags [DF], proto TCP (6), length 60)
    ec-bigdata-flink-worker-040.lansurveyor > 172.16.200.34.36762: Flags [S.], cksum 0xa62e (incorrect -> 0x3998), seq 2375752204, ack 611029850, win 28960, options [mss 1460,sackOK,TS val 3208549201 ecr 285643676,nop,wscale 9], length 0
    0x0000:  eeff ffff ffff 0016 3e34 f380 0800 4500  ........>4....E.
    0x0010:  003c 0000 4000 4006 94bc 0a00 27cd ac10  .<..@.@.....'...
    0x0020:  c822 10fb 8f9a 8d9b 1a0c 246b 935a a012  ."........$k.Z..
    0x0030:  7120 a62e 0000 0204 05b4 0402 080a bf3e  q..............>
    0x0040:  9351 1106 939c 0103 0309                 .Q........
12:17:59.440022 IP (tos 0x0, ttl 61, id 34631, offset 0, flags [DF], proto TCP (6), length 52)
    172.16.200.34.36762 > ec-bigdata-flink-worker-040.lansurveyor: Flags [.], cksum 0xd78b (correct), seq 1, ack 1, win 502, options [nop,nop,TS val 285643681 ecr 3208549201], length 0
    0x0000:  0016 3e34 f380 eeff ffff ffff 0800 4500  ..>4..........E.
    0x0010:  0034 8747 4000 3d06 107d ac10 c822 0a00  .4.G@.=..}..."..
    0x0020:  27cd 8f9a 10fb 246b 935a 8d9b 1a0d 8010  '.....$k.Z......
    0x0030:  01f6 d78b 0000 0101 080a 1106 93a1 bf3e  ...............>
    0x0040:  9351                                     .Q
12:17:59.448889 IP (tos 0x0, ttl 61, id 34632, offset 0, flags [DF], proto TCP (6), length 431)
    172.16.200.34.36762 > ec-bigdata-flink-worker-040.lansurveyor: Flags [P.], cksum 0xa379 (correct), seq 1:380, ack 1, win 502, options [nop,nop,TS val 285643690 ecr 3208549201], length 379
    0x0000:  0016 3e34 f380 eeff ffff ffff 0800 4500  ..>4..........E.
    0x0010:  01af 8748 4000 3d06 0f01 ac10 c822 0a00  ...H@.=......"..
    0x0020:  27cd 8f9a 10fb 246b 935a 8d9b 1a0d 8018  '.....$k.Z......
    0x0030:  01f6 a379 0000 0101 080a 1106 93aa bf3e  ...y...........>
    0x0040:  9351 4745 5420 2f63 6769 2d62 696e 2f63  .QGET./cgi-bin/c
    0x0050:  6f69 6e5f 696e 636c 7564 6573 2f63 6f6e  oin_includes/con
    0x0060:  7374 616e 7473 2e70 6870 3f5f 4343 4647  stants.php?_CCFG
    0x0070:  5b5f 504b 475f 5041 5448 5f49 4e43 4c5d  [_PKG_PATH_INCL]
    0x0080:  3d2f 6574 632f 7061 7373 7764 2530 3020  =/etc/passwd%00.
    0x0090:  4854 5450 2f31 2e31 0d0a 486f 7374 3a20  HTTP/1.1..Host:.
    0x00a0:  3130 2e30 2e33 392e 3230 353a 3433 3437  10.0.19.105:4347
    0x00b0:  0d0a 4163 6365 7074 2d43 6861 7273 6574  ..Accept-Charset
    0x00c0:  3a20 6973 6f2d 3838 3539 2d31 2c75 7466  :.iso-8859-1,utf
    0x00d0:  2d38 3b71 3d30 2e39 2c2a 3b71 3d30 2e31  -8;q=0.9,*;q=0.1
    0x00e0:  0d0a 4163 6365 7074 2d4c 616e 6775 6167  ..Accept-Languag
    0x00f0:  653a 2065 6e0d 0a43 6f6e 6e65 6374 696f  e:.en..Connectio
    0x0100:  6e3a 204b 6565 702d 416c 6976 650d 0a55  n:.Keep-Alive..U
    0x0110:  7365 722d 4167 656e 743a 204d 6f7a 696c  ser-Agent:.Mozil
    0x0120:  6c61 2f34 2e30 2028 636f 6d70 6174 6962  la/4.0.(compatib
    0x0130:  6c65 3b20 4d53 4945 2038 2e30 3b20 5769  le;.MSIE.8.0;.Wi
    0x0140:  6e64 6f77 7320 4e54 2035 2e31 3b20 5472  ndows.NT.5.1;.Tr
    0x0150:  6964 656e 742f 342e 3029 0d0a 5072 6167  ident/4.0)..Prag
    0x0160:  6d61 3a20 6e6f 2d63 6163 6865 0d0a 4163  ma:.no-cache..Ac
    0x0170:  6365 7074 3a20 696d 6167 652f 6769 662c  cept:.image/gif,
    0x0180:  2069 6d61 6765 2f78 2d78 6269 746d 6170  .image/x-xbitmap
    0x0190:  2c20 696d 6167 652f 6a70 6567 2c20 696d  ,.image/jpeg,.im
    0x01a0:  6167 652f 706a 7065 672c 2069 6d61 6765  age/pjpeg,.image
    0x01b0:  2f70 6e67 2c20 2a2f 2a0d 0a0d 0a         /png,.*/*....
12:17:59.448904 IP (tos 0x0, ttl 64, id 35162, offset 0, flags [DF], proto TCP (6), length 52)
    ec-bigdata-flink-worker-040.lansurveyor > 172.16.200.34.36762: Flags [.], cksum 0xa626 (incorrect -> 0xd7b4), seq 1, ack 380, win 59, options [nop,nop,TS val 3208549215 ecr 285643690], length 0
    0x0000:  eeff ffff ffff 0016 3e34 f380 0800 4500  ........>4....E.
    0x0010:  0034 895a 4000 4006 0b6a 0a00 27cd ac10  .4.Z@.@..j..'...
    0x0020:  c822 10fb 8f9a 8d9b 1a0d 246b 94d5 8010  ."........$k....
    0x0030:  003b a626 0000 0101 080a bf3e 935f 1106  .;.&.......>._..
    0x0040:  93aa                                     ..
12:17:59.449337 IP (tos 0x0, ttl 64, id 35163, offset 0, flags [DF], proto TCP (6), length 251)
    ec-bigdata-flink-worker-040.lansurveyor > 172.16.200.34.36762: Flags [P.], cksum 0xa6ed (incorrect -> 0x438a), seq 1:200, ack 380, win 59, options [nop,nop,TS val 3208549216 ecr 285643690], length 199
    0x0000:  eeff ffff ffff 0016 3e34 f380 0800 4500  ........>4....E.
    0x0010:  00fb 895b 4000 4006 0aa2 0a00 27cd ac10  ...[@.@.....'...
    0x0020:  c822 10fb 8f9a 8d9b 1a0d 246b 94d5 8018  ."........$k....
    0x0030:  003b a6ed 0000 0101 080a bf3e 9360 1106  .;.........>.`..
    0x0040:  93aa 4854 5450 2f31 2e31 2034 3034 204e  ..HTTP/1.1.404.N
    0x0050:  6f74 2046 6f75 6e64 0d0a 436f 6e74 656e  ot.Found..Conten
    0x0060:  742d 5479 7065 3a20 6170 706c 6963 6174  t-Type:.applicat
    0x0070:  696f 6e2f 6a73 6f6e 3b20 6368 6172 7365  ion/json;.charse
    0x0080:  743d 5554 462d 380d 0a43 6f6e 6e65 6374  t=UTF-8..Connect
    0x0090:  696f 6e3a 206b 6565 702d 616c 6976 650d  ion:.keep-alive.
    0x00a0:  0a63 6f6e 7465 6e74 2d6c 656e 6774 683a  .content-length:
    0x00b0:  2038 320d 0a0d 0a7b 2265 7272 6f72 7322  .82....{"errors"
    0x00c0:  3a5b 2255 6e61 626c 6520 746f 206c 6f61  :["Unable.to.loa
    0x00d0:  6420 7265 7175 6573 7465 6420 6669 6c65  d.requested.file
    0x00e0:  202f 6367 692d 6269 6e2f 636f 696e 5f69  ./cgi-bin/coin_i
    0x00f0:  6e63 6c75 6465 732f 636f 6e73 7461 6e74  ncludes/constant
    0x0100:  732e 7068 702e 225d 7d                   s.php."]}
12:17:59.454755 IP (tos 0x0, ttl 61, id 34633, offset 0, flags [DF], proto TCP (6), length 52)
    172.16.200.34.36762 > ec-bigdata-flink-worker-040.lansurveyor: Flags [.], cksum 0xd52c (correct), seq 380, ack 200, win 501, options [nop,nop,TS val 285643696 ecr 3208549216], length 0
    0x0000:  0016 3e34 f380 eeff ffff ffff 0800 4500  ..>4..........E.
    0x0010:  0034 8749 4000 3d06 107b ac10 c822 0a00  .4.I@.=..{..."..
    0x0020:  27cd 8f9a 10fb 246b 94d5 8d9b 1ad4 8010  '.....$k........
    0x0030:  01f5 d52c 0000 0101 080a 1106 93b0 bf3e  ...,...........>
    0x0040:  9360                                     .`
12:17:59.454924 IP (tos 0x0, ttl 61, id 34634, offset 0, flags [DF], proto TCP (6), length 52)
    172.16.200.34.36762 > ec-bigdata-flink-worker-040.lansurveyor: Flags [R.], cksum 0xd528 (correct), seq 380, ack 200, win 501, options [nop,nop,TS val 285643696 ecr 3208549216], length 0
    0x0000:  0016 3e34 f380 eeff ffff ffff 0800 4500  ..>4..........E.
    0x0010:  0034 874a 4000 3d06 107a ac10 c822 0a00  .4.J@.=..z..."..
    0x0020:  27cd 8f9a 10fb 246b 94d5 8d9b 1ad4 8014  '.....$k........
    0x0030:  01f5 d528 0000 0101 080a 1106 93b0 bf3e  ...(...........>
    0x0040:  9360                                     .`

以上是一个完整的循环，即“握手→互相Push消息→连接重置”（并且对方还试图请求非常敏感的数据，如/etc/passwd），所以短时间内爆出大量"Connection reset by peer"也就是不足为奇了。后来兜兜转转找到安全部门，得知他们正在进行漏洞扫描，而4347恰好是LAN Surveyor工具默认使用的端口，虚惊一场 = =

为了彻底解决问题，我们可以指定高可用JobManager的端口范围，排除掉大部分的注册端口。在flink-conf.yaml中设置：

high-availability.jobmanager.port: 35000-49150

今天帝都持续降雨，天气不好，还是早点回去吧。

民那晚安。

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 206,311评论 6赞 481
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 88,339评论 2赞 382
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 152,671评论 0赞 342
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 55,252评论 1赞 279
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 64,253评论 5赞 371
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,031评论 1赞 285
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,340评论 3赞 399
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,973评论 0赞 259
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,466评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,937评论 2赞 323
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,039评论 1赞 333
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,701评论 4赞 323
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,254评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,259评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,485评论 1赞 262
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,497评论 2赞 354
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,786评论 2赞 345

推荐阅读更多精彩内容