{"push_id":1397840316,"size":1,"distinct_size":1,"ref":"refs/heads/fix/another_try_at_close_channe_in_next_iterator","head":"d530c5990c184742a5e5845f147a17ae536c9958","before":"66e75d852afa673623986ce16d8df1cd6fe047f7","commits":[{"sha":"d530c5990c184742a5e5845f147a17ae536c9958","author":{"name":"Stéphane Seng","email":"2212596506a042f443330f537f4b259007c60817@gmail.com"},"message":"Trying to address another TimeoutException.\n\njava.util.concurrent.TimeoutException\n        at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:77)\n        at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:111)# Veuillez saisir le message de validation pour vos modifications. Les lignes\n        at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:37)# commençant par '#' seront ignorées, et un message vide abandonne la validation.\n        at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:367)# Sur la branche fix/another_try_at_close_channe_in_next_iterator\n        at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:293)# Modifications qui seront validées :\n        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:716)# modifié: src/main/scala/org/apache/spark/streaming/rabbitmq/consumer/Consumer.scala\n        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:647)# modifié: src/main/scala/org/apache/spark/streaming/rabbitmq/distributed/RabbitMQRDD.scala\n        at org.apache.spark.streaming.rabbitmq.consumer.Consumer$.org$apache$spark$streaming$rabbitmq$consumer$Consumer$$addConnection(Consumer.scala:256)#\n        at org.apache.spark.streaming.rabbitmq.consumer.Consumer$$anonfun$1.apply(Consumer.scala:248)\n        at org.apache.spark.streaming.rabbitmq.consumer.Consumer$$anonfun$1.apply(Consumer.scala:248)\n        at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)\n        at scala.collection.AbstractMap.getOrElse(Map.scala:59)\n        at org.apache.spark.streaming.rabbitmq.consumer.Consumer$.getChannel(Consumer.scala:248)\n        at org.apache.spark.streaming.rabbitmq.consumer.Consumer$.apply(Consumer.scala:204)\n        at org.apache.spark.streaming.rabbitmq.distributed.RabbitMQRDD$RabbitMQRDDIterator.getConsumer(RabbitMQRDD.scala:239)\n        at org.apache.spark.streaming.rabbitmq.distributed.RabbitMQRDD$RabbitMQRDDIterator.<init>(RabbitMQRDD.scala:165)\n        at org.apache.spark.streaming.rabbitmq.distributed.RabbitMQRDD.compute(RabbitMQRDD.scala:142)\n        at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)\n        at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:69)\n        at org.apache.spark.rdd.RDD.iterator(RDD.scala:268)\n        at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)\n        at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)\n        at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)\n        at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)\n        at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)\n        at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:69)\n        at org.apache.spark.rdd.RDD.iterator(RDD.scala:268)\n        at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)\n        at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)\n        at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)\n        at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)\n        at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)\n        at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)\n        at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)\n        at org.apache.spark.scheduler.Task.run(Task.scala:89)\n        at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)\n        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n        at java.lang.Thread.run(Thread.java:745)","distinct":true,"url":"https://api.github.com/repos/AttestationLegale/Spark-RabbitMQ/commits/d530c5990c184742a5e5845f147a17ae536c9958"}]}
{"actor":{"display_login":"stephaneseng"}}