[jira] [Commented] (SPARK-27409) Micro-batch support for Kafka Source in Spark 2.3

2019-04-10 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814314#comment-16814314 ] Gabor Somogyi commented on SPARK-27409: --- ping [~pbharaj] > Micro-batch support for Kafka Source

[jira] [Commented] (SPARK-27409) Micro-batch support for Kafka Source in Spark 2.3

2019-04-09 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813094#comment-16813094 ] Gabor Somogyi commented on SPARK-27409: --- It would definitely help if you can provide your

[jira] [Commented] (SPARK-27330) ForeachWriter is not being closed once a batch is aborted

2019-04-01 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806659#comment-16806659 ] Gabor Somogyi commented on SPARK-27330: --- Now I see the point and makes sense from my perspective.

[jira] [Commented] (SPARK-27330) ForeachWriter is not being closed once a batch is aborted

2019-04-01 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806638#comment-16806638 ] Gabor Somogyi commented on SPARK-27330: --- If processing throws any kind of exception then

[jira] [Updated] (SPARK-27294) Multi-cluster Kafka delegation token support

2019-03-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27294: -- Description: Kafka delegation token only supports single cluster at the moment. I've created

[jira] [Commented] (SPARK-27294) Multi-cluster Kafka delegation token support

2019-03-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802720#comment-16802720 ] Gabor Somogyi commented on SPARK-27294: --- [~vanzin] [~zsxwing] [~kabhwan] what do you think of the

[jira] [Created] (SPARK-27294) Multi-cluster Kafka delegation token support

2019-03-27 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27294: - Summary: Multi-cluster Kafka delegation token support Key: SPARK-27294 URL: https://issues.apache.org/jira/browse/SPARK-27294 Project: Spark Issue Type:

[jira] [Created] (SPARK-27270) Add Kafka dynamic JAAS authentication debug possibility

2019-03-25 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27270: - Summary: Add Kafka dynamic JAAS authentication debug possibility Key: SPARK-27270 URL: https://issues.apache.org/jira/browse/SPARK-27270 Project: Spark

[jira] [Commented] (SPARK-27218) spark-sql-kafka-0-10 startingOffset=earliest not working as expected with streaming

2019-03-25 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16800505#comment-16800505 ] Gabor Somogyi commented on SPARK-27218: --- [~emasab] no problem, the good thing that it has been

[jira] [Commented] (SPARK-27218) spark-sql-kafka-0-10 startingOffset=earliest not working as expected with streaming

2019-03-22 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799018#comment-16799018 ] Gabor Somogyi commented on SPARK-27218: --- Just for the sake of double checking are you sure the

[jira] [Comment Edited] (SPARK-27218) spark-sql-kafka-0-10 startingOffset=earliest not working as expected with streaming

2019-03-22 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798988#comment-16798988 ] Gabor Somogyi edited comment on SPARK-27218 at 3/22/19 1:22 PM:

[jira] [Comment Edited] (SPARK-27218) spark-sql-kafka-0-10 startingOffset=earliest not working as expected with streaming

2019-03-22 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798988#comment-16798988 ] Gabor Somogyi edited comment on SPARK-27218 at 3/22/19 12:53 PM: -

[jira] [Commented] (SPARK-27218) spark-sql-kafka-0-10 startingOffset=earliest not working as expected with streaming

2019-03-22 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798988#comment-16798988 ] Gabor Somogyi commented on SPARK-27218: --- [~emasab] Don't fully understand your test code: * When

[jira] [Resolved] (SPARK-27206) Using slice method with streaming api's Interval on DStream

2019-03-20 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-27206. --- Resolution: Invalid > Using slice method with streaming api's Interval on DStream >

[jira] [Commented] (SPARK-27206) Using slice method with streaming api's Interval on DStream

2019-03-20 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797153#comment-16797153 ] Gabor Somogyi commented on SPARK-27206: --- [~aarthipa] Can you please write a mail to the dev list?

[jira] [Commented] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-18 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794904#comment-16794904 ] Gabor Somogyi commented on SPARK-27124: --- [~hyukjin.kwon] thanks for your time in the discussion.

[jira] [Resolved] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-18 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-27124. --- Resolution: Won't Do OK, based on the discussion it's won't do. At least users may have

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789786#comment-16789786 ] Gabor Somogyi commented on SPARK-26998: --- Same understanding, chosen the file approach. >

[jira] [Comment Edited] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789653#comment-16789653 ] Gabor Somogyi edited comment on SPARK-26998 at 3/11/19 2:47 PM: Since

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789653#comment-16789653 ] Gabor Somogyi commented on SPARK-26998: --- Since the first part of the PR solved (http URLs in case

[jira] [Commented] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789591#comment-16789591 ] Gabor Somogyi commented on SPARK-27124: --- I would mention "SchemaConverters can be used to make

[jira] [Commented] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789494#comment-16789494 ] Gabor Somogyi commented on SPARK-27124: --- Yeah, the python implementation would use the same what

[jira] [Commented] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789376#comment-16789376 ] Gabor Somogyi commented on SPARK-27124: --- {quote}This is reachable via Py4J FWIW{quote} How

[jira] [Commented] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789356#comment-16789356 ] Gabor Somogyi commented on SPARK-27124: --- I've already put together a POC but interested in what do

[jira] [Created] (SPARK-27124) Expose org.apache.spark.sql.avro.SchemaConverters as developer API

2019-03-11 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27124: - Summary: Expose org.apache.spark.sql.avro.SchemaConverters as developer API Key: SPARK-27124 URL: https://issues.apache.org/jira/browse/SPARK-27124 Project: Spark

[jira] [Commented] (SPARK-20075) Support classifier, packaging in Maven coordinates

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-20075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789341#comment-16789341 ] Gabor Somogyi commented on SPARK-20075: --- [~kabhwan] cool. I think we both can give a try and share

[jira] [Commented] (SPARK-20075) Support classifier, packaging in Maven coordinates

2019-03-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-20075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789329#comment-16789329 ] Gabor Somogyi commented on SPARK-20075: --- [~kabhwan] To continue the discussion started on

[jira] [Commented] (SPARK-27044) Maven dependency resolution does not support classifiers

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787834#comment-16787834 ] Gabor Somogyi commented on SPARK-27044: --- Thanks [~herberts] rebuilt shaded jar was my main

[jira] [Commented] (SPARK-27044) Maven dependency resolution does not support classifiers

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787784#comment-16787784 ] Gabor Somogyi commented on SPARK-27044: --- I've already started but wanted to double check things

[jira] [Commented] (SPARK-27044) Maven dependency resolution does not support classifiers

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787754#comment-16787754 ] Gabor Somogyi commented on SPARK-27044: --- [~herberts] Could you give an example of {quote}fetch

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787720#comment-16787720 ] Gabor Somogyi commented on SPARK-27027: --- After compile {quote}./bin/spark-shell --packages

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787701#comment-16787701 ] Gabor Somogyi commented on SPARK-27027: --- With spark-shell, in unit test the functionality works.

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787662#comment-16787662 ] Gabor Somogyi commented on SPARK-27027: --- Please see the comments. The issue fully reproducible. >

[jira] [Comment Edited] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787662#comment-16787662 ] Gabor Somogyi edited comment on SPARK-27027 at 3/8/19 8:34 AM: --- Please see

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787626#comment-16787626 ] Gabor Somogyi commented on SPARK-27027: --- Not sure its avro issue but somehow SQL only shows the

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786978#comment-16786978 ] Gabor Somogyi commented on SPARK-27027: --- [~dongjoon] [~Gengliang.Wang] do you have any idea what

[jira] [Comment Edited] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783478#comment-16783478 ] Gabor Somogyi edited comment on SPARK-27027 at 3/7/19 4:44 PM: --- What I've

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786969#comment-16786969 ] Gabor Somogyi commented on SPARK-27027: --- Hmm, seems like the converted avro binary is exactly the

[jira] [Comment Edited] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783478#comment-16783478 ] Gabor Somogyi edited comment on SPARK-27027 at 3/7/19 4:36 PM: --- What I've

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786726#comment-16786726 ] Gabor Somogyi commented on SPARK-26998: --- I've tested the things through and see the issue. I think

[jira] [Commented] (SPARK-24621) WebUI - application 'name' urls point to http instead of https (even when ssl enabled)

2019-03-06 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785583#comment-16785583 ] Gabor Somogyi commented on SPARK-24621: --- I've analyzed through this issue with the latest master

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-05 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784410#comment-16784410 ] Gabor Somogyi commented on SPARK-26998: --- Ahaaa, I see now. 2 problems tried to be solved in one

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-05 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784406#comment-16784406 ] Gabor Somogyi commented on SPARK-26998: --- {quote} Can be resolved if below PR is merged: [[Github]

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-05 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784391#comment-16784391 ] Gabor Somogyi commented on SPARK-26998: --- [~toopt4] thanks for the info. Are you working on this?

