RE: Flink - OpenSearch connector query

2024-02-22 Thread Praveen Chandna via user
Hello Request you to please share, how to proceed ? I need to create Index with custom settings (no. of shards and replicas etc.) Thanks !! From: Praveen Chandna via user Sent: Wednesday, February 21, 2024 3:57 PM To: Praveen Chandna via user Subject: Flink - OpenSearch connector query

Flink - OpenSearch connector query

2024-02-21 Thread Praveen Chandna via user
Hello As per the OpenSearch connector documentation, OpensearchEmitter can be used to perform requests of different types i.e., IndexRequest, DeleteRequest, UpdateRequest etc. https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/datastream/opensearch/#configuring-the-inter

RE: Flink connection with AWS OpenSearch Service

2024-02-12 Thread Praveen Chandna via user
Hello Request you to please update. Thanks !! From: Praveen Chandna via user Sent: Friday, February 9, 2024 2:46 PM To: Praveen Chandna via user Subject: Flink connection with AWS OpenSearch Service Hello As per the Flink OpenSearch connector documentation, it specify how to connect to

Flink connection with AWS OpenSearch Service

2024-02-09 Thread Praveen Chandna via user
Hello As per the Flink OpenSearch connector documentation, it specify how to connect to OpenSearch database. But it doesn't mention anything how to connect with the AWS OpenSearch service. https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/datastream/opensearch/ Whereas

Flink release plan

2024-01-10 Thread Praveen Chandna via user
Hello Once Flink 2.0 will be released in Dec 2024, what would be the release plan for Flink 1.x ? Those who are using the Flink 1.20 or earlier releases, do they need to migrate to Flink 2.0 for Bug Fixes or Flink 1.x release track will be active for Bug fixes. Thanks !! // Regards Praveen Ch

RE: Re:RE: Flink - Java 17 support

2023-12-19 Thread Praveen Chandna via user
on ? Thanks !! From: Praveen Chandna Sent: 17 December 2023 21:28 To: Praveen Chandna via user mailto:user@flink.apache.org>> Subject: Flink - Java 17 support Hello In the Flink version 1.18, there is experimental support for Java 17. What is the plan for Java 17 supported release of Fl

RE: Flink - Java 17 support

2023-12-19 Thread Praveen Chandna via user
Chandna via user Subject: Flink - Java 17 support Hello In the Flink version 1.18, there is experimental support for Java 17. What is the plan for Java 17 supported release of Flink ? As the below Jira is already closed for Java 17 support. https://issues.apache.org/jira/browse/FLINK-15736

RE: Java 8 support in Flink 1.18

2023-12-18 Thread Praveen Chandna via user
Thanks a lot for quick response. From: Junrui Lee Sent: 18 December 2023 15:57 To: Praveen Chandna via user Cc: Praveen Chandna Subject: Re: Java 8 support in Flink 1.18 Hello, Praveen According to the Flink release-2.0 wiki page (https://cwiki.apache.org/confluence/display/FLINK/2.0

Java 8 support in Flink 1.18

2023-12-18 Thread Praveen Chandna via user
Hello Team As per the Flink 1.15 release notes, Java 8 support has been deprecated. Will there be any impact ? Can I continue to use Java 8 or is there any risk ? Thanks !! // Regards Praveen Chandna

Flink - Java 17 support

2023-12-17 Thread Praveen Chandna via user
Hello In the Flink version 1.18, there is experimental support for Java 17. What is the plan for Java 17 supported release of Flink ? As the below Jira is already closed for Java 17 support. https://issues.apache.org/jira/browse/FLINK-15736 Thanks !! // Regards Praveen Chandna

OpenSearch connector for Flink version 1.18

2023-12-12 Thread Praveen Chandna via user
Hello In the Flink version 1.18, the connector for OpenSearch sink is not available. It's mentioned "There is no connector (yet) available for Flink version 1.18." https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/datastream/opensearch/ What is the plan, when will the c

Flink OpenSearch Connector - Avro JSON to JSON

2023-11-20 Thread Praveen Chandna via user
Hello Team Please helps to answer the below query. 1. OpenSearch supports writing data in the JSON format, but in Flink its default data format is Avro JSON. What is the best practice to write data to Open Search using Flink OpenSearch Connector? Do we need to manually convert Avro JSON to