clear query| facets| time Search criteria: .   Results from 31 to 40 from 84 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Kafka 2.0 quotas - Flink - [mail # user]
...Aah, quotas are broker side "throttles" so I guess this is any client APIspecific including "flink" ?On Mon, Jan 7, 2019 at 2:17 PM Vishal Santoshi wrote:>> https://www.cloudera.com/do...
   Author: Vishal Santoshi , 2019-01-07, 19:27
[expand - 3 more] - Is there an example of flink cluster "as a job" deployment on k8s ? - Flink - [mail # user]
...Awesome. If https://issues.apache.org/jira/browse/FLINK-9953. is on wewould rather wait. In the interim we might go for the static pool route.https://github.com/kubernetes/community/blob/mas...
   Author: Vishal Santoshi , 2019-01-04, 09:35
Flink 1.5 + resource elasticity resulting in overloaded workers - Flink - [mail # user]
...+1.On Thu, Dec 20, 2018, 12:56 AM jelmer <[EMAIL PROTECTED] wrote:> Hi, We recently upgraded to flink 1.6 and seem to be suffering from the> issue described in this email>>>...
   Author: Vishal Santoshi , 2018-12-19, 23:13
Tentative release date for 1.6.3 - Flink - [mail # user]
...+1. Do not see 1.7 release details anywhere.On Mon, Nov 26, 2018, 8:02 AM galantaa <[EMAIL PROTECTED] wrote:> Hi vino,> We want to upgrade flink version to 1.6>> I searched bu...
   Author: Vishal Santoshi , 2018-11-26, 17:36
[expand - 2 more] - Reset kafka offets to latest on restart - Flink - [mail # user]
...I think I can set . a new uuid but it seems `allowNonRestoreState` is a CLIhint. I need the "automatic" restart on failure to use the new uuid.Our use case has no use of data on Kafka that i...
   Author: Vishal Santoshi , 2018-11-24, 20:51
[expand - 3 more] - Question about sharing resource among slots with a TM - Flink - [mail # user]
...Aah got it.https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/debugging_classloading.htmlOn Thu, Sep 27, 2018 at 11:04 AM Vishal Santoshi wrote:> Makes sense. An additional...
   Author: Vishal Santoshi , 2018-09-28, 02:46
[expand - 4 more] - 2 Broadcast streams to a Single Keyed Stream....how to? - Flink - [mail # user]
...of course2.  DataStream unionedStream  =  DataStream.union(DatStream);//here X.type = Y.type     B = unionedStream.broadcast( ..) ;     DataStrea...
   Author: Vishal Santoshi , 2018-09-18, 16:00
[expand - 3 more] - Access to Kafka Event Time - Flink - [mail # user]
...Thanks a lot! Awesome that 1.6 will have the ts of the element....On Tue, Aug 7, 2018, 4:19 AM Aljoscha Krettek  wrote:> Hi Vishal,>> to answer the original question: it should...
   Author: Vishal Santoshi , 2018-08-07, 21:54
[expand - 1 more] - 1.5.1 - Flink - [mail # user]
...According to the UI it seems that "org.apache.flink.util.FlinkException: The assigned slot208af709ef7be2d2dfc028ba3bbf4600_10 was removed." was the cause of a pipe restart.As to the TM it is...
   Author: Vishal Santoshi , 2018-07-22, 11:20
[expand - 1 more] - Flink 1.5 job distribution over cluster nodes - Flink - [mail # user]
...For example state size / logs etc all these are now one one physical node (or couple rather then spread out )  for that one pipe where we desire tohave a large state.  We have decr...
   Author: Vishal Santoshi , 2018-07-19, 02:52