Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

SDK: Add support for communication between SDK and OpenSearch #2351

Closed
4 tasks done
owaiskazi19 opened this issue Mar 4, 2022 · 4 comments
Closed
4 tasks done

SDK: Add support for communication between SDK and OpenSearch #2351

owaiskazi19 opened this issue Mar 4, 2022 · 4 comments
Labels
Build Libraries & Interfaces enhancement Enhancement or improvement to existing feature or request

Comments

@owaiskazi19
Copy link
Member

owaiskazi19 commented Mar 4, 2022 •
edited
Loading

Is your feature request related to a problem? Please describe.
A request coming to the TransportService required to be decoded, adding a protocol to it and making sure headers are present in it. Once the request is validated invoke the right extension point.

  • Get the right message protocol for TransportRequest
  • Serialize/Deserialize request for TransportService
  • Establish communication between OpenSearch and SDK
  • Send a PluginResponse from SDK to OpenSearch

Describe the solution you'd like
A clear and concise description of what you want to happen.

Describe alternatives you've considered
A clear and concise description of any alternative solutions or features you've considered.

Additional context
Add any other context or screenshots about the feature request here.
@owaiskazi19 owaiskazi19 added enhancement Enhancement or improvement to existing feature or request untriaged labels Mar 4, 2022
@owaiskazi19 owaiskazi19 mentioned this issue Mar 4, 2022
Open
@owaiskazi19 owaiskazi19 mentioned this issue Mar 9, 2022
Closed
5 tasks
@owaiskazi19
Copy link
Member Author

Logs of connection bewteen SDK and OpenSearch :

14:46:56.261 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#4]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0x7e76a4e2, L:/127.0.0.1:60282 - R:/127.0.0.1:61466] REGISTERED
14:46:56.261 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#11]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf2d5bf4f, L:/127.0.0.1:60282 - R:/127.0.0.1:61473] ACTIVE

14:46:56.302 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xb63a78ca, L:/127.0.0.1:60282 - R:/127.0.0.1:61474] READ: 55B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 31 00 00 00 00 00 00 00 01 08 00 |ES...1..........|
|00000010| 6c 56 5f 00 00 00 1a 00 00 00 16 69 6e 74 65 72 |lV_........inter|
|00000020| 6e 61 6c 3a 74 63 70 2f 68 61 6e 64 73 68 61 6b |nal:tcp/handshak|
|00000030| 65 00 04 e3 89 fa 40                            |e.....@         |
+--------+-------------------------------------------------+----------------+
MESSAGE RECEIVED:ESlV_internal:tcp/handshake㉺@

OpenSearch sent an internal tcp handshake request to the SDK.

@owaiskazi19 owaiskazi19 mentioned this issue Mar 18, 2022
Closed
7 tasks
@owaiskazi19
Copy link
Member Author

Created TCP handshake and communication between SDK and OpenSearch.

SDK:

