clear query| facets| time Search criteria: .   Results from 11 to 20 from 769 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Can I specify watermark using raw sql alone? - Spark - [mail # user]
...I don't see a withWatermark UDF to use it in Raw sql. I am currently usingSpark 2.3.1On Sat, Jul 14, 2018 at 4:19 PM, kant kodali  wrote:> Hi All,>> Can I specify watermark usi...
   Author: kant kodali , 2018-07-15, 06:57
[SPARK-20894] Error while checkpointing to HDFS - Spark - [issue]
...Dataset<Row> df2 = df1.groupBy(functions.window(df1.col("Timestamp5"), "24 hours", "24 hours"), df1.col("AppName")).count();StreamingQuery query = df2.writeStream().foreach(new KafkaSi...    Author: kant kodali , 2018-07-12, 17:43
[FLINK-8795] Scala shell broken for Flip6 - Flink - [issue]
...I am trying to run the simple code below after building everything from Flink's github master branch for various reasons. I get an exception below and I wonder what runs on port 9065? and Ho...    Author: kant kodali , 2018-07-09, 13:01
[expand - 5 more] - spark-shell gets stuck in ACCEPTED state forever when ran in YARN client mode. - Spark - [mail # user]
...@yohann Looks like something is wrong with my environment which I am yet tofigure out but the theory so far makes sense and I had also tried it inanother environments with very minimal confi...
   Author: kant kodali , 2018-07-09, 11:15
[expand - 1 more] - Error while doing stream-stream inner join (java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access) - Spark - [mail # user]
...I am currently using Spark 2.3.0. Will try it with 2.3.1On Tue, Jul 3, 2018 at 3:12 PM, Shixiong(Ryan) Zhu wrote:> Which version are you using? There is a known issue regarding this and&g...
   Author: kant kodali , 2018-07-04, 05:31
[expand - 1 more] - Is there a plan for Feature like this in C* ? - Cassandra - [mail # user]
...Hi Justin,Thanks, Looks like a very early stage feature and no integration with Kafkayet I suppose.Thanks!On Mon, Jul 2, 2018 at 6:24 PM, Justin Cameron wrote:> yes, take a look at http:/...
   Author: Kant Kodali , 2018-07-03, 01:51
Feature request: Java-specific transform method in Dataset - Spark - [mail # dev]
...I am not affiliated with Flink or Spark but I do think some of the thoughtsheremakes senseOn Sun, Jul 1, 2018 at 4:12 PM, Sean Owen  wrote:> It's true, that is one of the issues to b...
   Author: kant kodali , 2018-07-02, 02:12
[expand - 1 more] - Does Spark Structured Streaming have a JDBC sink or Do I need to use ForEachWriter? - Spark - [mail # user]
...From my experience so far, update mode in structured streaming is the mostuseful one out of the three available modes. But when it comes it RDBMSthere isn't really an upsert so If I go with ...
   Author: kant kodali , 2018-06-21, 14:36
is spark stream-stream joins in update mode targeted for 2.4? - Spark - [mail # user]
...Hi All,Is spark stream-stream joins in update mode targeted for 2.4?Thanks!...
   Author: kant kodali , 2018-06-18, 10:42
is there a way to parse and modify raw spark sql query? - Spark - [mail # user]
...Hi All,is there a way to parse and modify raw spark sql query?For example, given the following queryspark.sql("select hello from view")I want to modify the query or logical plan such that I ...
   Author: kant kodali , 2018-06-05, 08:39