[jira] [Comment Edited] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-05 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784391#comment-16784391 ] Gabor Somogyi edited comment on SPARK-26998 at 3/5/19 12:51 PM:

[jira] [Updated] (SPARK-27055) Update Structured Streaming documentation because of DSv2 changes

2019-03-05 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27055: -- Description: Since SPARK-26956 has been merged the Structured Streaming documentation has to

[jira] [Created] (SPARK-27055) Update Structured Streaming documentation because of DSv2 changes

2019-03-05 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27055: - Summary: Update Structured Streaming documentation because of DSv2 changes Key: SPARK-27055 URL: https://issues.apache.org/jira/browse/SPARK-27055 Project: Spark

[jira] [Reopened] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reopened SPARK-27027: --- > from_avro function does not deserialize the Avro record of a struct column > type correctly

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783509#comment-16783509 ] Gabor Somogyi commented on SPARK-27027: --- > Does that imply the bug is in the implementation of

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783505#comment-16783505 ] Gabor Somogyi commented on SPARK-27027: --- [~hyukjin.kwon] seems like the issue comes only with

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783478#comment-16783478 ] Gabor Somogyi commented on SPARK-27027: --- What I've found is really interesting. The following

[jira] [Updated] (SPARK-27046) Remove SPARK-19185 related references from documentation since its resolved

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27046: -- Component/s: Documentation > Remove SPARK-19185 related references from documentation since

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783416#comment-16783416 ] Gabor Somogyi commented on SPARK-27027: --- OK, started to dig and write it here when I've found

[jira] [Commented] (SPARK-27027) from_avro function does not deserialize the Avro record of a struct column type correctly

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783388#comment-16783388 ] Gabor Somogyi commented on SPARK-27027: --- [~hyukjin.kwon] excellent. Can you put the commit here

[jira] [Created] (SPARK-27046) Remove SPARK-19185 related references from documentation since its resolved

2019-03-04 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27046: - Summary: Remove SPARK-19185 related references from documentation since its resolved Key: SPARK-27046 URL: https://issues.apache.org/jira/browse/SPARK-27046

[jira] [Commented] (SPARK-26727) CREATE OR REPLACE VIEW query fails with TableAlreadyExistsException

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783337#comment-16783337 ] Gabor Somogyi commented on SPARK-26727: --- I think the trick is not executing things in a loop but

[jira] [Updated] (SPARK-27042) Query fails if task is failing due to corrupt cached Kafka producer

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27042: -- Description: If a task is failing due to a corrupt cached KafkaProducer and the task is

[jira] [Updated] (SPARK-27042) Query fails if task is failing due to corrupt cached Kafka producer

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27042: -- Description: If a task is failing due to a cached corrupted KafkaProducer and the task is

[jira] [Updated] (SPARK-27042) Query fails if task is failing due to corrupt cached Kafka producer

2019-03-04 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27042: -- Description: If a task is failing due to a cached Kafka producer and the task is retried in

[jira] [Created] (SPARK-27042) Query fails if task is failing due to corrupt cached Kafka producer

2019-03-04 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27042: - Summary: Query fails if task is failing due to corrupt cached Kafka producer Key: SPARK-27042 URL: https://issues.apache.org/jira/browse/SPARK-27042 Project: Spark

[jira] [Comment Edited] (SPARK-26727) CREATE OR REPLACE VIEW query fails with TableAlreadyExistsException

2019-03-03 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783074#comment-16783074 ] Gabor Somogyi edited comment on SPARK-26727 at 3/4/19 7:55 AM: --- [~Udbhav

[jira] [Commented] (SPARK-26727) CREATE OR REPLACE VIEW query fails with TableAlreadyExistsException

2019-03-03 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783074#comment-16783074 ] Gabor Somogyi commented on SPARK-26727: --- I was dealing with "failOnDataLoss=false should not

[jira] [Comment Edited] (SPARK-26727) CREATE OR REPLACE VIEW query fails with TableAlreadyExistsException

2019-03-01 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782162#comment-16782162 ] Gabor Somogyi edited comment on SPARK-26727 at 3/1/19 10:21 PM: I've

[jira] [Commented] (SPARK-26727) CREATE OR REPLACE VIEW query fails with TableAlreadyExistsException

2019-03-01 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782162#comment-16782162 ] Gabor Somogyi commented on SPARK-26727: --- I've seen this issue lately when I was dealing with a

[jira] [Commented] (SPARK-26998) spark.ssl.keyStorePassword in plaintext on 'ps -ef' output of executor processes in Standalone mode

