[jira] [Resolved] (SPARK-43188) Cannot write to Azure Datalake Gen2 (abfs/abfss) after Spark 3.1.2

[ https://issues.apache.org/jira/browse/SPARK-43188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas PHUNG resolved SPARK-43188. --- Resolution: Workaround > Cannot write to Azure Datalake Gen2 (abfs/abfss) after Spark 3.1.2

[jira] [Commented] (SPARK-43188) Cannot write to Azure Datalake Gen2 (abfs/abfss) after Spark 3.1.2

[ https://issues.apache.org/jira/browse/SPARK-43188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726667#comment-17726667 ] Nicolas PHUNG commented on SPARK-43188: --- Hello [~srowen]  I don't think so, but I manage to get it

[jira] [Updated] (SPARK-43188) Cannot write to Azure Datalake Gen2 (abfs/abfss) after Spark 3.1.2

[ https://issues.apache.org/jira/browse/SPARK-43188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas PHUNG updated SPARK-43188: -- Description: Hello, I have an issue with Spark 3.3.2 & Spark 3.4.0 to write into Azure Data

[jira] [Created] (SPARK-43188) Cannot write to Azure Datalake Gen2 (abfs/abfss) after Spark 3.1.2

Nicolas PHUNG created SPARK-43188: - Summary: Cannot write to Azure Datalake Gen2 (abfs/abfss) after Spark 3.1.2 Key: SPARK-43188 URL: https://issues.apache.org/jira/browse/SPARK-43188 Project: Spark

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15028966#comment-15028966 ] Nicolas PHUNG commented on SPARK-7122: -- I'm confirming it works now in Spark 1.5.2 >

[jira] [Issue Comment Deleted] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas PHUNG updated SPARK-7122: - Comment: was deleted (was: Sorry for the delay. I will test as soon as Cloudera distribution has

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14904515#comment-14904515 ] Nicolas PHUNG commented on SPARK-7122: -- Sorry for the delay. I will test as soon as Cloudera

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14904513#comment-14904513 ] Nicolas PHUNG commented on SPARK-7122: -- Sorry for the delay. I will test as soon as Cloudera

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587602#comment-14587602 ] Nicolas PHUNG commented on SPARK-7122: -- I'm waiting for it to be in the release

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14571609#comment-14571609 ] Nicolas PHUNG commented on SPARK-7122: -- Platon, I have tried with a 10 seconds batch

[jira] [Comment Edited] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14570847#comment-14570847 ] Nicolas PHUNG edited comment on SPARK-7122 at 6/3/15 1:53 PM: --

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568854#comment-14568854 ] Nicolas PHUNG commented on SPARK-7122: -- For _KafkaUtils.createStream_, jobs take

[jira] [Comment Edited] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569147#comment-14569147 ] Nicolas PHUNG edited comment on SPARK-7122 at 6/2/15 2:23 PM: --

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569147#comment-14569147 ] Nicolas PHUNG commented on SPARK-7122: -- Mode 1 (old Kafka Streaming API) {code}

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569343#comment-14569343 ] Nicolas PHUNG commented on SPARK-7122: -- Yes, I print just the first 11 messages. But

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567879#comment-14567879 ] Nicolas PHUNG commented on SPARK-7122: -- My events are timestamp. So I just check the

[jira] [Commented] (SPARK-7122) KafkaUtils.createDirectStream - unreasonable processing time in absence of load

[ https://issues.apache.org/jira/browse/SPARK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567857#comment-14567857 ] Nicolas PHUNG commented on SPARK-7122: -- I have a similar issue regarding the

[jira] [Commented] (SPARK-3601) Kryo NPE for output operations on Avro complex Objects even after registering.

[ https://issues.apache.org/jira/browse/SPARK-3601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519005#comment-14519005 ] Nicolas PHUNG commented on SPARK-3601: -- For GenericData.Array Avro, I use the