Hi Alvaro,
it seems this issues is related to the Java version and the Flink wrapper – which Java version are you using? Is the processor working when using the plain JVM wrapper instead of Flink (e.g., by creating the skeleton using the Maven archetype)? Dominik From: Alvaro Augusto Locatelli de Souza <[email protected]> Sent: Tuesday, September 7, 2021 1:31 PM To: [email protected] Subject: Fwd: Fwd: StreamPipes Hello Patrick, Thanks for your prompt reply. We have build a few components (adapters, processors and sinks), which seems to work fine. But this specific one we are getting the following error when we try to start the pipeline. "ERROR o.a.s.c.a.InvocablePipelineElementResource - Could not invoke pipeline element Processor due to the following error: Unable to make field private static final long java.util.Properties.serialVersionUID accessible: module java.base does not "opens java.util" to unnamed module @6950ed69 " The adapter is working as it should (in this case we are using the standard mqtt client), I can see the data in the live preview but the processor shows no data. But are connected and streaming directly as you can see below. .requiredStream(StreamRequirementsBuilder .create() .requiredProperty(EpRequirements.anyProperty()) .build()) And streaming the output directly also: .supportedProtocols(SupportedProtocols.kafka()) .supportedFormats(SupportedFormats.jsonFormat()) .outputStrategy(OutputStrategies.keep()) .build(); This is just a test processor, but I really would like to understand what is wrong with it to better understand the StreamPipes ecosystem. We're also using a standard dashboard sink. The logs shows no errors. I have looked in the class *Program that extend FlinkDataProcessorRuntime and implements Serializable. "private static final long serialVersionUID = 1L" Seems to be ok. Do you have a guess why it can't find the constant. Thank you very much Best regards Alvaro -------- Forwarded Message -------- Subject: Re: Fwd: StreamPipes Date: Tue, 7 Sep 2021 12:21:22 +0200 From: Alvaro Augusto Locatelli de Souza <mailto:[email protected]> <[email protected]> To: Patrick Wiener <mailto:[email protected]> <[email protected]> Hello Patrick, Thanks for your prompt reply. We have build a few components (adapters, processors and sinks), which seems to work fine. But this specific one we are getting the following error when we try to start the pipeline. "ERROR o.a.s.c.a.InvocablePipelineElementResource - Could not invoke pipeline element Processor due to the following error: Unable to make field private static final long java.util.Properties.serialVersionUID accessible: module java.base does not "opens java.util" to unnamed module @6950ed69 " The adapter is working as it should (in this case we are using the standard mqtt client), I can see the data in the live preview but the processor shows no data. But are connected and streaming directly as you can see below. .requiredStream(StreamRequirementsBuilder .create() .requiredProperty(EpRequirements.anyProperty()) .build()) And streaming the output directly also: .supportedProtocols(SupportedProtocols.kafka()) .supportedFormats(SupportedFormats.jsonFormat()) .outputStrategy(OutputStrategies.keep()) .build(); This is just a test processor, but I really would like to understand what is wrong with it to better understand the StreamPipes ecosystem. We're also using a standard dashboard sink. The logs shows no errors. I have looked in the class *Program that extend FlinkDataProcessorRuntime and implements Serializable. "private static final long serialVersionUID = 1L" Seems to be ok. Do you have a guess why it can't find the constant. Thank you very much Best regards Alvaro On 06.09.21 20:57, Patrick Wiener wrote: Hi Alvaro, I port this to the dev mailing list. Could you please provide more details what your trying to achieve and where exactly the error occurs? Cheers Patrick Anfang der weitergeleiteten Nachricht: Von: Alvaro Augusto Locatelli de Souza <[email protected] <mailto:[email protected]> > Betreff: StreamPipes Datum: 6. September 2021 um 20:24:55 MESZ An: [email protected] <mailto:[email protected]> Hello Patrick, my name is Alvaro, I'm a Software Engineer at EDI GmbH. We are currently preparing the production environment for StreamPipes, which has been going fine so far. I have recently written to your Forum because I had a question and it was great, I could solve the problem with the answer I got. Speaking to Mohanad here at EDI he suggested that you could help me solve one problem that we're currently having. We are producing a few components and we're getting an error which I haven't been able to debug. The error is: "Unable to make field private static final long java.util.Properties.serialVersionUID". I've tried to set "serialVersionUID" as public, I've tried to set a new value but haven't had any luck so far. Do you have any idea where I could be going wrong? I hope it is fine that I contacted you directly. Best regards, Alvaro -- EDI GmbH Engineering Data Intelligence Hermann-Weick-Weg 3 76229 Karlsruhe (Grötzingen), Deutschland Alvaro Locatelli Souza Software Enginner Telefon: +49 721 79199 155 Mobil: +49 160 92504 106 Email: [email protected] <mailto:[email protected]> WWW: www <http://www.edi.gmbh/en/> . <http://www.edi.gmbh/en/> edi.gmbh <http://www.edi.gmbh/en/> <https://www.youtube.com/channel/UCaLsW2mgWB3BB8isicyqU6g?view_as=subscriber> <https://www.linkedin.com/authwall?trk=ripf&trkInfo=AQEzpm6QRZtfBwAAAXaG-GNQu9A0kNpT5EDSPJWHJJdrGfQWIQkO6aw4SCy1fkWaYk9JsvuRCRdMHe30l4tZpPkDAKWlnjiA1OIvsvMogKwGpP4h36ZJBkNfWRakUrXQi_ES-Ig=&originalReferer=&sessionRedirect=https%3A%2F%2Fwww.linkedin.com%2Fcompany%2Fengineering-data-intelligence> <https://www.youtube.com/channel/UCaLsW2mgWB3BB8isicyqU6g> Die EDI GmbH wird vertreten durch die Geschäftsführer Dr.-Ing. Mohanad El-Haji und Dr.-Ing. Thomas Freudenmann. Sitz der Gesellschaft ist Karlsruhe, HRB 723936 (Registergericht AG Mannheim) -- -- EDI GmbH Engineering Data Intelligence Hermann-Weick-Weg 3 76229 Karlsruhe (Grötzingen), Deutschland Alvaro Locatelli Souza Software Enginner Telefon: +49 721 79199 155 Mobil: +49 160 92504 106 Email: [email protected] <mailto:[email protected]> WWW: www <http://www.edi.gmbh/en/> . <http://www.edi.gmbh/en/> edi.gmbh <http://www.edi.gmbh/en/> <https://www.youtube.com/channel/UCaLsW2mgWB3BB8isicyqU6g?view_as=subscriber> <https://www.linkedin.com/authwall?trk=ripf&trkInfo=AQEzpm6QRZtfBwAAAXaG-GNQu9A0kNpT5EDSPJWHJJdrGfQWIQkO6aw4SCy1fkWaYk9JsvuRCRdMHe30l4tZpPkDAKWlnjiA1OIvsvMogKwGpP4h36ZJBkNfWRakUrXQi_ES-Ig=&originalReferer=&sessionRedirect=https%3A%2F%2Fwww.linkedin.com%2Fcompany%2Fengineering-data-intelligence> <https://www.youtube.com/channel/UCaLsW2mgWB3BB8isicyqU6g> Die EDI GmbH wird vertreten durch die Geschäftsführer Dr.-Ing. Mohanad El-Haji und Dr.-Ing. Thomas Freudenmann. Sitz der Gesellschaft ist Karlsruhe, HRB 723936 (Registergericht AG Mannheim)