15:11:08.557 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf82fe48b, L:/127.0.0.1:56799 - R:/127.0.0.1:57120] READ: 55B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 31 00 00 00 00 00 00 00 01 08 00 |ES...1..........|
|00000010| 6c 56 5f 00 00 00 1a 00 00 00 16 69 6e 74 65 72 |lV_........inter|
|00000020| 6e 61 6c 3a 74 63 70 2f 68 61 6e 64 73 68 61 6b |nal:tcp/handshak|
|00000030| 65 00 04 e3 89 fa 40                            |e.....@         |
+--------+-------------------------------------------------+----------------+
MESSAGE RECEIVED:ESlV_internal:tcp/handshake㉺@
15:11:08.572 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:56799, remoteAddress=/127.0.0.1:57120} [length: 55, request id: 1, type: request, version: 7.9.99, action: internal:tcp/handshake] READ: 55B
15:11:08.576 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE org.opensearch.transport.TransportService.tracer - [1][internal:tcp/handshake] received request
15:11:08.589 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:56799, remoteAddress=/127.0.0.1:57120} [length: 29, request id: 1, type: response, version: 7.9.99, header size: 2B] WRITE: 29B
15:11:08.600 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf82fe48b, L:/127.0.0.1:56799 - R:/127.0.0.1:57120] WRITE: 29B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 17 00 00 00 00 00 00 00 01 09 00 |ES..............|
|00000010| 6c 56 5f 00 00 00 02 00 00 e3 89 fa 40          |lV_.........@   |
+--------+-------------------------------------------------+----------------+
15:11:08.602 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf82fe48b, L:/127.0.0.1:56799 - R:/127.0.0.1:57120] FLUSH
15:11:08.608 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#12]] TRACE org.opensearch.transport.TransportService.tracer - [1][internal:tcp/handshake] sent response
15:11:08.626 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf4bf02d7, L:/127.0.0.1:56799 - R:/127.0.0.1:57114] READ: 56B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 32 00 00 00 00 00 00 00 02 00 08 |ES...2..........|
|00000010| 1e 84 e3 00 00 00 20 00 00 00 1c 69 6e 74 65 72 |...... ....inter|
|00000020| 6e 61 6c 3a 74 72 61 6e 73 70 6f 72 74 2f 68 61 |nal:transport/ha|
|00000030| 6e 64 73 68 61 6b 65 00                         |ndshake.        |
+--------+-------------------------------------------------+----------------+
MESSAGE RECEIVED:ES�　 internal:transport/handshake
15:11:08.626 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:56799, remoteAddress=/127.0.0.1:57114} [length: 56, request id: 2, type: request, version: 2.0.0, action: internal:transport/handshake] READ: 56B
15:11:08.627 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE org.opensearch.transport.TransportService.tracer - [2][internal:transport/handshake] received request
15:11:08.627 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE org.opensearch.tasks.TaskManager - register 1 [transport] [internal:transport/handshake] []
15:11:08.629 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE org.opensearch.tasks.TaskManager - unregister task for id: 1
15:11:08.630 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:56799, remoteAddress=/127.0.0.1:57114} [length: 187, request id: 2, type: response, version: 2.0.0, header size: 2B] WRITE: 187B
15:11:08.631 [opensearch[NettySizeHeaderFrameDecoderTests][transport_worker][T#6]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf4bf02d7, L:/127.0.0.1:56799 - R:/127.0.0.1:57114] WRITE: 187B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 b5 00 00 00 00 00 00 00 02 01 08 |ES..............|
|00000010| 1e 84 e3 00 00 00 02 00 00 01 00 0e 6e 6f 64 65 |............node|
|00000020| 5f 65 78 74 65 6e 73 69 6f 6e 16 6c 6b 54 68 50 |_extension.lkThP|
|00000030| 6d 2d 53 53 6b 4b 6b 69 64 37 59 41 39 55 55 69 |m-SSkKkid7YA9UUi|
|00000040| 77 09 31 32 37 2e 30 2e 30 2e 31 09 31 32 37 2e |w.127.0.0.1.127.|
|00000050| 30 2e 30 2e 31 04 7f 00 00 01 09 31 32 37 2e 30 |0.0.1......127.0|
|00000060| 2e 30 2e 31 00 00 c5 9a 00 04 0f 63 6c 75 73 74 |.0.1.......clust|
|00000070| 65 72 5f 6d 61 6e 61 67 65 72 01 6d 00 04 64 61 |er_manager.m..da|
|00000080| 74 61 01 64 01 06 69 6e 67 65 73 74 01 69 00 15 |ta.d..ingest.i..|
|00000090| 72 65 6d 6f 74 65 5f 63 6c 75 73 74 65 72 5f 63 |remote_cluster_c|
|000000a0| 6c 69 65 6e 74 01 72 00 e3 89 fa 40 0a 6f 70 65 |lient.r....@.ope|
|000000b0| 6e 73 65 61 72 63 68 e3 89 fa 40                |nsearch...@     |
+--------+-------------------------------------------------+----------------+

OpenSearch:

[2022-03-23T15:11:09,107][DEBUG][o.o.c.c.Coordinator      ] [runTask-0] startInitialJoin: coordinator becoming CANDIDATE in term 0 (was null, lastKnownLeader was [Optional.empty])
[2022-03-23T15:11:09,110][INFO ][o.o.c.c.Coordinator      ] [runTask-0] setting initial configuration to VotingConfiguration{mT7OwjXWTnC4DU8U1EfpHw}
[2022-03-23T15:11:09,111][WARN ][o.o.d.FileBasedSeedHostsProvider] [runTask-0] expected, but did not find, a dynamic hosts list at [/Users/kazabdu/sarat/OpenSearch/build/testclusters/runTask-0/config/unicast_hosts.txt]
[2022-03-23T15:11:09,309][DEBUG][o.o.c.c.ElectionSchedulerFactory] [runTask-0] scheduling scheduleNextElection{gracePeriod=0s, thisAttempt=0, maxDelayMillis=100, delayMillis=9, ElectionScheduler{attempt=1, ElectionSchedulerFactory{initialTimeout=100ms, backoffTime=100ms, maxTimeout=10s}}}
[2022-03-23T15:11:09,320][DEBUG][o.o.c.c.ElectionSchedulerFactory] [runTask-0] scheduleNextElection{gracePeriod=0s, thisAttempt=0, maxDelayMillis=100, delayMillis=9, ElectionScheduler{attempt=1, ElectionSchedulerFactory{initialTimeout=100ms, backoffTime=100ms, maxTimeout=10s}}} starting election
[2022-03-23T15:11:09,326][INFO ][o.o.h.AbstractHttpServerTransport] [runTask-0] publish_address {127.0.0.1:9200}, bound_addresses {[::1]:9200}, {127.0.0.1:9200}
[2022-03-23T15:11:09,352][DEBUG][o.o.c.c.ElectionSchedulerFactory] [runTask-0] scheduling scheduleNextElection{gracePeriod=500ms, thisAttempt=1, maxDelayMillis=200, delayMillis=578, ElectionScheduler{attempt=2, ElectionSchedulerFactory{initialTimeout=100ms, backoffTime=100ms, maxTimeout=10s}}}
[2022-03-23T15:11:09,353][INFO ][o.o.n.Node               ] [runTask-0] started
[2022-03-23T15:11:09,354][DEBUG][o.o.c.c.PreVoteCollector ] [runTask-0] PreVotingRound{preVotesReceived={}, electionStarted=false, preVoteRequest=PreVoteRequest{sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, currentTerm=0}, isClosed=false} requesting pre-votes from [{runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}]
[2022-03-23T15:11:09,354][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest trying for connection to node: {runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}
[2022-03-23T15:11:09,354][INFO ][o.o.t.TransportService   ] [runTask-0] Getting localnodeConnection runTask-0
[2022-03-23T15:11:09,354][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest internal:cluster/request_pre_vote
[2022-03-23T15:11:09,354][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:cluster/request_pre_vote
[2022-03-23T15:11:09,354][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest localnode connection internal:cluster/request_pre_vote
[2022-03-23T15:11:09,355][INFO ][o.o.t.TransportService   ] [runTask-0] sendLocalRequest internal:cluster/request_pre_vote PreVoteRequest{sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, currentTerm=0}
[2022-03-23T15:11:09,355][INFO ][o.o.t.TransportService   ] [runTask-0] [3][internal:cluster/request_pre_vote] sent to [{runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}] (timeout: [null])
[2022-03-23T15:11:09,355][INFO ][o.o.t.TransportService   ] [runTask-0] sendLocalRequest RequestHandler org.opensearch.cluster.coordination.PreVoteCollector$$Lambda$2188/0x000000080128e840@233a8764
[2022-03-23T15:11:09,357][DEBUG][o.o.c.c.PreVoteCollector ] [runTask-0] PreVotingRound{preVotesReceived={{runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}=PreVoteResponse{currentTerm=0, lastAcceptedTerm=0, lastAcceptedVersion=0}}, electionStarted=true, preVoteRequest=PreVoteRequest{sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, currentTerm=0}, isClosed=false} added PreVoteResponse{currentTerm=0, lastAcceptedTerm=0, lastAcceptedVersion=0} from {runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, starting election
[2022-03-23T15:11:09,358][DEBUG][o.o.c.c.Coordinator      ] [runTask-0] starting election with StartJoinRequest{term=1,node={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}}
[2022-03-23T15:11:09,358][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest trying for connection to node: {runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}
[2022-03-23T15:11:09,358][INFO ][o.o.t.TransportService   ] [runTask-0] Getting localnodeConnection runTask-0
[2022-03-23T15:11:09,358][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest internal:cluster/coordination/start_join
[2022-03-23T15:11:09,358][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:cluster/coordination/start_join
[2022-03-23T15:11:09,358][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest localnode connection internal:cluster/coordination/start_join
[2022-03-23T15:11:09,359][INFO ][o.o.t.TransportService   ] [runTask-0] sendLocalRequest internal:cluster/coordination/start_join StartJoinRequest{term=1,node={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}}
[2022-03-23T15:11:09,359][INFO ][o.o.t.TransportService   ] [runTask-0] [4][internal:cluster/coordination/start_join] sent to [{runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}] (timeout: [null])
[2022-03-23T15:11:09,359][INFO ][o.o.t.TransportService   ] [runTask-0] sendLocalRequest RequestHandler org.opensearch.cluster.coordination.JoinHelper$$Lambda$2181/0x000000080128cc40@10134cdf
[2022-03-23T15:11:09,359][DEBUG][o.o.c.c.Coordinator      ] [runTask-0] joinLeaderInTerm: for [{runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}] with term 1
[2022-03-23T15:11:09,359][DEBUG][o.o.c.c.CoordinationState] [runTask-0] handleStartJoin: leaving term [0] due to StartJoinRequest{term=1,node={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}}
[2022-03-23T15:11:09,613][DEBUG][o.o.c.c.JoinHelper       ] [runTask-0] attempting to join {runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true} with JoinRequest{sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, minimumTerm=0, optionalJoin=Optional[Join{term=1, lastAcceptedTerm=0, lastAcceptedVersion=0, sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, targetNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}}]}
[2022-03-23T15:11:09,614][INFO ][o.o.t.TransportService   ] [runTask-0] Getting localnodeConnection runTask-0
[2022-03-23T15:11:09,614][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:cluster/coordination/join
[2022-03-23T15:11:09,614][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest localnode connection internal:cluster/coordination/join
[2022-03-23T15:11:09,615][INFO ][o.o.t.TransportService   ] [runTask-0] sendLocalRequest internal:cluster/coordination/join JoinRequest{sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, minimumTerm=0, optionalJoin=Optional[Join{term=1, lastAcceptedTerm=0, lastAcceptedVersion=0, sourceNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}, targetNode={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}}]}
[2022-03-23T15:11:09,615][INFO ][o.o.t.TransportService   ] [runTask-0] [5][internal:cluster/coordination/join] sent to [{runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}] (timeout: [null])
[2022-03-23T15:11:09,615][INFO ][o.o.t.TransportService   ] [runTask-0] sendLocalRequest RequestHandler org.opensearch.cluster.coordination.JoinHelper$$Lambda$2179/0x000000080128c440@4bf0860a
[2022-03-23T15:11:09,616][DEBUG][o.o.c.c.JoinHelper       ] [runTask-0] successful response to StartJoinRequest{term=1,node={runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}} from {runTask-0}{mT7OwjXWTnC4DU8U1EfpHw}{ReGc4YMFRS-aamPSa8nYJg}{127.0.0.1}{127.0.0.1:9300}{dimr}{testattr=test, shard_indexing_pressure_enabled=true}

@owaiskazi19
Copy link
Member Author

owaiskazi19 commented Mar 31, 2022 •
edited
Loading

Communication is established between OpenSearch and SDK.

Logs of SDK:

12:23:59.076 [opensearch[node_extension][transport_worker][T#3]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf92851aa, L:/127.0.0.1:4532 - R:/127.0.0.1:61942] WRITE: 200B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 c2 00 00 00 00 00 00 00 02 01 08 |ES..............|
|00000010| 1e 84 e3 00 00 00 02 00 00 01 0e 6e 6f 64 65 5f |...........node_|
|00000020| 65 78 74 65 6e 73 69 6f 6e 16 71 4f 38 6d 52 54 |extension.qO8mRT|
|00000030| 79 68 54 72 79 45 67 64 6c 45 6a 76 61 67 6b 67 |yhTryEgdlEjvagkg|
|00000040| 16 57 48 47 76 32 4a 71 6b 52 50 57 76 64 6b 4c |.WHGv2JqkRPWvdkL|
|00000050| 5f 35 6f 39 48 41 77 09 31 32 37 2e 30 2e 30 2e |_5o9HAw.127.0.0.|
|00000060| 31 09 31 32 37 2e 30 2e 30 2e 31 04 7f 00 00 01 |1.127.0.0.1.....|
|00000070| 09 31 32 37 2e 30 2e 30 2e 31 00 00 11 b4 00 e3 |.127.0.0.1......|
|00000080| 89 fa 40 04 04 64 61 74 61 01 64 01 06 69 6e 67 |..@..data.d..ing|
|00000090| 65 73 74 01 69 00 06 6d 61 73 74 65 72 01 6d 00 |est.i..master.m.|
|000000a0| 15 72 65 6d 6f 74 65 5f 63 6c 75 73 74 65 72 5f |.remote_cluster_|
|000000b0| 63 6c 69 65 6e 74 01 72 00 0a 6f 70 65 6e 73 65 |client.r..opense|
|000000c0| 61 72 63 68 e3 89 fa 40                         |arch...@        |
+--------+-------------------------------------------------+----------------+
12:23:59.076 [opensearch[node_extension][transport_worker][T#3]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf92851aa, L:/127.0.0.1:4532 - R:/127.0.0.1:61942] FLUSH
12:23:59.077 [opensearch[node_extension][transport_worker][T#3]] TRACE org.opensearch.transport.TransportService.tracer - [2][internal:transport/handshake] sent response
12:23:59.085 [opensearch[node_extension][transport_worker][T#8]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xfa0aa34f, L:/127.0.0.1:4532 - R:/127.0.0.1:61948] READ: 195B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 bd 00 00 00 00 00 00 00 03 00 08 |ES..............|
|00000010| 1e 84 e3 00 00 00 21 00 00 00 1d 69 6e 74 65 72 |......!....inter|
|00000020| 6e 61 6c 3a 64 69 73 63 6f 76 65 72 79 2f 65 78 |nal:discovery/ex|
|00000030| 74 65 6e 73 69 6f 6e 73 00 00 0e 6e 6f 64 65 5f |tensions...node_|
|00000040| 65 78 74 65 6e 73 69 6f 6e 16 67 64 63 70 32 70 |extension.gdcp2p|
|00000050| 73 61 53 5f 53 73 4c 6a 31 62 45 49 77 46 4b 41 |saS_SsLj1bEIwFKA|
|00000060| 09 31 32 37 2e 30 2e 30 2e 31 09 31 32 37 2e 30 |.127.0.0.1.127.0|
|00000070| 2e 30 2e 31 04 7f 00 00 01 09 31 32 37 2e 30 2e |.0.1......127.0.|
|00000080| 30 2e 31 00 00 11 b4 00 e3 89 fa 40 04 04 64 61 |0.1........@..da|
|00000090| 74 61 01 64 01 06 69 6e 67 65 73 74 01 69 00 06 |ta.d..ingest.i..|
|000000a0| 6d 61 73 74 65 72 01 6d 00 15 72 65 6d 6f 74 65 |master.m..remote|
|000000b0| 5f 63 6c 75 73 74 65 72 5f 63 6c 69 65 6e 74 01 |_cluster_client.|
|000000c0| 72 00 00                                        |r..             |
+--------+-------------------------------------------------+----------------+
MESSAGE RECEIVED:ES�　!internal:discovery/extensionsnode_extensiongdcp2psaS_SsLj1bEIwFKA 127.0.0.1       127.0.0.1�  127.0.0.1´㉺@datadingestimastermremote_cluster_clientr
12:23:59.086 [opensearch[node_extension][transport_worker][T#8]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:4532, remoteAddress=/127.0.0.1:61948} [length: 195, request id: 3, type: request, version: 2.0.0, action: internal:discovery/extensions] READ: 195B
12:23:59.086 [opensearch[node_extension][transport_worker][T#8]] TRACE org.opensearch.transport.TransportService.tracer - [3][internal:discovery/extensions] received request
12:23:59.090 [opensearch[node_extension][generic][T#1]] TRACE org.opensearch.tasks.TaskManager - register 2 [transport] [internal:discovery/extensions] []
12:23:59.091 [opensearch[node_extension][generic][T#1]] INFO  transportservice.RunPlugin - Handling Plugins Request
12:23:59.091 [opensearch[node_extension][generic][T#1]] TRACE org.opensearch.tasks.TaskManager - unregister task for id: 2
12:23:59.091 [opensearch[node_extension][generic][T#1]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:4532, remoteAddress=/127.0.0.1:61948} [length: 39, request id: 3, type: response, version: 2.0.0, header size: 2B] WRITE: 39B
12:23:59.093 [opensearch[node_extension][transport_worker][T#8]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xfa0aa34f, L:/127.0.0.1:4532 - R:/127.0.0.1:61948] WRITE: 39B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 21 00 00 00 00 00 00 00 03 01 08 |ES...!..........|
|00000010| 1e 84 e3 00 00 00 02 00 00 0d 52 65 61 6c 45 78 |..........RealEx|
|00000020| 74 65 6e 73 69 6f 6e                            |tension         |
+--------+-------------------------------------------------+----------------+
12:23:59.094 [opensearch[node_extension][transport_worker][T#8]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xfa0aa34f, L:/127.0.0.1:4532 - R:/127.0.0.1:61948] FLUSH
12:23:59.094 [opensearch[node_extension][transport_worker][T#8]] TRACE org.opensearch.transport.TransportService.tracer - [3][internal:discovery/extensions] sent response

Logs of OpenSearch:

[2022-03-31T12:23:58,826][INFO ][o.o.t.TransportService   ] [runTask-0] connectToNode Connecting to node {node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode {node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 1.
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 2.
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 3.
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 5.
[2022-03-31T12:23:58,888][INFO ][o.o.t.TransportService   ] [runTask-0] [1][internal:tcp/handshake] sent to [{node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}] (timeout: [null])
[2022-03-31T12:23:59,062][INFO ][o.o.t.InboundHandler     ] [runTask-0] STREAM HERE
[2022-03-31T12:23:59,068][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:transport/handshake
[2022-03-31T12:23:59,071][INFO ][o.o.t.TransportService   ] [runTask-0] [2][internal:transport/handshake] sent to [{node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}] (timeout: [30s])
[2022-03-31T12:23:59,079][INFO ][o.o.t.InboundHandler     ] [runTask-0] STREAM HERE
[2022-03-31T12:23:59,082][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest trying for connection to node: {node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}
[2022-03-31T12:23:59,082][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest internal:discovery/extensions
[2022-03-31T12:23:59,082][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:discovery/extensions
[2022-03-31T12:23:59,084][INFO ][o.o.t.TransportService   ] [runTask-0] [3][internal:discovery/extensions] sent to [{node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}] (timeout: [null])
[2022-03-31T12:23:59,094][INFO ][o.o.t.InboundHandler     ] [runTask-0] STREAM HERE
[2022-03-31T12:23:59,095][INFO ][o.o.p.PluginsOrchestrator] [runTask-0] received PluginResponse{nameRealExtension}
[2022-03-31T12:23:59,407][DEBUG][o.o.c.c.Coordinator      ] [runTask-0] startInitialJoin: coordinator becoming CANDIDATE in term 0 (was null, lastKnownLeader was [Optional.empty])
[2022-03-31T12:23:59,412][INFO ][o.o.c.c.Coordinator      ] [runTask-0] setting initial configuration to VotingConfiguration{kQe8LYsHRk-1IeTBlDF-bg}
[2022-03-31T12:23:59,412][WARN ][o.o.d.FileBasedSeedHostsProvider] [runTask-0] expected, but did not find, a dynamic hosts list at [/Users/kazabdu/sarat/OpenSearch/build/testclusters/runTask-0/config/unicast_hosts.txt]
[2022-03-31T12:23:59,614][DEBUG][o.o.c.c.ElectionSchedulerFactory] [runTask-0] scheduling scheduleNextElection{gracePeriod=0s, thisAttempt=0, maxDelayMillis=100, delayMillis=80, ElectionScheduler{attempt=1, ElectionSchedulerFactory{initialTimeout=100ms, backoffTime=100ms, maxTimeout=10s}}}
[2022-03-31T12:23:59,640][INFO ][o.o.h.AbstractHttpServerTransport] [runTask-0] publish_address {127.0.0.1:9200}, bound_addresses {[::1]:9200}, {127.0.0.1:9200}
[2022-03-31T12:23:59,642][INFO ][o.o.n.Node               ] [runTask-0] started

@owaiskazi19 owaiskazi19 changed the title POC: Send a TransportRequest to the extension and invoke the right extension point POC: Establish Communcaition and Send a TransportRequest to the extension Mar 31, 2022
@owaiskazi19 owaiskazi19 changed the title POC: Establish Communcaition and Send a TransportRequest to the extension POC: Establish Communication and Send a TransportRequest to the extension Mar 31, 2022
@saratvemulapalli
Copy link
Member

Communication is established between OpenSearch and SDK.

Logs of SDK:

12:23:59.076 [opensearch[node_extension][transport_worker][T#3]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf92851aa, L:/127.0.0.1:4532 - R:/127.0.0.1:61942] WRITE: 200B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 c2 00 00 00 00 00 00 00 02 01 08 |ES..............|
|00000010| 1e 84 e3 00 00 00 02 00 00 01 0e 6e 6f 64 65 5f |...........node_|
|00000020| 65 78 74 65 6e 73 69 6f 6e 16 71 4f 38 6d 52 54 |extension.qO8mRT|
|00000030| 79 68 54 72 79 45 67 64 6c 45 6a 76 61 67 6b 67 |yhTryEgdlEjvagkg|
|00000040| 16 57 48 47 76 32 4a 71 6b 52 50 57 76 64 6b 4c |.WHGv2JqkRPWvdkL|
|00000050| 5f 35 6f 39 48 41 77 09 31 32 37 2e 30 2e 30 2e |_5o9HAw.127.0.0.|
|00000060| 31 09 31 32 37 2e 30 2e 30 2e 31 04 7f 00 00 01 |1.127.0.0.1.....|
|00000070| 09 31 32 37 2e 30 2e 30 2e 31 00 00 11 b4 00 e3 |.127.0.0.1......|
|00000080| 89 fa 40 04 04 64 61 74 61 01 64 01 06 69 6e 67 |..@..data.d..ing|
|00000090| 65 73 74 01 69 00 06 6d 61 73 74 65 72 01 6d 00 |est.i..master.m.|
|000000a0| 15 72 65 6d 6f 74 65 5f 63 6c 75 73 74 65 72 5f |.remote_cluster_|
|000000b0| 63 6c 69 65 6e 74 01 72 00 0a 6f 70 65 6e 73 65 |client.r..opense|
|000000c0| 61 72 63 68 e3 89 fa 40                         |arch...@        |
+--------+-------------------------------------------------+----------------+
12:23:59.076 [opensearch[node_extension][transport_worker][T#3]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xf92851aa, L:/127.0.0.1:4532 - R:/127.0.0.1:61942] FLUSH
12:23:59.077 [opensearch[node_extension][transport_worker][T#3]] TRACE org.opensearch.transport.TransportService.tracer - [2][internal:transport/handshake] sent response
12:23:59.085 [opensearch[node_extension][transport_worker][T#8]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xfa0aa34f, L:/127.0.0.1:4532 - R:/127.0.0.1:61948] READ: 195B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 bd 00 00 00 00 00 00 00 03 00 08 |ES..............|
|00000010| 1e 84 e3 00 00 00 21 00 00 00 1d 69 6e 74 65 72 |......!....inter|
|00000020| 6e 61 6c 3a 64 69 73 63 6f 76 65 72 79 2f 65 78 |nal:discovery/ex|
|00000030| 74 65 6e 73 69 6f 6e 73 00 00 0e 6e 6f 64 65 5f |tensions...node_|
|00000040| 65 78 74 65 6e 73 69 6f 6e 16 67 64 63 70 32 70 |extension.gdcp2p|
|00000050| 73 61 53 5f 53 73 4c 6a 31 62 45 49 77 46 4b 41 |saS_SsLj1bEIwFKA|
|00000060| 09 31 32 37 2e 30 2e 30 2e 31 09 31 32 37 2e 30 |.127.0.0.1.127.0|
|00000070| 2e 30 2e 31 04 7f 00 00 01 09 31 32 37 2e 30 2e |.0.1......127.0.|
|00000080| 30 2e 31 00 00 11 b4 00 e3 89 fa 40 04 04 64 61 |0.1........@..da|
|00000090| 74 61 01 64 01 06 69 6e 67 65 73 74 01 69 00 06 |ta.d..ingest.i..|
|000000a0| 6d 61 73 74 65 72 01 6d 00 15 72 65 6d 6f 74 65 |master.m..remote|
|000000b0| 5f 63 6c 75 73 74 65 72 5f 63 6c 69 65 6e 74 01 |_cluster_client.|
|000000c0| 72 00 00                                        |r..             |
+--------+-------------------------------------------------+----------------+
MESSAGE RECEIVED:ES�　!internal:discovery/extensionsnode_extensiongdcp2psaS_SsLj1bEIwFKA 127.0.0.1       127.0.0.1�  127.0.0.1´㉺@datadingestimastermremote_cluster_clientr
12:23:59.086 [opensearch[node_extension][transport_worker][T#8]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:4532, remoteAddress=/127.0.0.1:61948} [length: 195, request id: 3, type: request, version: 2.0.0, action: internal:discovery/extensions] READ: 195B
12:23:59.086 [opensearch[node_extension][transport_worker][T#8]] TRACE org.opensearch.transport.TransportService.tracer - [3][internal:discovery/extensions] received request
12:23:59.090 [opensearch[node_extension][generic][T#1]] TRACE org.opensearch.tasks.TaskManager - register 2 [transport] [internal:discovery/extensions] []
12:23:59.091 [opensearch[node_extension][generic][T#1]] INFO  transportservice.RunPlugin - Handling Plugins Request
12:23:59.091 [opensearch[node_extension][generic][T#1]] TRACE org.opensearch.tasks.TaskManager - unregister task for id: 2
12:23:59.091 [opensearch[node_extension][generic][T#1]] TRACE org.opensearch.transport.TransportLogger - Netty4TcpChannel{localAddress=/127.0.0.1:4532, remoteAddress=/127.0.0.1:61948} [length: 39, request id: 3, type: response, version: 2.0.0, header size: 2B] WRITE: 39B
12:23:59.093 [opensearch[node_extension][transport_worker][T#8]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xfa0aa34f, L:/127.0.0.1:4532 - R:/127.0.0.1:61948] WRITE: 39B
         +-------------------------------------------------+
         |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+--------+-------------------------------------------------+----------------+
|00000000| 45 53 00 00 00 21 00 00 00 00 00 00 00 03 01 08 |ES...!..........|
|00000010| 1e 84 e3 00 00 00 02 00 00 0d 52 65 61 6c 45 78 |..........RealEx|
|00000020| 74 65 6e 73 69 6f 6e                            |tension         |
+--------+-------------------------------------------------+----------------+
12:23:59.094 [opensearch[node_extension][transport_worker][T#8]] TRACE transportservice.netty4.OpenSearchLoggingHandler - [id: 0xfa0aa34f, L:/127.0.0.1:4532 - R:/127.0.0.1:61948] FLUSH
12:23:59.094 [opensearch[node_extension][transport_worker][T#8]] TRACE org.opensearch.transport.TransportService.tracer - [3][internal:discovery/extensions] sent response

Logs of OpenSearch:

[2022-03-31T12:23:58,826][INFO ][o.o.t.TransportService   ] [runTask-0] connectToNode Connecting to node {node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode {node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 1.
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 2.
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 3.
[2022-03-31T12:23:58,827][INFO ][o.o.t.ClusterConnectionManager] [runTask-0] connectToNode 5.
[2022-03-31T12:23:58,888][INFO ][o.o.t.TransportService   ] [runTask-0] [1][internal:tcp/handshake] sent to [{node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}] (timeout: [null])
[2022-03-31T12:23:59,062][INFO ][o.o.t.InboundHandler     ] [runTask-0] STREAM HERE
[2022-03-31T12:23:59,068][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:transport/handshake
[2022-03-31T12:23:59,071][INFO ][o.o.t.TransportService   ] [runTask-0] [2][internal:transport/handshake] sent to [{node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}] (timeout: [30s])
[2022-03-31T12:23:59,079][INFO ][o.o.t.InboundHandler     ] [runTask-0] STREAM HERE
[2022-03-31T12:23:59,082][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest trying for connection to node: {node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}
[2022-03-31T12:23:59,082][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest internal:discovery/extensions
[2022-03-31T12:23:59,082][INFO ][o.o.t.TransportService   ] [runTask-0] sendRequest action: internal:discovery/extensions
[2022-03-31T12:23:59,084][INFO ][o.o.t.TransportService   ] [runTask-0] [3][internal:discovery/extensions] sent to [{node_extension}{gdcp2psaS_SsLj1bEIwFKA}{127.0.0.1}{127.0.0.1:4532}{dimr}] (timeout: [null])
[2022-03-31T12:23:59,094][INFO ][o.o.t.InboundHandler     ] [runTask-0] STREAM HERE
[2022-03-31T12:23:59,095][INFO ][o.o.p.PluginsOrchestrator] [runTask-0] received PluginResponse{nameRealExtension}
[2022-03-31T12:23:59,407][DEBUG][o.o.c.c.Coordinator      ] [runTask-0] startInitialJoin: coordinator becoming CANDIDATE in term 0 (was null, lastKnownLeader was [Optional.empty])
[2022-03-31T12:23:59,412][INFO ][o.o.c.c.Coordinator      ] [runTask-0] setting initial configuration to VotingConfiguration{kQe8LYsHRk-1IeTBlDF-bg}
[2022-03-31T12:23:59,412][WARN ][o.o.d.FileBasedSeedHostsProvider] [runTask-0] expected, but did not find, a dynamic hosts list at [/Users/kazabdu/sarat/OpenSearch/build/testclusters/runTask-0/config/unicast_hosts.txt]
[2022-03-31T12:23:59,614][DEBUG][o.o.c.c.ElectionSchedulerFactory] [runTask-0] scheduling scheduleNextElection{gracePeriod=0s, thisAttempt=0, maxDelayMillis=100, delayMillis=80, ElectionScheduler{attempt=1, ElectionSchedulerFactory{initialTimeout=100ms, backoffTime=100ms, maxTimeout=10s}}}
[2022-03-31T12:23:59,640][INFO ][o.o.h.AbstractHttpServerTransport] [runTask-0] publish_address {127.0.0.1:9200}, bound_addresses {[::1]:9200}, {127.0.0.1:9200}
[2022-03-31T12:23:59,642][INFO ][o.o.n.Node               ] [runTask-0] started

This is awesome to see. Finally we are able to communicate between OpenSearch <-> SDK :)

@saratvemulapalli saratvemulapalli changed the title POC: Establish Communication and Send a TransportRequest to the extension SDK: Add support for communication between SDK and OpenSearch Apr 27, 2022
@saratvemulapalli saratvemulapalli mentioned this issue Apr 27, 2022
Open
15 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
Build Libraries & Interfaces enhancement Enhancement or improvement to existing feature or request
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@owaiskazi19 @saratvemulapalli @minalsha