Kinesis Producer not working with Flink 1.11.2

[Sanket Agrawal]

Hi,

We are trying to use Kinesis along with Flink(1.11.2) and JDK 11 on EMR 
cluster(6.2). When the application starts we are getting below error:

2021-08-24 12:46:27.980 [INFO] [CONFIGURATION_BROADC] {App-N=app_name, 
App-V=3.0.0} {} 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.KinesisProducer:881
 - Extracting binaries to /tmp/amazon-kinesis-producer-native-binaries
2021-08-24 12:46:28.011 [WARN] [kpl-daemon-0003] {App-N=app_name, App-V=3.0.0} 
{} 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.LogInputStreamReader:479
 - 
/tmp/amazon-kinesis-producer-native-binaries/kinesis_producer_11BBB09B74B2C545674C3F227551D80BA4F64AA7:
 
/tmp/amazon-kinesis-producer-native-binaries/kinesis_producer_11BBB09B74B2C545674C3F227551D80BA4F64AA7:
 cannot execute binary file
2021-08-24 12:46:28.007 [ERROR] [kpl-daemon-0000] {App-N=app_name, App-V=3.0.0} 
{} 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.KinesisProducer:152
 - Error in child process
java.lang.RuntimeException: Child process exited with code 126
                at 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:533)
 [app_name.jar:?]
                at 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:509)
 [app_name.jar:?]
                at 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon.startChildProcess(Daemon.java:487)
 [app_name.jar:?]
                at 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon.access$100(Daemon.java:63)
 [app_name.jar:?]
                at 
org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon.java:133)
 [app_name.jar:?]
                at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) 
[?:?]
                at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) 
[?:?]
                at java.lang.Thread.run(Thread.java:829) [?:?]

Used libraries and respective versions are as follows:

  1.  flink-connector-kinesis_2.12 - 1.11.2
  2.  aws-java-sdk-kinesis - 1.11.880
  3.  ​amazon-kinesis-client - 2.2.9

Any help on this would be really helpful.

Thanks,
Sanket