AWS manged Flink sinkto S3 not working , Getting connection timeout error and ssl co

0

Enter image description here We are working on POC , AWS managed Kafka is source which sends the JSON documents , AWS managed Flink connect s to AWS Kafka and process the JSON document and writes to S3 , The problem what we are facing is Flink could connect to Kafka , but while writing to S3 it is not ingesting to S3 , Could not understand the reason attached the image , it seems always busy and writing any thing , Please suggest

3回答
1

It looks like the application is spending 100% of its time trying to connect to a socket, as indicated by the stack trace involving java.net.Socket.connect, and specifically SSLConnectionFactory.connectSocket. This suggests that the Flink job is not proceeding to the S3 write operation because it is stuck trying to establish an SSL connection, likely to Kafka, as there is no indication of S3 specific API calls in the stack trace.

Try these steps:

  1. Verify that the Flink application has the correct network access to the Kafka brokers and that no firewall or security group is blocking the required ports.
  2. If you're using SSL/TLS for the Kafka connection, verify that your truststore and keystore configurations are correct and that the Flink application can access the necessary files with the correct passwords.
  3. The problem seems to be before the S3 write operation, so make sure that the Flink application has the right permissions and configurations to write to the specified S3 bucket.

If you're unfamiliar with how to verify a security group, you can find detailed instructions in this article Networking 101 - Part 2, specifically in the section about security groups.

profile picture
エキスパート
回答済み 1ヶ月前
0

Seems like a connection issue. Have you checked eventual firewall rules that could block the communication?

profile pictureAWS
回答済み 1ヶ月前
0

Hi Cristian , Thanks for reply , Kindly suggest what are checks that I have to look in for firewall , We are at POC stage , If you could give step by step doc that could be great , We are building data pipelines source is aws managed kafka , AWS managed Flink process the JSON doc and write to S3 .. please sugest what are the checks that I look in here ,

Thanks

mk
回答済み 1ヶ月前

ログインしていません。 ログイン 回答を投稿する。

優れた回答とは、質問に明確に答え、建設的なフィードバックを提供し、質問者の専門分野におけるスキルの向上を促すものです。

質問に答えるためのガイドライン

関連するコンテンツ