Skip to content

Conversation

@15656215623
Copy link
Contributor

@15656215623 15656215623 commented Aug 16, 2022

Purpose of this pull request

Which issue you fix

Fixes # (issue).

Checklist:

  • I have executed the 'mvn spotless:apply' command to format my code.
  • I have a meaningful commit message (including the issue id, the template of commit message is '[label-type-#issue-id][fixed-module] a meaningful commit message.')
  • I have performed a self-review of my own code.
  • I have commented my code, particularly in hard-to-understand areas.
  • I have made corresponding changes to the documentation.
  • I have added tests that prove my fix is effective or that my feature works.
  • New and existing unit tests pass locally with my changes.
  • I have checked my code and corrected any misspellings.
  • My commit is only one. (If there are multiple commits, you can use 'git squash' to compress multiple commits into one.)

@15656215623
Copy link
Contributor Author

emqx这个插件作为sink,接受大量数据的时候,运行3h以上就会报错,无法连接。然后看了源码,发现没有设置emqx断线重连机制;所以本人改了一些源码,做了测试,运行大概5d21h ,发现都没出现报错信息!
image
数据插入正常,之前都是flink页面没异常,但是日志报错,不再往tdengine数据库里面插入数据,处于掉线情况!
经改良,运行接近6d 都正常
image

@15656215623
Copy link
Contributor Author

现在是之前的至少47倍

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant