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

mk
asked 20 days ago85 views
3 Answers
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
EXPERT
answered 20 days ago
0

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

profile pictureAWS
answered 20 days ago
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
answered 20 days ago

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions