[jira] [Assigned] (SPARK-27416) UnsafeMapData & UnsafeArrayData Kryo serialization breaks when two machines have different Oops size

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan reassigned SPARK-27416: --- Assignee: peng bo > UnsafeMapData & UnsafeArrayData Kryo serialization breaks when two

[jira] [Resolved] (SPARK-27416) UnsafeMapData & UnsafeArrayData Kryo serialization breaks when two machines have different Oops size

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan resolved SPARK-27416. - Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24357

[jira] [Created] (SPARK-27485) Certain query plans fail to run when autoBroadcastJoinThreshold is set to -1

2019-04-16 Thread Muthu Jayakumar (JIRA)
Muthu Jayakumar created SPARK-27485: --- Summary: Certain query plans fail to run when  autoBroadcastJoinThreshold is set to -1 Key: SPARK-27485 URL: https://issues.apache.org/jira/browse/SPARK-27485

[jira] [Assigned] (SPARK-27483) move the data source v2 fallback to v1 logic to an analyzer rule

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan reassigned SPARK-27483: --- Assignee: (was: Wenchen Fan) > move the data source v2 fallback to v1 logic to an

[jira] [Created] (SPARK-27484) create the streaming writing logical plan node before query is analyzed

2019-04-16 Thread Wenchen Fan (JIRA)
Wenchen Fan created SPARK-27484: --- Summary: create the streaming writing logical plan node before query is analyzed Key: SPARK-27484 URL: https://issues.apache.org/jira/browse/SPARK-27484 Project: Spark

[jira] [Created] (SPARK-27483) move the data source v2 fallback to v1 logic to an analyzer rule

2019-04-16 Thread Wenchen Fan (JIRA)
Wenchen Fan created SPARK-27483: --- Summary: move the data source v2 fallback to v1 logic to an analyzer rule Key: SPARK-27483 URL: https://issues.apache.org/jira/browse/SPARK-27483 Project: Spark

[jira] [Updated] (SPARK-27482) Show BroadcastHashJoinExec numOutputRows statistics info on SparkSQL UI page

2019-04-16 Thread peng bo (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] peng bo updated SPARK-27482: Description: Currently, the {{SparkSQL}} UI page shows only actual {{metric}} info in each {{SparkPlan}} 

[jira] [Updated] (SPARK-27482) Show BroadcastHashJoinExec numOutputRows statistics info on SparkSQL UI page

