Issues
- 0
Add a tuple->vec function
#140 opened by johnmcconnell - 0
- 0
Update log4j 1.x to 2.x
#138 opened by johnmcconnell - 0
No session ns in 0.7
#137 opened by alanmarazzi - 0
Getting error while setting Spark configuration
#136 opened by mayankpahwa - 1
- 9
support spark 2.3.1
#134 opened by lambda-knight - 5
Getting error on spark job submission
#132 opened by deepakjangid123 - 0
Not working with clojure 1.9
#133 opened by deepakjangid123 - 6
Registering User Defined Functions in SparkSQL
#125 opened by gareth625 - 2
Possible issue with set-if-missing?
#127 opened by MissingNo1028 - 3
Warning killing my CI
#118 opened by cigrainger - 0
Wrapper for `.foreachRDD` is missing
#120 opened by slipset - 0
`flambo.sql` shadows `clojure.core/count`
#119 opened by slipset - 1
Exception: org.apache.spark.SparkException: Failed to get broadcast_0_piece0 of broadcast_0
#114 opened by Ryan-Factual - 1
dataframe via jdbc.write() doesn't save results?
#113 opened by joefromct - 2
Flambo shell
#111 opened by zero323 - 1
Error using flambo sql
#110 opened by saikatkumardey - 9
Connecting spark cluster from REPL
#103 opened by ogis-hashi - 1
- 4
Left Outer Join documentation is inaccurate
#107 opened by philipnee - 1
hive-context throws No such var: sql/hive-context
#106 opened by jiyouyou125 - 4
java.lang.NoSuchMethodError: scala.collection.immutable.ListSet$.empty()Lscala/collection/immutable/ListSet;
#104 opened by funston - 4
f/iterator-fn fails
#102 opened by ogis-hashi - 2
How to create a comparator from api/fn macro?
#72 opened by ararog - 13
- 2
flatMap Exception: clojure.lang.PersistentVector cannot be cast to java.util.Iterator
#96 opened by clojurians-org - 8
Cannot use map on RDD action result
#98 opened by minor6th - 2
f/map doesn't work on a sql DataFrame
#85 opened by RasterBurn - 2
- 2
0.8.0-SNAPSHOT failed with java.lang.ClassCastException: clojure.lang.LazySeq
#97 opened by ogis-hashi - 5
spark 2.0 text-file error
#95 opened by clojurians-org - 1
How to define custom keys and Partitioners?
#94 opened by punit-naik - 2
Topic map in flambo.streaming/kafka-stream
#91 opened by punit-naik - 1
defsparkfn does not support docstrings
#80 opened by b-ryan - 1
How to destructure dataframe/rdd?
#84 opened by sihingkk - 3
- 14
Flambo Stand-Alone Applications Broken
#78 opened by snunez1 - 4
Using sparksql rows in flambo
#66 opened by ararog - 2
Running on mesos with lein run
#74 opened by krukowski - 1
Can't map in saveAsTextFile
#65 opened by afandian - 1
Flambo on Mesos
#70 opened by hellonico - 3
WARN fn: caught exception: com.esotericsoftware.kryo.KryoException: java.util.ConcurrentModificationException
#73 opened by danoyoung - 1
Add support for RDD/min and max
#67 opened by ararog - 1
0.6.0 not available yet on clojars
#68 opened by esumitra - 1
Dataframes lacks CSV Reader
#56 opened by snunez1 - 0
Tests for `flambo.sql`
#57 opened by snunez1 - 0
JavaDoubleRDD Strangeness
#61 opened by snunez1 - 3
No matching method found for join
#53 opened by snunez1 - 2
ClassNotFoundException: flambo.function.Function
#52 opened by snunez1