[jira] [Updated] (FLINK-35096) Flink OpenSearch Connector

["Martijn Visser (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-35096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Martijn Visser updated FLINK-35096:
-----------------------------------
    Component/s: Connectors / Opensearch

> Flink OpenSearch Connector
> --------------------------
>
>                 Key: FLINK-35096
>                 URL: https://issues.apache.org/jira/browse/FLINK-35096
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Opensearch
>            Reporter: Harish Sharma
>            Priority: Major
>
> Hi Team,
> I am trying to connect with the OS using the FLINK Java but as I dont find a way to pass the IAM-ROLE for the OS cluster I am not able to create the index also it does not throw any exception.
> Here is my code which I am trying to
> final DataStream<Tuple4<String, String, Long, Long>> tupleSource = env.fromCollection(users);
> final OpensearchSink<Tuple4<String, String, Long, Long>> sink =
> new OpensearchSinkBuilder<Tuple4<String, String, Long, Long>>()
> .setBulkFlushMaxActions(1)
> .setHosts(new HttpHost("aws-cluster", 443, "https"))
> .setEmitter( (element, ctx, indexer) -> {
> indexer.add(
> Requests
> .indexRequest()
> .index("users")
> .id(element.f0)
> .source(Map.ofEntries(
> Map.entry("user_id", element.f0),
> Map.entry("user_name", element.f1),
> Map.entry("uv", element.f2),
> Map.entry("pv", element.f3)
> )));
> })
> .setAllowInsecure(true)
> .setBulkFlushMaxActions(1)
> .build();
> Idly we do pass the assumeRole of the user once we wan to connect any of the managed service but I dont find a way role anywhere in the OS connector



--
This message was sent by Atlassian Jira
(v8.20.10#820010)