clear query| facets| time Search criteria: .   Results from 1 to 10 from 8242 (0.0s).
Loading phrases to help you
refine your search...
[expand - 3 more] - Flink 1.11 SQL error: No operators defined in streaming topology. Cannot execute. - Flink - [mail # user]
...Weighing ~tEnv.executeSql would execute the SQL asynchronously, e.g. submitting a job to the backend cluster with a builtin job name, the tEnv.executeSql itself did return a JobResult immedi...
   Author: Danny Chan , Lu Weizheng , ... , 2020-08-13, 11:45
[expand - 1 more] - Cannot resume from Savepoint when operator changes - Flink - [mail # user]
...Hi EleanoreWhen adding an operator of source while savepoint not included, it would run from scratch and fetch the offset depended on your configuration of source connector.Take the scenario...
   Author: Yun Tang , Eleanore Jin , ... , 2020-08-13, 10:34
[expand - 4 more] - TaskManagers are still up even after job execution completed in PerJob deployment mode - Flink - [mail # user]
...Hi Narasimha,if you are deploying the Flink cluster manually on K8s then there isno automatic way of stopping the TaskExecutor/TaskManager pods. This issomething you have to do manually (sim...
   Author: Till Rohrmann , Kostas Kloudas , ... , 2020-08-13, 09:42
[expand - 5 more] - getting error after upgrade Flink 1.11.1 - Flink - [mail # user]
...Hi Dasraj,Yes, I would recommend to use Public and, if necessary, PublicEvolvingAPIs as they provide better guarantees for future maintenance.Unfortunately there are no Docs about which APIs...
   Author: Kostas Kloudas , dasraj , ... , 2020-08-13, 09:41
[expand - 1 more] - k8s job cluster using StatefulSet - Flink - [mail # user]
...Hi Alexey,I don't see any issue in using stateful sets immediately.I'd recommend using one of the K8s operators or Ververica's communityedition [1] though if you start with a new setup as th...
   Author: Arvid Heise , Alexey Trenikhun , ... , 2020-08-13, 08:38
[expand - 1 more] - Using managed keyed state with AsynIo - Flink - [mail # user]
...Hi KristoffSC,Afaik asyncIO does not support state operations at all because of yourmentioned issues (RichAsyncFunction fails if you access state).I'd probably solve it by having a map or pr...
   Author: Arvid Heise , KristoffSC , ... , 2020-08-13, 08:27
[expand - 1 more] - Tools for Flink Job performance testing - Flink - [mail # user]
...Hi,performance testing is quite vague. Usually you start by writing a smallfirst version of your pipeline and check how the well computation scales onyour data. Flink's web UI [1] already he...
   Author: Arvid Heise , narasimha , ... , 2020-08-13, 07:55
[expand - 1 more] - State Processor API to boot strap keyed state for Stream Application. - Flink - [mail # user]
...For future readers: this thread has been resolved in "Please help, I needto bootstrap keyed state into a stream" on the user mailing list asked byMarco.On Fri, Aug 7, 2020 at 11:52 PM Marco ...
   Author: Arvid Heise , Marco Villalobos , ... , 2020-08-13, 07:42
[expand - 2 more] - Is there a way to start a timer without ever receiving an event? - Flink - [mail # user]
...What you can do is creating an initial control stream e.g. using `StreamExecutionEnivronment.fromElements()` and either use `union(controlStream, actualStream)` or use `actualStream.connect(...
   Author: Timo Walther , Andrey Zagrebin , ... , 2020-08-13, 07:38
[expand - 6 more] - Flink CPU load metrics in K8s - Flink - [mail # user]
...Hi Abhinav,according to [1], you need 8u261 for the OperatingSystemMXBean to work asexpected.[1] https://bugs.openjdk.java.net/browse/JDK-8242287On Thu, Aug 13, 2020 at 1:10 AM Bajaj, Abhina...
   Author: Arvid Heise , Bajaj, Abhinav , ... , 2020-08-13, 07:33