Hi, I tried to reproduce the issue in local in debug mode and I can see that after sockStmr.start(); the WordsSocketStreamerServer node is getting stopped.
I do not see any exception in console and I think it stopped gracefully. We will need to debug further why it is getting stopped and not listening to port 5555 for client messages. Regards, Saikat On Thu, Jan 9, 2020 at 5:48 AM narges saleh <snarges...@gmail.com> wrote: > Any clue what could be wrong? > > On Tue, Jan 7, 2020 at 8:52 AM narges saleh <snarges...@gmail.com> wrote: > >> Thanks Saikat for the reply. >> >> 1) I will check out the webinar. thanks. >> 2) The socket streamer server code goes to the finally clause right after >> the socket streamer is starts. The screen snapshot with 2 servers and one >> client is here. >> >> [image: image.png] >> >> On Mon, Jan 6, 2020 at 7:59 PM Saikat Maitra <saikat.mai...@gmail.com> >> wrote: >> >>> Hi, >>> >>> 1. If you define schema for your dataset then you should be able to >>> execute qry to get the desired resultset. Please take a look into Valentin >>> Kulichenko's webinar related to using jdbc thin client and getting >>> resultset. You can execute similar qry using rest api. Alternatively, you >>> can also use rest api to Execute command to perform any task in the Ignite >>> grid. >>> >>> https://www.youtube.com/watch?v=eMs_2vEsbBk&t=3103s >>> >>> 2. If I understand correctly the topology for the grid, we have 4 ignite >>> servers and 1 Data streamer client which is pushing the data to Ignite >>> cluster. If the Ignite Data Streamer client is stopped in finally clause >>> then where do you receive the "Ignite node stopped message". >>> >>> Also, can you please share if this is a INFO message or ERROR message? >>> >>> Regards, >>> Saikat >>> >>> >>> >>> On Sun, Jan 5, 2020 at 8:23 PM narges saleh <snarges...@gmail.com> >>> wrote: >>> >>>> Hello Saikat, >>>> 1) Any service method; say I have an affinity based deployed service >>>> with a method that aggregates the balances for each customer based on >>>> their location. >>>> Also, I take it that it is not possible to have rest API/streamer >>>> producer/consumer arrangement as you would have in tcp socket connection >>>> between the client data producer and streamer data consumer, right? >>>> 2)Yes the nodes report number of servers=4 and clients=1 and but then >>>> the number of clients goes to 0 when the streamer node stops (but the >>>> number of servers stays at 4). >>>> thanks. >>>> >>>> On Sun, Jan 5, 2020 at 6:56 PM Saikat Maitra <saikat.mai...@gmail.com> >>>> wrote: >>>> >>>>> Hi, >>>>> >>>>> 1. The rest api is separate interface to load data in cache. I do not >>>>> think we have rest endpoint to call ignite service method, can you share >>>>> an >>>>> example of which service method you want to call using rest api. You can >>>>> check the rest api docs to learn more about rest apis supported >>>>> functionality. >>>>> >>>>> https://apacheignite.readme.io/docs/rest-api >>>>> >>>>> 2. Can you see if any active node running, all the nodes will log >>>>> cluster health information and number of servers running etc >>>>> >>>>> Regards, >>>>> Saikat >>>>> >>>>> On Sun, Jan 5, 2020 at 3:21 PM narges saleh <snarges...@gmail.com> >>>>> wrote: >>>>> >>>>>> Thanks Saikat for the reply. >>>>>> >>>>>> 1) Rest API: how does the streamer listen to the REST requests? Is >>>>>> there an example? Or do I just enable streaming an option (e.g., the way >>>>>> you do it with JDBC/SQL)? Sorry if this is a trivial question. Another >>>>>> question(unrelated to the topic of data load via streamers): is it >>>>>> possible >>>>>> to use Ignite's rest API to call an ignite service method (via a service >>>>>> proxy? If yes, is there an example? >>>>>> 2) I started anywhere from 2 to 4 ExampleNodeStartup nodes (different >>>>>> tries), but still got the "ignite node stopped" message. >>>>>> >>>>>> >>>>>> On Sun, Jan 5, 2020 at 12:04 PM Saikat Maitra < >>>>>> saikat.mai...@gmail.com> wrote: >>>>>> >>>>>>> Hi, >>>>>>> >>>>>>> Thank you for your email and using DataStreamer. >>>>>>> >>>>>>> 1. Yes, there are rest endpoints available to send data in Ignite >>>>>>> cache. Here is the docs for the same >>>>>>> https://apacheignite.readme.io/docs/rest-api >>>>>>> 2. As per the docs as mentioned below, can you please confirm if you >>>>>>> have few nodes running using ExampleNodeStartup? >>>>>>> >>>>>>> * To start the example, you should: >>>>>>> * <ul> >>>>>>> * <li>Start a few nodes using {@link ExampleNodeStartup}.</li> >>>>>>> * <li>Start socket server using {@link >>>>>>> WordsSocketStreamerServer}.</li> >>>>>>> * <li>Start a few socket clients using {@link >>>>>>> WordsSocketStreamerClient}.</li> >>>>>>> * <li>Start querying popular words using {@link QueryWords}.</li> >>>>>>> * </ul> >>>>>>> Regards, >>>>>>> Saikat >>>>>>> >>>>>>> On Sat, Jan 4, 2020 at 2:33 PM narges saleh <snarges...@gmail.com> >>>>>>> wrote: >>>>>>> >>>>>>>> Hi All, >>>>>>>> >>>>>>>> I have two questions regarding loading data with the streamer, with >>>>>>>> non ignite client. >>>>>>>> >>>>>>>> 1) Is there a REST/HTTP counterpart for the TCP socket streamer, >>>>>>>> meaning the client sending the data to the streamer via HTTP POST? >>>>>>>> 2) I am trying to play with ignite's TCP socket streamer example, >>>>>>>> but the client node stops with the message "Ignite node stopped" -- It >>>>>>>> hits >>>>>>>> the finally clause after the socket streamer is started. Any idea what >>>>>>>> could be wrong? >>>>>>>> >>>>>>>> >>>>>>>> https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerServer.java >>>>>>>> >>>>>>>> thanks. >>>>>>>> >>>>>>>>