2019-04-16 Thread peng bo (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] peng bo updated SPARK-27482: Summary: Show BroadcastHashJoinExec numOutputRows statistics info on SparkSQL UI page (was: Show

[jira] [Updated] (SPARK-27482) Show BroadcastHashJoinExec numOutputRows statistic info on SparkSQL UI page

2019-04-16 Thread peng bo (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] peng bo updated SPARK-27482: Attachment: SPARK-27482-1.png > Show BroadcastHashJoinExec numOutputRows statistic info on SparkSQL UI

[jira] [Created] (SPARK-27482) Show BroadcastHashJoinExec numOutputRows statistic info on SparkSQL UI page

2019-04-16 Thread peng bo (JIRA)
peng bo created SPARK-27482: --- Summary: Show BroadcastHashJoinExec numOutputRows statistic info on SparkSQL UI page Key: SPARK-27482 URL: https://issues.apache.org/jira/browse/SPARK-27482 Project: Spark

[jira] [Resolved] (SPARK-27479) Hide API docs for "org.apache.spark.util.kvstore"

2019-04-16 Thread Xiao Li (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Li resolved SPARK-27479. - Resolution: Fixed Fix Version/s: 2.4.2 > Hide API docs for "org.apache.spark.util.kvstore" >

[jira] [Commented] (SPARK-27468) "Storage Level" in "RDD Storage Page" is not correct

2019-04-16 Thread shahid (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819679#comment-16819679 ] shahid commented on SPARK-27468: Hi [~srfnmnk], I tried to reproduce in the master branch. The steps

[jira] [Updated] (SPARK-27468) "Storage Level" in "RDD Storage Page" is not correct

2019-04-16 Thread shahid (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shahid updated SPARK-27468: --- Attachment: Screenshot from 2019-04-17 10-42-55.png > "Storage Level" in "RDD Storage Page" is not correct

[jira] [Issue Comment Deleted] (SPARK-24630) SPIP: Support SQLStreaming in Spark

2019-04-16 Thread Kevin Zhang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-24630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Zhang updated SPARK-24630: Comment: was deleted (was: thanks [~Jackey Lee] So I'm wondering what's blocking the pr of this

[jira] [Created] (SPARK-27481) Upgrade commons-logging to 1.1.3

2019-04-16 Thread Yuming Wang (JIRA)
Yuming Wang created SPARK-27481: --- Summary: Upgrade commons-logging to 1.1.3 Key: SPARK-27481 URL: https://issues.apache.org/jira/browse/SPARK-27481 Project: Spark Issue Type: Sub-task

[jira] [Comment Edited] (SPARK-16859) History Server storage information is missing

2019-04-16 Thread shahid (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-16859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819662#comment-16819662 ] shahid edited comment on SPARK-16859 at 4/17/19 2:07 AM: - [~Hauer] [~toopt4] Can

[jira] [Commented] (SPARK-16859) History Server storage information is missing

2019-04-16 Thread shahid (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-16859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819662#comment-16819662 ] shahid commented on SPARK-16859: [~Hauer][~toopt4] Can you try enabling

[jira] [Created] (SPARK-27480) Improve explain output of describe query command to show the actual input query as opposed to a truncated logical plan.

2019-04-16 Thread Dilip Biswal (JIRA)
Dilip Biswal created SPARK-27480: Summary: Improve explain output of describe query command to show the actual input query as opposed to a truncated logical plan. Key: SPARK-27480 URL:

[jira] [Commented] (SPARK-27396) SPIP: Public APIs for extended Columnar Processing Support

2019-04-16 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819592#comment-16819592 ] Robert Joseph Evans commented on SPARK-27396: - This SPIP is to put a framework in place to

[jira] [Resolved] (SPARK-25348) Data source for binary files

2019-04-16 Thread Xiangrui Meng (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiangrui Meng resolved SPARK-25348. --- Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24354

[jira] [Resolved] (SPARK-27453) DataFrameWriter.partitionBy is Silently Dropped by DSV1

2019-04-16 Thread Tathagata Das (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tathagata Das resolved SPARK-27453. --- Resolution: Fixed Fix Version/s: 2.4.2 3.0.0 Issue resolved by

[jira] [Resolved] (SPARK-27452) Update zstd-jni to 1.3.8-9

2019-04-16 Thread Dongjoon Hyun (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongjoon Hyun resolved SPARK-27452. --- Resolution: Fixed Fix Version/s: 3.0.0 This is resolved via

[jira] [Resolved] (SPARK-27467) Upgrade Maven to 3.6.1

2019-04-16 Thread Dongjoon Hyun (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongjoon Hyun resolved SPARK-27467. --- Resolution: Fixed Assignee: Dongjoon Hyun Fix Version/s: 3.0.0 This is

[jira] [Resolved] (SPARK-27476) Refactoring SchemaPruning rule to remove duplicate code

2019-04-16 Thread Dongjoon Hyun (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongjoon Hyun resolved SPARK-27476. --- Resolution: Fixed Assignee: Liang-Chi Hsieh Fix Version/s: 3.0.0 This is

[jira] [Created] (SPARK-27479) Hide API docs for "org.apache.spark.util.kvstore"

2019-04-16 Thread Xiao Li (JIRA)
Xiao Li created SPARK-27479: --- Summary: Hide API docs for "org.apache.spark.util.kvstore" Key: SPARK-27479 URL: https://issues.apache.org/jira/browse/SPARK-27479 Project: Spark Issue Type:

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

2019-04-16 Thread Prabhjot Singh Bharaj (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819473#comment-16819473 ] Prabhjot Singh Bharaj commented on SPARK-27409: --- [~gsomogyi] I haven't tried it on master.

[jira] [Created] (SPARK-27478) Make HasParallelism public?

2019-04-16 Thread Nicholas Resnick (JIRA)
Nicholas Resnick created SPARK-27478: Summary: Make HasParallelism public? Key: SPARK-27478 URL: https://issues.apache.org/jira/browse/SPARK-27478 Project: Spark Issue Type: Wish

[jira] [Updated] (SPARK-27468) "Storage Level" in "RDD Storage Page" is not correct

2019-04-16 Thread Shixiong Zhu (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shixiong Zhu updated SPARK-27468: - Description: I ran the following unit test and checked the UI. {code} val conf = new

[jira] [Updated] (SPARK-27468) "Storage Level" in "RDD Storage Page" is not correct

2019-04-16 Thread Shixiong Zhu (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shixiong Zhu updated SPARK-27468: - Description: I ran the following unit test and checked the UI. {code} val conf = new

[jira] [Comment Edited] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Mitesh (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819270#comment-16819270 ] Mitesh edited comment on SPARK-11033 at 4/16/19 4:59 PM: - Thanks [~vanzin]! One

[jira] [Commented] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Marcelo Vanzin (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819274#comment-16819274 ] Marcelo Vanzin commented on SPARK-11033: It's definitely not that simple. > Launcher: add

[jira] [Commented] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Mitesh (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819270#comment-16819270 ] Mitesh commented on SPARK-11033: Thanks [~vanzin]! One quick question...is getting this working just a

[jira] [Commented] (SPARK-27468) "Storage Level" in "RDD Storage Page" is not correct

2019-04-16 Thread Gengliang Wang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819228#comment-16819228 ] Gengliang Wang commented on SPARK-27468: [~shahid] Thanks > "Storage Level" in "RDD Storage

[jira] [Created] (SPARK-27477) Kafka token provider should have provided dependency on Spark

2019-04-16 Thread koert kuipers (JIRA)
koert kuipers created SPARK-27477: - Summary: Kafka token provider should have provided dependency on Spark Key: SPARK-27477 URL: https://issues.apache.org/jira/browse/SPARK-27477 Project: Spark

[jira] [Commented] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Marcelo Vanzin (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819211#comment-16819211 ] Marcelo Vanzin commented on SPARK-11033: I just filed the bug. I have no intention of working on

[jira] [Commented] (SPARK-27396) SPIP: Public APIs for extended Columnar Processing Support

2019-04-16 Thread Kazuaki Ishizaki (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819181#comment-16819181 ] Kazuaki Ishizaki commented on SPARK-27396: -- I have one question regarding low-level API. In my

[jira] [Comment Edited] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Mitesh (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819178#comment-16819178 ] Mitesh edited comment on SPARK-11033 at 4/16/19 4:00 PM: - [~vanzin] Is there any

[jira] [Comment Edited] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Mitesh (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819178#comment-16819178 ] Mitesh edited comment on SPARK-11033 at 4/16/19 3:58 PM: - [~vanzin] Is there any

[jira] [Comment Edited] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Mitesh (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819178#comment-16819178 ] Mitesh edited comment on SPARK-11033 at 4/16/19 3:58 PM: - [~vanzin] Is there any

[jira] [Commented] (SPARK-11033) Launcher: add support for monitoring standalone/cluster apps

2019-04-16 Thread Mitesh (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819178#comment-16819178 ] Mitesh commented on SPARK-11033: [~vanzin] Is there any plan to get this working? I'm on 2.3.2 using

[jira] [Commented] (SPARK-27396) SPIP: Public APIs for extended Columnar Processing Support

2019-04-16 Thread Thomas Graves (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819153#comment-16819153 ] Thomas Graves commented on SPARK-27396: --- Since I don't hear any strong objections against the

[jira] [Commented] (SPARK-27475) dev/deps/spark-deps-hadoop-3.2 is incorrect

2019-04-16 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819130#comment-16819130 ] Sean Owen commented on SPARK-27475: --- That seems OK if it's the only way; this script is not run

[jira] [Created] (SPARK-27476) Refactoring SchemaPruning rule to remove duplicate code

2019-04-16 Thread Liang-Chi Hsieh (JIRA)
Liang-Chi Hsieh created SPARK-27476: --- Summary: Refactoring SchemaPruning rule to remove duplicate code Key: SPARK-27476 URL: https://issues.apache.org/jira/browse/SPARK-27476 Project: Spark

[jira] [Commented] (SPARK-27396) SPIP: Public APIs for extended Columnar Processing Support

2019-04-16 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819125#comment-16819125 ] Robert Joseph Evans commented on SPARK-27396: - [~bryanc], I see your point that if this is

[jira] [Commented] (SPARK-27475) dev/deps/spark-deps-hadoop-3.2 is incorrect

2019-04-16 Thread Yuming Wang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819124#comment-16819124 ] Yuming Wang commented on SPARK-27475: - [~srowen] One way to fix it is to change [this

[jira] [Created] (SPARK-27475) dev/deps/spark-deps-hadoop-3.2 is incorrect

2019-04-16 Thread Yuming Wang (JIRA)
Yuming Wang created SPARK-27475: --- Summary: dev/deps/spark-deps-hadoop-3.2 is incorrect Key: SPARK-27475 URL: https://issues.apache.org/jira/browse/SPARK-27475 Project: Spark Issue Type: Bug

[jira] [Updated] (SPARK-27475) dev/deps/spark-deps-hadoop-3.2 is incorrect

2019-04-16 Thread Yuming Wang (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuming Wang updated SPARK-27475: Description: parquet-hadoop-bundle-1.6.0.jar should be  parquet-hadoop-bundle-1.8.1.jar. (was:

[jira] [Assigned] (SPARK-27464) Add Constant instead of referring string literal used from many places

2019-04-16 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Owen reassigned SPARK-27464: - Assignee: Shivu Sondur > Add Constant instead of referring string literal used from many

[jira] [Resolved] (SPARK-27464) Add Constant instead of referring string literal used from many places

2019-04-16 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Owen resolved SPARK-27464. --- Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24368

[jira] [Resolved] (SPARK-27469) Update Commons BeanUtils to 1.9.3

2019-04-16 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Owen resolved SPARK-27469. --- Resolution: Fixed Fix Version/s: 3.0.0 Resolved by

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

2019-04-16 Thread Eyal Zituny (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eyal Zituny updated SPARK-27330: Description: in cases where a micro batch is being killed (interrupted), not during actual

[jira] [Resolved] (SPARK-27397) Take care of OpenJ9 in JVM dependant parts

2019-04-16 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Owen resolved SPARK-27397. --- Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24308

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

2019-04-16 Thread Eyal Zituny (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819054#comment-16819054 ] Eyal Zituny commented on SPARK-27330: - [~gsomogyi] i've submitted a PR > ForeachWriter is not being

[jira] [Assigned] (SPARK-27397) Take care of OpenJ9 in JVM dependant parts

2019-04-16 Thread Sean Owen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Owen reassigned SPARK-27397: - Assignee: Kazuaki Ishizaki > Take care of OpenJ9 in JVM dependant parts >

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

2019-04-16 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818963#comment-16818963 ] Gabor Somogyi commented on SPARK-27409: --- After I've modified the code the same way just like in

[jira] [Updated] (SPARK-27474) avoid retrying a task failed with CommitDeniedException many times

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan updated SPARK-27474: Summary: avoid retrying a task failed with CommitDeniedException many times (was: try best to

[jira] [Resolved] (SPARK-27470) Upgrade pyrolite to 4.23

2019-04-16 Thread Hyukjin Kwon (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hyukjin Kwon resolved SPARK-27470. -- Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24381

[jira] [Commented] (SPARK-27468) "Storage Level" in "RDD Storage Page" is not correct

2019-04-16 Thread Daniel Tomes (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818889#comment-16818889 ] Daniel Tomes commented on SPARK-27468: -- Excellent [~shahid], if you need any assistance

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

2019-04-16 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818882#comment-16818882 ] Gabor Somogyi commented on SPARK-27409: --- [~pbharaj] {quote}Yes, I'm following the kafka

[jira] [Created] (SPARK-27474) try best to not submit tasks when the partitions are already completed

2019-04-16 Thread Wenchen Fan (JIRA)
Wenchen Fan created SPARK-27474: --- Summary: try best to not submit tasks when the partitions are already completed Key: SPARK-27474 URL: https://issues.apache.org/jira/browse/SPARK-27474 Project: Spark

[jira] [Commented] (SPARK-25250) Race condition with tasks running when new attempt for same stage is created leads to other task in the next attempt running on the same partition id retry multiple ti

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818707#comment-16818707 ] Wenchen Fan commented on SPARK-25250: - good points! I'm creating another ticket for the issue, and

[jira] [Resolved] (SPARK-25250) Race condition with tasks running when new attempt for same stage is created leads to other task in the next attempt running on the same partition id retry multiple tim

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan resolved SPARK-25250. - Resolution: Fixed > Race condition with tasks running when new attempt for same stage is

[jira] [Resolved] (SPARK-27448) File source V2 table provider should be compatible with V1 provider

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan resolved SPARK-27448. - Resolution: Fixed Fix Version/s: 3.0.0 Issue resolved by pull request 24356

[jira] [Assigned] (SPARK-27448) File source V2 table provider should be compatible with V1 provider

2019-04-16 Thread Wenchen Fan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenchen Fan reassigned SPARK-27448: --- Assignee: Gengliang Wang > File source V2 table provider should be compatible with V1

[jira] [Updated] (SPARK-27465) Kafka Client 0.11.0.0 is not Supporting the kafkatestutils package

2019-04-16 Thread Praveen (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Praveen updated SPARK-27465: Description: Hi Team, We are getting the below exceptions with Kafka Client Version 0.11.0.0 for