All Questions
117
questions
0
votes
1
answer
30
views
Use Jedis `echo` in pipeline
The examples use Scala code, but the issue would be the same with Java.
Way back in version 2 of Jedis, you could use echo in a pipeline:
import redis.clients.jedis._
object Main {
def main(args: ...
- 341
0
votes
0
answers
46
views
Limiting interactions with ETCD without impacting Performance
I have been working on limiting the interactions with ETCD server for my scala-maven application.
To give you all an idea on why we use ETCD is because my application in its entire lifecycle for an ...
- 1
0
votes
1
answer
558
views
Redis scan issue for multiple replica configuration
I am using AWS Elasticache redis(cluster mode off) with 1 primary and 2 replica and trying to get keys from redis for a given key pattern using redis scan command (scan (cursor, count, matchGlobe)) ...
- 43
0
votes
1
answer
118
views
redis4cats Scala redis.set not setting any records
Scala redis4cats library
redis: RedisCommands[IO, String, String]
Below code line in scala does not set any records in redis.
redis.set("a", "x")
Although when setting via ...
- 83
0
votes
1
answer
121
views
Failed to return from Redis call from Scala/spark, Shows some Deadlock in thread dump
I am new to scala and spark world, some where in scala code I am seeing invocation to Redis call via Redisson 3.9.1 to get keys data which is very few number of records and this leads me some deadlock ...
- 431
1
vote
1
answer
436
views
How to authenticate into a Redis stream from spark with an ssl certificate
I am trying to access a Redis server that needs an ssl certificate to authenticate through spark with Scala. I understand SparkSession has a parameter "spark.redis.ssl" which takes in a ...
- 11
-1
votes
1
answer
476
views
Scala-Redis: How to connect a global redis cache in Scala?
I am using scala-redis to make a connection to global redis database. I am able to connect easily with the locally running redis server but not sure what to pass in the constructor to connect with the ...
- 4,732
0
votes
1
answer
283
views
Spark program stucks because of Jedis Pool
According to my previous question with Jedis and threading. I changed my code to use a JedisPool instead of Jedis. But still the program stucks as the threads increase. I tried to increase .setMaxIdle(...
- 180
1
vote
0
answers
310
views
Why does my Spark Scala Job hang when reading/writing to Redis Pool using Jedis Client
I have a spark scala job that I posted about earlier which had long running tasks here, I was able to figure out that the job is getting stuck because of the connection to Redis. I'm seeing ...
- 157
0
votes
1
answer
734
views
Trouble using Threading with Redis (Jedis) in Scala
I have a Scala program using threading (actually Spark) and Redis (Jedis). I defined an object for my Redis operations where I have a Lazy val for the connection. I need each thread to open a ...
- 180
0
votes
2
answers
984
views
How to listen redis list event with redisson and ZIO
With Radisson, simply receiving events is enough to add new items to the list. To do this, you need to do the following:
object Test extends App {
val redisson = Redisson.create()
val events = ...
- 19
0
votes
1
answer
368
views
creating a RedisClient from a typed akka behavior
Im trying to use this scala redis library etaty which needs an implicit akka.actor.ActorSystem when creating it's RedisClient object. I used the context.system.classicSystem in the Behaviors.setup ...
- 144
0
votes
0
answers
872
views
Play framework how to use redis as cache server with tls enabled
I am trying to use Redis as a cache server for my web server written in scala using play framework.
I am using the library play-redis as per the play scala documentation. But I am not able to connect ...
- 1,789
0
votes
1
answer
630
views
Save kafka stream dataframe to Redis in Databricks after data transformation
I am using pyspark to direct the kafka streams to redis after performing aggregations on the data. The final output is a streaming datafame.
The code I connect to kafka streams. (You might find my ...
- 507
0
votes
1
answer
380
views
configuration of twitter finagle redis client with tls enabled
How do I configure the finagle Redis client with tls-enabled?
@Provides
def providesRedisClient(@Flag("redis-addr") host: String): redis.Client = {
redis.Client(host)
}
as the ...
- 1