clear query| facets| time Search criteria: .   Results from 1 to 10 from 33 (0.0s).
Loading phrases to help you
refine your search...
MirrorMaker 2 Plugin class loader Error - Kafka - [mail # user]
...+1On Mon, Nov 11, 2019 at 2:07 PM Ryanne Dolan  wrote:> Rajeev, the config errors are unavoidable at present and can be ignored or> silenced. The Plugin error is concerning, and w...
   Author: Vishal Santoshi , 2019-11-12, 15:51
[expand - 2 more] - MirrorMaker 2.0 ( working off origin/2.4 ) - Kafka - [mail # user]
...I can verify that the above did take. ( kicking myself ) . It should be thesame for, these too ?b.producer.batch.size = 1048576b.producer.linger.ms  = 30b.producer.acks = 1etc etc...I a...
   Author: Vishal Santoshi , 2019-11-04, 20:27
[expand - 18 more] - Running a stand alone Mirror Maker 2.0 cluster and Issues - Kafka - [mail # user]
...Yep, I increase the number of tasks and the umber of nodes executing thetasks, the above issues appears. It creates the topics ( so non issuereaching the clusters ) but does not create  ...
   Author: Vishal Santoshi , 2019-10-25, 17:25
[expand - 2 more] - Mirror Maker 2.0 cluster and starting from latest offset and other queries - Flink - [mail # user]
...oh shit.. sorry wrong wrong forum :)On Thu, Oct 17, 2019 at 1:41 PM Piotr Nowojski  wrote:> Hi,>> It sounds like setting up Mirror Maker has very little to do with Flink.> S...
   Author: Vishal Santoshi , 2019-10-17, 18:06
[expand - 2 more] - flink 1.9 - Flink - [mail # user]
...Thanks a lot.On Wed, Oct 9, 2019, 8:55 AM Chesnay Schepler  wrote:> Java 11 support will be part of Flink 1.10 (FLINK-10725). You can take the> current master and compile&run it o...
   Author: Vishal Santoshi , 2019-10-09, 15:14
[FLINK-9349] KafkaConnector Exception  while fetching from multiple kafka topics - Flink - [issue]
..../flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java It seems the List subscribedPartitionStates was being modi...
http://issues.apache.org/jira/browse/FLINK-9349    Author: Vishal Santoshi , 2019-07-11, 07:45
[expand - 8 more] - Job recovers from an old dangling CheckPoint in case of Job Cluster based Flink pipeline - Flink - [mail # user]
...I guess using a session cluster rather then a job cluster will decouple thejob from the container and may be the only option as of today?On Sat, Jun 29, 2019, 9:34 AM Vishal Santoshi wrote:&...
   Author: Vishal Santoshi , 2019-07-03, 12:27
[expand - 2 more] - Why did JM fail on K8s (see original thread below) - Flink - [mail # user]
...even thoughMax. number of execution retries Restart with fixed delay (240000 ms). #20restart attempts.On Sat, Jun 29, 2019 at 10:44 AM Vishal Santoshi wrote:> This is strange, the retry s...
   Author: Vishal Santoshi , 2019-06-29, 14:45
[expand - 3 more] - Deletion of topic from a pattern in KafkaConsumer if auto-create is true will always recreate the topic - Flink - [mail # user]
...I am sure there was a ticket open that allowed for clean manipulation ofstate ( that would have saved us a whole lot )......On Fri, Jun 14, 2019 at 1:19 PM Vishal Santoshi wrote:> Yep, bu...
   Author: Vishal Santoshi , 2019-06-14, 17:42
[expand - 1 more] - Flink 1.8 - Flink - [mail # user]
...Based on where this line of  code is, it is hard to get the full stacktrace, as in theLOG.error("Cannot update accumulators for job {}.", getJobID(), e);does not get us the full stack t...
   Author: Vishal Santoshi , 2019-06-04, 23:02