raw issues

2024-06-16 Thread Fokou Toukam, Thierry
hello, i am trying to do vector assembling with flink 1.15 but i have this. How can i solve it please? 2024-06-16 03:47:24 DEBUG Main:114 - Assembled Data Table Schema: root |-- tripId: INT |-- stopId: INT |-- routeId: INT |-- stopSequence: INT |-- speed: DOUBLE |-- currentStatus: INT

raw error

2024-06-06 Thread Fokou Toukam, Thierry
Hi everyone, why does flink xonsider densevector or vectors as a raw types'features: RAW('org.apache.flink.ml.linalg.Vector', '...')'? I'm trying to deploy my job on flink and i have this error Server Response: org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute

Information Request

2024-06-06 Thread Fokou Toukam, Thierry
I want to set up a stream processing environment on a ubuntu server for machine learning. Which version of Apache Flink do you recommend me if i want to use maven? Thierry FOKOU | IT M.A.Sc Student Département de génie logiciel et TI École de technologie supérieure | Université du Québec

Flink job Deployement problem

2024-06-05 Thread Fokou Toukam, Thierry
Hi, i'm trying to deploy flink job but i have this error. How to solve it please? [cid:b13357ec-00b9-4a15-8d04-1c797a4eced3] Thierry FOKOU | IT M.A.Sc Student Département de génie logiciel et TI École de technologie supérieure | Université du Québec 1100, rue Notre-Dame Ouest Montréal

join two streams with pyflink

2024-04-02 Thread Fokou Toukam, Thierry
Hi, i have 2 streams as sean in this example (6> {"tripId": "275118740", "timestamp": "2024-04-02T06:20:00Z", "stopSequence": 13, "stopId": "61261", "bearing": 0.0, "speed": 0.0, "vehicleId": "39006", "routeId": "747"} 1> {"visibility": 1, "weather_conditions": "clear sky", "timestamp":

Re: flink version stable

2024-03-29 Thread Fokou Toukam, Thierry
[image001]<http://etsmtl.ca/> De : Junrui Lee Envoyé : Friday, March 29, 2024 5:11:03 AM À : user Objet : Re: flink version stable Hi, The latest stable version of FLINK is 1.19.0 Fokou Toukam, Thierry mailto:thierry.fokou-touka...@ens.etsmtl.ca>>

flink version stable

2024-03-28 Thread Fokou Toukam, Thierry
Hi, just want to know which version of flink is stable? Thierry FOKOU | IT M.A.Sc Student Département de génie logiciel et TI École de technologie supérieure | Université du Québec 1100, rue Notre-Dame Ouest Montréal (Québec) H3C 1K3 Tél +1 (438) 336-9007 [image001]