2019-03-01 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782135#comment-16782135 ] Gabor Somogyi commented on SPARK-26998: --- How is this different from

[jira] [Created] (SPARK-27022) Kafka delegation token support

2019-03-01 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27022: - Summary: Kafka delegation token support Key: SPARK-27022 URL: https://issues.apache.org/jira/browse/SPARK-27022 Project: Spark Issue Type: Improvement

[jira] [Commented] (SPARK-26783) Kafka parameter documentation doesn't match with the reality (upper/lowercase)

2019-02-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16779408#comment-16779408 ] Gabor Somogyi commented on SPARK-26783: --- I've gone through the whole chain on v2.4.0 and it looks

[jira] [Resolved] (SPARK-26783) Kafka parameter documentation doesn't match with the reality (upper/lowercase)

2019-02-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-26783. --- Resolution: Not A Bug > Kafka parameter documentation doesn't match with the reality

[jira] [Comment Edited] (SPARK-26783) Kafka parameter documentation doesn't match with the reality (upper/lowercase)

2019-02-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16779408#comment-16779408 ] Gabor Somogyi edited comment on SPARK-26783 at 2/27/19 2:56 PM: I've

[jira] [Updated] (SPARK-27002) Latest kafka delegation token not always picked up

2019-02-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27002: -- Description: Lately KAFKA-8004 has been discovered and this triggered me to do further tests

[jira] [Created] (SPARK-27002) Latest kafka delegation token not always picked up

2019-02-27 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-27002: - Summary: Latest kafka delegation token not always picked up Key: SPARK-27002 URL: https://issues.apache.org/jira/browse/SPARK-27002 Project: Spark Issue

[jira] [Updated] (SPARK-27002) Latest kafka delegation token not always picked up

2019-02-27 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-27002: -- Priority: Critical (was: Major) > Latest kafka delegation token not always picked up >

[jira] [Resolved] (SPARK-26686) Remove unnecessary KafkaSourceProvider parameter lowercase conversion

2019-02-19 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-26686. --- Resolution: Won't Do > Remove unnecessary KafkaSourceProvider parameter lowercase

[jira] [Commented] (SPARK-26686) Remove unnecessary KafkaSourceProvider parameter lowercase conversion

2019-02-19 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771805#comment-16771805 ] Gabor Somogyi commented on SPARK-26686: --- As the API is not explicitly stating that it provides

[jira] [Resolved] (SPARK-26888) Upgrade to Log4j 2.x

2019-02-15 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-26888. --- Resolution: Duplicate > Upgrade to Log4j 2.x > > >

[jira] [Commented] (SPARK-26888) Upgrade to Log4j 2.x

2019-02-15 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769746#comment-16769746 ] Gabor Somogyi commented on SPARK-26888: --- +1, duplicate. > Upgrade to Log4j 2.x >

[jira] [Created] (SPARK-26889) Fix timestamp type in Structured Streaming + Kafka Integration Guide

2019-02-15 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-26889: - Summary: Fix timestamp type in Structured Streaming + Kafka Integration Guide Key: SPARK-26889 URL: https://issues.apache.org/jira/browse/SPARK-26889 Project:

[jira] [Created] (SPARK-26888) Upgrade to Log4j 2.x

2019-02-15 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-26888: - Summary: Upgrade to Log4j 2.x Key: SPARK-26888 URL: https://issues.apache.org/jira/browse/SPARK-26888 Project: Spark Issue Type: Improvement

[jira] [Resolved] (SPARK-19888) Seeing offsets not resetting even when reset policy is configured explicitly

2019-02-14 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-19888. --- Resolution: Fixed Issue solved in SPARK-19185. > Seeing offsets not resetting even when

[jira] [Commented] (SPARK-19888) Seeing offsets not resetting even when reset policy is configured explicitly

2019-02-14 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768276#comment-16768276 ] Gabor Somogyi commented on SPARK-19888: --- Please reopen it if appears again. > Seeing offsets not

[jira] [Updated] (SPARK-26866) Support kinesis checkpoint with subSequenceNumber

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26866: -- Target Version/s: (was: 2.3.0) > Support kinesis checkpoint with subSequenceNumber >

[jira] [Updated] (SPARK-26866) Support kinesis checkpoint with subSequenceNumber

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26866: -- Fix Version/s: (was: 2.3.0) > Support kinesis checkpoint with subSequenceNumber >

