[jira] [Commented] (SPARK-25106) A new Kafka consumer gets created for every batch

[ https://issues.apache.org/jira/browse/SPARK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591834#comment-16591834 ] Alexis Seigneurin commented on SPARK-25106: --- I just built the code from

[jira] [Updated] (SPARK-25106) A new Kafka consumer gets created for every batch

[ https://issues.apache.org/jira/browse/SPARK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-25106: -- Description: I have a fairly simple piece of code that reads from Kafka, applies some

[jira] [Updated] (SPARK-25106) A new Kafka consumer gets created for every batch

[ https://issues.apache.org/jira/browse/SPARK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-25106: -- Description: I have a fairly simple piece of code that reads from Kafka, applies some

[jira] [Updated] (SPARK-25106) A new Kafka consumer gets created for every batch

[ https://issues.apache.org/jira/browse/SPARK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-25106: -- Attachment: console.txt > A new Kafka consumer gets created for every batch >

[jira] [Created] (SPARK-25106) A new Kafka consumer gets created for every batch

Alexis Seigneurin created SPARK-25106: - Summary: A new Kafka consumer gets created for every batch Key: SPARK-25106 URL: https://issues.apache.org/jira/browse/SPARK-25106 Project: Spark

[jira] [Created] (SPARK-20110) Windowed aggregation do not work when the timestamp is a nested field

Alexis Seigneurin created SPARK-20110: - Summary: Windowed aggregation do not work when the timestamp is a nested field Key: SPARK-20110 URL: https://issues.apache.org/jira/browse/SPARK-20110

[jira] [Commented] (SPARK-10925) Exception when joining DataFrames

[ https://issues.apache.org/jira/browse/SPARK-10925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14957731#comment-14957731 ] Alexis Seigneurin commented on SPARK-10925: --- Well, technically, it's not a duplicate column. An

[jira] [Commented] (SPARK-5885) Add VectorAssembler

[ https://issues.apache.org/jira/browse/SPARK-5885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14953236#comment-14953236 ] Alexis Seigneurin commented on SPARK-5885: -- {quote} I tried to create a pipeline in which the

[jira] [Comment Edited] (SPARK-10925) Exception when joining DataFrames

[ https://issues.apache.org/jira/browse/SPARK-10925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943318#comment-14943318 ] Alexis Seigneurin edited comment on SPARK-10925 at 10/5/15 12:44 PM: -

[jira] [Updated] (SPARK-10925) Exception when joining DataFrames

[ https://issues.apache.org/jira/browse/SPARK-10925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-10925: -- Attachment: (was: Photo 05-10-2015 14 31 16.jpg) > Exception when joining

[jira] [Updated] (SPARK-10925) Exception when joining DataFrames

[ https://issues.apache.org/jira/browse/SPARK-10925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-10925: -- Attachment: Photo 05-10-2015 14 31 16.jpg > Exception when joining DataFrames >

[jira] [Updated] (SPARK-10925) Exception when joining DataFrames

[ https://issues.apache.org/jira/browse/SPARK-10925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-10925: -- Attachment: TestCase2.scala > Exception when joining DataFrames >

[jira] [Created] (SPARK-10925) Exception when joining DataFrames

Alexis Seigneurin created SPARK-10925: - Summary: Exception when joining DataFrames Key: SPARK-10925 URL: https://issues.apache.org/jira/browse/SPARK-10925 Project: Spark Issue Type: Bug

[jira] [Updated] (SPARK-10925) Exception when joining DataFrames

[ https://issues.apache.org/jira/browse/SPARK-10925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-10925: -- Attachment: Photo 05-10-2015 14 31 16.jpg The workflow. > Exception when joining

[jira] [Commented] (SPARK-4557) Spark Streaming' foreachRDD method should accept a VoidFunction..., not a Function..., Void

[ https://issues.apache.org/jira/browse/SPARK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610376#comment-14610376 ] Alexis Seigneurin commented on SPARK-4557: -- Yes, but the problem is not compiling

[jira] [Commented] (SPARK-4557) Spark Streaming' foreachRDD method should accept a VoidFunction..., not a Function..., Void

[ https://issues.apache.org/jira/browse/SPARK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14610456#comment-14610456 ] Alexis Seigneurin commented on SPARK-4557: -- Here:

[jira] [Commented] (SPARK-4557) Spark Streaming' foreachRDD method should accept a VoidFunction..., not a Function..., Void

[ https://issues.apache.org/jira/browse/SPARK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14581888#comment-14581888 ] Alexis Seigneurin commented on SPARK-4557: -- I'm using Java 8. Here is what the

[jira] [Commented] (SPARK-4557) Spark Streaming' foreachRDD method should accept a VoidFunction..., not a Function..., Void

[ https://issues.apache.org/jira/browse/SPARK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572965#comment-14572965 ] Alexis Seigneurin commented on SPARK-4557: -- I've tried to overload:

[jira] [Created] (SPARK-5412) Cannot bind Master to a specific hostname as per the documentation

Alexis Seigneurin created SPARK-5412: Summary: Cannot bind Master to a specific hostname as per the documentation Key: SPARK-5412 URL: https://issues.apache.org/jira/browse/SPARK-5412 Project:

[jira] [Commented] (SPARK-4560) Lambda deserialization error

[ https://issues.apache.org/jira/browse/SPARK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14269711#comment-14269711 ] Alexis Seigneurin commented on SPARK-4560: -- Any update on this one? Lambda

[jira] [Updated] (SPARK-4560) Lambda deserialization error

[ https://issues.apache.org/jira/browse/SPARK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-4560: - Affects Version/s: 1.1.1 Lambda deserialization error

[jira] [Created] (SPARK-4560) Lambda deserialization error

Alexis Seigneurin created SPARK-4560: Summary: Lambda deserialization error Key: SPARK-4560 URL: https://issues.apache.org/jira/browse/SPARK-4560 Project: Spark Issue Type: Bug

[jira] [Updated] (SPARK-4560) Lambda deserialization error

[ https://issues.apache.org/jira/browse/SPARK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Seigneurin updated SPARK-4560: - Attachment: IndexTweets.java pom.xml I'm attaching the class I'm using

[jira] [Commented] (SPARK-4560) Lambda deserialization error

[ https://issues.apache.org/jira/browse/SPARK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=1482#comment-1482 ] Alexis Seigneurin commented on SPARK-4560: -- It looks like the foreach() method is

[jira] [Commented] (SPARK-1834) NoSuchMethodError when invoking JavaPairRDD.reduce() in Java

[ https://issues.apache.org/jira/browse/SPARK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14156464#comment-14156464 ] Alexis Seigneurin commented on SPARK-1834: -- Same issue here with Spark 1.1.0: