Richard Grossman
Richard Grossman
Using the version 2.1.0 I get a lot of these exception `java.lang.ArrayIndexOutOfBoundsException: Index 17 out of bounds for length 17 at kamon.tag.TagSet$Builder$ChainedArray.addPair(TagSet.scala:520) at kamon.tag.TagSet$Builder$ChainedArray.$anonfun$add$1(TagSet.scala:473) at kamon.tag.TagSet$Builder$ChainedArray.$anonfun$add$1$adapted(TagSet.scala:473) at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553) at scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551)...
**Describe the bug** MacOS BigSur 11.6.4 **To Reproduce** Quick install on local machine running docker and kubernetes (not minikube) normal docker install including kubernetes **Expected behavior** The process should finish...
### Describe the issue Trying to use hyperspace API produce a runtime exception. `java.lang.NoSuchMethodError: org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.transformDown(Lscala/PartialFunction;)Lorg/apache/spark/sql/catalyst/plans/logical/LogicalPlan; at com.microsoft.hyperspace.index.covering.CoveringIndexRuleUtils$.transformPlanToUseIndexOnlyScan(CoveringIndexRuleUtils.scala:110) at com.microsoft.hyperspace.index.covering.CoveringIndexRuleUtils$.transformPlanToUseIndex(CoveringIndexRuleUtils.scala:79) at com.microsoft.hyperspace.index.covering.FilterIndexRule$.applyIndex(FilterIndexRule.scala:148) at com.microsoft.hyperspace.index.rules.HyperspaceRule.apply(HyperspaceRule.scala:75) at com.microsoft.hyperspace.index.rules.HyperspaceRule.apply$(HyperspaceRule.scala:62) at com.microsoft.hyperspace.index.covering.FilterIndexRule$.apply(FilterIndexRule.scala:129) at com.microsoft.hyperspace.index.rules.ScoreBasedIndexPlanOptimizer.$anonfun$recApply$3(ScoreBasedIndexPlanOptimizer.scala:56) at...
Hi After debugging a lot secor when writing Parquet from Avro message. I come to the conclusion that a possible racing condition can occurs. - So Iv'e a topic with...
I've deployed secor in K8s using the helm charts. After some time completely random I get this this exception crash the pod: ``` java.lang.RuntimeException: Failed to apply upload policy at...
The current config only includes compression for the file produced however Avro have hist own compression codec who is not configurable using the current config
Hi when I switch using com.pinterest.secor.monitoring.MicroMeterMetricCollector instead of com.pinterest.secor.monitoring.OstrichMetricCollector I get thousands of exception `WARN Error while discarding collection, stopping java.util.ConcurrentModificationException at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:909) at java.util.ArrayList$Itr.next(ArrayList.java:859) at io.micrometer.shaded.reactor.core.publisher.Operators.onDiscardMultiple(Operators.java:565) at io.micrometer.shaded.reactor.core.publisher.FluxBufferPredicate$BufferPredicateSubscriber.cancel(FluxBufferPredicate.java:174) at...
Hi I run secor on google cloud kubernetes. The nodes pool use preemptive machine meaning the machine restart every 24H. I've deployed 7 pods The data in kafka is avro...
Hi I would like to add more on this because I check it now The problem is that Avro doesn't support Gzip compression by default. The problem is that Avro...
Hi I would like to test writing data as Avro instead of parquet I've configured Secor to write Avro file After some time I get and the process is stopped...