[jira] [Updated] (SPARK-26772) Delete ServiceCredentialProvider and make HadoopDelegationTokenProvider a developer API

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26772: -- Description: HadoopDelegationTokenProvider has basically the same functionality just likeĀ 

[jira] [Updated] (SPARK-26772) Delete ServiceCredentialProvider and make HadoopDelegationTokenProvider a developer API

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26772: -- Description: HadoopDelegationTokenProvider has basically the same functionality just likeĀ  >

[jira] [Updated] (SPARK-26772) Delete ServiceCredentialProvider and make HadoopDelegationTokenProvider a developer API

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26772: -- Summary: Delete ServiceCredentialProvider and make HadoopDelegationTokenProvider a developer

[jira] [Updated] (SPARK-26772) Delete ServiceCredentialProvider and make HadoopDelegationTokenProvider a developer API

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26772: -- Description: (was: YARNHadoopDelegationTokenManager now loads ServiceCredentialProviders

[jira] [Commented] (SPARK-26856) Python support for "from_avro" and "to_avro" APIs

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767120#comment-16767120 ] Gabor Somogyi commented on SPARK-26856: --- OK, same understanding. Adapt the patch to the things

[jira] [Commented] (SPARK-26856) Python support for "from_avro" and "to_avro" APIs

2019-02-12 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765977#comment-16765977 ] Gabor Somogyi commented on SPARK-26856: --- You mean not even having an API but just suggest the

[jira] [Commented] (SPARK-26856) Python support for "from_avro" and "to_avro" APIs

2019-02-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764819#comment-16764819 ] Gabor Somogyi commented on SPARK-26856: --- Until now nothing fancy just added a direct call to the

[jira] [Commented] (SPARK-26856) Python support for "from_avro" and "to_avro" APIs

2019-02-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764839#comment-16764839 ] Gabor Somogyi commented on SPARK-26856: --- What can enhanced here is to add a check whether the JVM

[jira] [Commented] (SPARK-26856) Python support for "from_avro" and "to_avro" APIs

2019-02-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764790#comment-16764790 ] Gabor Somogyi commented on SPARK-26856: --- I've created a patch but hesitant to create a PR because

[jira] [Created] (SPARK-26856) Python support for "from_avro" and "to_avro" APIs

2019-02-11 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created SPARK-26856: - Summary: Python support for "from_avro" and "to_avro" APIs Key: SPARK-26856 URL: https://issues.apache.org/jira/browse/SPARK-26856 Project: Spark Issue

[jira] [Commented] (SPARK-26783) Kafka parameter documentation doesn't match with the reality (upper/lowercase)

2019-02-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764772#comment-16764772 ] Gabor Somogyi commented on SPARK-26783: --- [~dongjoon] at the moment waiting on [~sindiri] to report

[jira] [Comment Edited] (SPARK-26845) Avro to_avro from_avro roundtrip fails if data type is string

2019-02-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764769#comment-16764769 ] Gabor Somogyi edited comment on SPARK-26845 at 2/11/19 8:50 AM:

[jira] [Commented] (SPARK-26845) Avro to_avro from_avro roundtrip fails if data type is string

2019-02-11 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764769#comment-16764769 ] Gabor Somogyi commented on SPARK-26845: --- [~Gengliang.Wang] Thanks for the confirmation! Hope

[jira] [Resolved] (SPARK-26845) Avro to_avro from_avro roundtrip fails if data type is string

2019-02-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved SPARK-26845. --- Resolution: Not A Problem > Avro to_avro from_avro roundtrip fails if data type is string >

[jira] [Commented] (SPARK-26845) Avro to_avro from_avro roundtrip fails if data type is string

2019-02-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763868#comment-16763868 ] Gabor Somogyi commented on SPARK-26845: --- I think I've found the reason for the second question:

[jira] [Commented] (SPARK-26845) Avro to_avro from_avro roundtrip fails if data type is string

2019-02-08 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763848#comment-16763848 ] Gabor Somogyi commented on SPARK-26845: --- [~attilapiros] Thanks for the help, this explains why the

[jira] [Updated] (SPARK-26845) Avro to_avro from_avro roundtrip fails if data type is string

2019-02-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26845: -- Summary: Avro to_avro from_avro roundtrip fails if data type is string (was: Avro from_avro

[jira] [Updated] (SPARK-26845) Avro from_avro to_avro roundtrip fails if data type is string

2019-02-07 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated SPARK-26845: -- Labels: correctness (was: ) > Avro from_avro to_avro roundtrip fails if data type is string

<    1   2   3   4   5   6   7   >