AmplabJenkins removed a comment on issue #26772: [WIP][SPARK-28210][CORE]
Introducing Shuffle Reader API
URL: https://github.com/apache/spark/pull/26772#issuecomment-562396887
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.be
SparkQA commented on issue #26772: [WIP][SPARK-28210][CORE] Introducing Shuffle
Reader API
URL: https://github.com/apache/spark/pull/26772#issuecomment-562396954
**[Test build #114922 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114922/testReport)**
for
beliefer commented on a change in pull request #25001: [SPARK-28083][SQL]
Support LIKE ... ESCAPE syntax
URL: https://github.com/apache/spark/pull/25001#discussion_r35465
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/regexpExpressions.scala
SparkQA commented on issue #26772: [WIP][SPARK-28210][CORE] Introducing Shuffle
Reader API
URL: https://github.com/apache/spark/pull/26772#issuecomment-562396551
**[Test build #114922 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114922/testReport)**
for
ifilonenko opened a new pull request #26772: [WIP][SPARK-28210][CORE]
Introducing Shuffle Reader API
URL: https://github.com/apache/spark/pull/26772
WIP (still requires unit tests to pass)
### What changes were proposed in this pull request?
Extending the ExecutorComponents to inc
AmplabJenkins removed a comment on issue #26752: [SPARK-30112][SQL] Allow
insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562393395
Test PASSed.
Refer to this link for build results (access rights to CI server
AmplabJenkins removed a comment on issue #26752: [SPARK-30112][SQL] Allow
insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562393388
Merged build finished. Test PASSed.
AmplabJenkins commented on issue #26752: [SPARK-30112][SQL] Allow insert
overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562393388
Merged build finished. Test PASSed.
AmplabJenkins commented on issue #26752: [SPARK-30112][SQL] Allow insert
overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562393395
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
SparkQA commented on issue #26752: [SPARK-30112][SQL] Allow insert overwrite
same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562393076
**[Test build #114921 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequest
rdblue commented on a change in pull request #26684: [SPARK-30001][SQL]
ResolveRelations should handle both V1 and V2 tables.
URL: https://github.com/apache/spark/pull/26684#discussion_r354627788
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analy
bersprockets commented on a change in pull request #26016: [SPARK-24914][SQL]
New statistic to improve data size estimate for columnar storage formats
URL: https://github.com/apache/spark/pull/26016#discussion_r354627478
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sq
imback82 commented on a change in pull request #26684: [SPARK-30001][SQL]
ResolveRelations should handle both V1 and V2 tables.
URL: https://github.com/apache/spark/pull/26684#discussion_r354626929
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Ana
bersprockets commented on a change in pull request #26016: [SPARK-24914][SQL]
New statistic to improve data size estimate for columnar storage formats
URL: https://github.com/apache/spark/pull/26016#discussion_r354623854
##
File path:
sql/core/src/main/scala/org/apache/spark/sql/ex
viirya commented on a change in pull request #26752: [SPARK-30112][SQL] Allow
insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#discussion_r354624788
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/sources/In
rdblue commented on a change in pull request #26684: [SPARK-30001][SQL]
ResolveRelations should handle both V1 and V2 tables.
URL: https://github.com/apache/spark/pull/26684#discussion_r354624656
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analy
vanzin commented on a change in pull request #26416: [SPARK-29779][CORE]
Compact old event log files and cleanup
URL: https://github.com/apache/spark/pull/26416#discussion_r354621867
##
File path:
core/src/main/scala/org/apache/spark/deploy/history/EventFilter.scala
##
@@
vanzin commented on a change in pull request #26416: [SPARK-29779][CORE]
Compact old event log files and cleanup
URL: https://github.com/apache/spark/pull/26416#discussion_r354622853
##
File path:
core/src/main/scala/org/apache/spark/deploy/history/EventLogFilterRateCalculator.scal
vanzin commented on a change in pull request #26416: [SPARK-29779][CORE]
Compact old event log files and cleanup
URL: https://github.com/apache/spark/pull/26416#discussion_r354622258
##
File path:
core/src/main/scala/org/apache/spark/deploy/history/EventFilter.scala
##
@@
vanzin commented on a change in pull request #26416: [SPARK-29779][CORE]
Compact old event log files and cleanup
URL: https://github.com/apache/spark/pull/26416#discussion_r354619053
##
File path:
core/src/main/scala/org/apache/spark/deploy/history/EventFilter.scala
##
@@
vanzin commented on a change in pull request #26416: [SPARK-29779][CORE]
Compact old event log files and cleanup
URL: https://github.com/apache/spark/pull/26416#discussion_r354622717
##
File path:
core/src/main/scala/org/apache/spark/deploy/history/EventLogFileCompactor.scala
dongjoon-hyun commented on a change in pull request #26752: [SPARK-30112][SQL]
Allow insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#discussion_r354624321
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/sou
imback82 commented on a change in pull request #26684: [SPARK-30001][SQL]
ResolveRelations should handle both V1 and V2 tables.
URL: https://github.com/apache/spark/pull/26684#discussion_r354623705
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Ana
srowen commented on issue #26722: [SPARK-24666][ML] Fix infinity vectors
produced by Word2Vec when numIterations are large
URL: https://github.com/apache/spark/pull/26722#issuecomment-562385030
I'm OK with putting it in 2.4, I think. It's a minor behavior change, but,
also appears to be mo
dongjoon-hyun commented on a change in pull request #26752: [SPARK-30112][SQL]
Allow insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#discussion_r354621458
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/sou
viirya commented on a change in pull request #26752: [SPARK-30112][SQL] Allow
insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#discussion_r354621480
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/sources/In
dongjoon-hyun commented on a change in pull request #26752: [SPARK-30112][SQL]
Allow insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#discussion_r354621289
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/sou
dongjoon-hyun commented on a change in pull request #26752: [SPARK-30112][SQL]
Allow insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#discussion_r354621366
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/sou
AmplabJenkins commented on issue #26752: [SPARK-30112][SQL] Allow insert
overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562384370
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
AmplabJenkins removed a comment on issue #26752: [SPARK-30112][SQL] Allow
insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562384364
Merged build finished. Test PASSed.
AmplabJenkins removed a comment on issue #26752: [SPARK-30112][SQL] Allow
insert overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562384370
Test PASSed.
Refer to this link for build results (access rights to CI server
AmplabJenkins commented on issue #26752: [SPARK-30112][SQL] Allow insert
overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562384364
Merged build finished. Test PASSed.
SparkQA commented on issue #26752: [SPARK-30112][SQL] Allow insert overwrite
same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562384008
**[Test build #114920 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequest
dongjoon-hyun commented on issue #26752: [SPARK-30112][SQL] Allow insert
overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562383812
Thank you for making a PR for this issue.
--
dongjoon-hyun commented on issue #26752: [SPARK-30112][SQL] Allow insert
overwrite same table if using dynamic partition overwrite
URL: https://github.com/apache/spark/pull/26752#issuecomment-562383398
Retest this please.
Thi
AmplabJenkins removed a comment on issue #26740: [SPARK-30053][SQL] Add the
ability for v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382628
Test FAILed.
Refer to this link for build results (access rights to CI serv
AmplabJenkins removed a comment on issue #26740: [SPARK-30053][SQL] Add the
ability for v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382554
Merged build finished. Test PASSed.
-
AmplabJenkins commented on issue #26740: [SPARK-30053][SQL] Add the ability for
v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382628
Test FAILed.
Refer to this link for build results (access rights to CI server neede
AmplabJenkins removed a comment on issue #26740: [SPARK-30053][SQL] Add the
ability for v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382623
Merged build finished. Test FAILed.
-
SparkQA removed a comment on issue #26740: [SPARK-30053][SQL] Add the ability
for v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382260
**[Test build #114919 has
started](https://amplab.cs.berkeley.edu/jenkins/job/Spark
AmplabJenkins commented on issue #26740: [SPARK-30053][SQL] Add the ability for
v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382623
Merged build finished. Test FAILed.
-
SparkQA commented on issue #26740: [SPARK-30053][SQL] Add the ability for v2
datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382617
**[Test build #114919 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullReq
AmplabJenkins removed a comment on issue #26740: [SPARK-30053][SQL] Add the
ability for v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382561
Test PASSed.
Refer to this link for build results (access rights to CI serv
AmplabJenkins commented on issue #26740: [SPARK-30053][SQL] Add the ability for
v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382554
Merged build finished. Test PASSed.
-
AmplabJenkins commented on issue #26740: [SPARK-30053][SQL] Add the ability for
v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382561
Test PASSed.
Refer to this link for build results (access rights to CI server neede
SparkQA commented on issue #26740: [SPARK-30053][SQL] Add the ability for v2
datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562382260
**[Test build #114919 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequ
AmplabJenkins removed a comment on issue #26740: [SPARK-30053][SQL] Add the
ability for v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-560554339
Can one of the admins verify this patch?
dongjoon-hyun commented on issue #26740: [SPARK-30053][SQL] Add the ability for
v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562381786
Thank you for contribution, @AndrewKL .
Please run `./dev/lint-scala` and fix the s
dongjoon-hyun commented on issue #26740: [SPARK-30053][SQL] Add the ability for
v2 datasource so specify a vacuum action on the table
URL: https://github.com/apache/spark/pull/26740#issuecomment-562381599
ok to test
This is a
dongjoon-hyun commented on issue #26493: [SPARK-29574][K8S] Add
SPARK_DIST_CLASSPATH to the executor class path
URL: https://github.com/apache/spark/pull/26493#issuecomment-562380703
Gentle ping, @sshakeri .
This is an automa
viirya commented on issue #26722: [SPARK-24666][ML] Fix infinity vectors
produced by Word2Vec when numIterations are large
URL: https://github.com/apache/spark/pull/26722#issuecomment-562380369
Thanks! Merging to master and 2.4.
-
viirya closed pull request #26722: [SPARK-24666][ML] Fix infinity vectors
produced by Word2Vec when numIterations are large
URL: https://github.com/apache/spark/pull/26722
This is an automated message from the Apache Git Ser
dongjoon-hyun commented on issue #23059: [SPARK-26091][SQL] Upgrade to 2.3.4
for Hive Metastore Client 2.3
URL: https://github.com/apache/spark/pull/23059#issuecomment-562377726
Since SPARK-26091 was an improvement issue, we didn't backport this.
Is there any problem with Apache Spark 2.
AmplabJenkins removed a comment on issue #26770:
[SPARK-30142][BUILD][test-maven] Upgrade Maven to 3.6.3
URL: https://github.com/apache/spark/pull/26770#issuecomment-562376882
Merged build finished. Test PASSed.
This is an au
AmplabJenkins removed a comment on issue #26770:
[SPARK-30142][BUILD][test-maven] Upgrade Maven to 3.6.3
URL: https://github.com/apache/spark/pull/26770#issuecomment-562376889
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.ber
AmplabJenkins commented on issue #26770: [SPARK-30142][BUILD][test-maven]
Upgrade Maven to 3.6.3
URL: https://github.com/apache/spark/pull/26770#issuecomment-562376889
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.ed
AmplabJenkins commented on issue #26770: [SPARK-30142][BUILD][test-maven]
Upgrade Maven to 3.6.3
URL: https://github.com/apache/spark/pull/26770#issuecomment-562376882
Merged build finished. Test PASSed.
This is an automated
SparkQA removed a comment on issue #26770: [SPARK-30142][BUILD][test-maven]
Upgrade Maven to 3.6.3
URL: https://github.com/apache/spark/pull/26770#issuecomment-562243238
**[Test build #114915 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114915/testReport)
SparkQA commented on issue #26770: [SPARK-30142][BUILD][test-maven] Upgrade
Maven to 3.6.3
URL: https://github.com/apache/spark/pull/26770#issuecomment-562376435
**[Test build #114915 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114915/testReport)**
for
yuchenhuo commented on issue #26614: [SPARK-29976][CORE] Trigger speculation
for stages with too few tasks
URL: https://github.com/apache/spark/pull/26614#issuecomment-562374386
@tgravescs @jiangxb1987 Thanks for the feedbacks! I've updated the PR
corresponding to the discussion. May I get
viirya commented on issue #26722: [SPARK-24666][ML] Fix infinity vectors
produced by Word2Vec when numIterations are large
URL: https://github.com/apache/spark/pull/26722#issuecomment-562371645
Ok. I tried to increase number of partitions and iterations of existing
test, but can not reprod
vanzin commented on issue #23820: [SPARK-22860][CORE][YARN] Redact command line
arguments for running Driver and Executor before logging (standalone and YARN)
URL: https://github.com/apache/spark/pull/23820#issuecomment-562370025
Feel free to open a PR.
viirya edited a comment on issue #26722: [SPARK-24666][ML] Fix infinity vectors
produced by Word2Vec when numIterations are large
URL: https://github.com/apache/spark/pull/26722#issuecomment-562363790
Let me check if it is also reproducible with big partition number +
iteration on existing
AmplabJenkins commented on issue #25514: [SPARK-28784][SS] Use
CheckpointFileManager in StreamExecution/StreamingQueryManager for checkpoint
dirs
URL: https://github.com/apache/spark/pull/25514#issuecomment-562368721
Merged build finished. Test PASSed.
AmplabJenkins removed a comment on issue #25514: [SPARK-28784][SS] Use
CheckpointFileManager in StreamExecution/StreamingQueryManager for checkpoint
dirs
URL: https://github.com/apache/spark/pull/25514#issuecomment-562368726
Test PASSed.
Refer to this link for build results (access righ
AmplabJenkins removed a comment on issue #25514: [SPARK-28784][SS] Use
CheckpointFileManager in StreamExecution/StreamingQueryManager for checkpoint
dirs
URL: https://github.com/apache/spark/pull/25514#issuecomment-562368721
Merged build finished. Test PASSed.
AmplabJenkins commented on issue #25514: [SPARK-28784][SS] Use
CheckpointFileManager in StreamExecution/StreamingQueryManager for checkpoint
dirs
URL: https://github.com/apache/spark/pull/25514#issuecomment-562368726
Test PASSed.
Refer to this link for build results (access rights to CI
tooptoop4 commented on issue #23059: [SPARK-26091][SQL] Upgrade to 2.3.4 for
Hive Metastore Client 2.3
URL: https://github.com/apache/spark/pull/23059#issuecomment-562368501
can this go in spark 2.4.5?
This is an automated me
SparkQA commented on issue #25514: [SPARK-28784][SS] Use CheckpointFileManager
in StreamExecution/StreamingQueryManager for checkpoint dirs
URL: https://github.com/apache/spark/pull/25514#issuecomment-562368329
**[Test build #114916 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/
SparkQA removed a comment on issue #25514: [SPARK-28784][SS] Use
CheckpointFileManager in StreamExecution/StreamingQueryManager for checkpoint
dirs
URL: https://github.com/apache/spark/pull/25514#issuecomment-562290562
**[Test build #114916 has
started](https://amplab.cs.berkeley.edu/jenk
tooptoop4 commented on issue #23820: [SPARK-22860][CORE][YARN] Redact command
line arguments for running Driver and Executor before logging (standalone and
YARN)
URL: https://github.com/apache/spark/pull/23820#issuecomment-562366993
@vanzin can this go in 2.4.5?
--
viirya commented on issue #26722: [SPARK-24666][ML] Fix infinity vectors
produced by Word2Vec when numIterations are large
URL: https://github.com/apache/spark/pull/26722#issuecomment-562363790
Let me check if it is also reproducible with big partition number +
iteration on existing mllib
maropu commented on a change in pull request #26656: [SPARK-27986][SQL] Support
ANSI SQL filter clause for aggregate expression
URL: https://github.com/apache/spark/pull/26656#discussion_r354595927
##
File path:
sql/core/src/test/resources/sql-tests/inputs/postgreSQL/window_part3.s
mukulmurthy commented on a change in pull request #26771: [SPARK-30143][SS] Add
a timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#discussion_r354588985
##
File path:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecuti
mukulmurthy commented on a change in pull request #26771: [SPARK-30143][SS] Add
a timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#discussion_r354587841
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
#
mukulmurthy commented on a change in pull request #26771: [SPARK-30143][SS] Add
a timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#discussion_r354591734
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/MicroBatchExe
dongjoon-hyun commented on a change in pull request #26769: [SPARK-30011][SQL]
Inline 2.12 "AsIfIntegral" classes, not present in 2.13
URL: https://github.com/apache/spark/pull/26769#discussion_r35458
##
File path: sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.s
dongjoon-hyun commented on a change in pull request #26769: [SPARK-30011][SQL]
Inline 2.12 "AsIfIntegral" classes, not present in 2.13
URL: https://github.com/apache/spark/pull/26769#discussion_r35458
##
File path: sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.s
AmplabJenkins removed a comment on issue #26771: [SPARK-30143][SS] Add a
timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350881
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.
SparkQA removed a comment on issue #26771: [SPARK-30143][SS] Add a timeout on
stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350455
**[Test build #114917 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114917/testR
AmplabJenkins removed a comment on issue #26771: [SPARK-30143][SS] Add a
timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350968
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab
AmplabJenkins removed a comment on issue #26771: [SPARK-30143][SS] Add a
timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350957
Merged build finished. Test PASSed.
This is
AmplabJenkins removed a comment on issue #26771: [SPARK-30143][SS] Add a
timeout on stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350873
Merged build finished. Test FAILed.
This is
AmplabJenkins commented on issue #26771: [SPARK-30143][SS] Add a timeout on
stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350873
Merged build finished. Test FAILed.
This is an auto
AmplabJenkins commented on issue #26771: [SPARK-30143][SS] Add a timeout on
stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350968
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berk
AmplabJenkins commented on issue #26771: [SPARK-30143][SS] Add a timeout on
stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350881
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berke
AmplabJenkins commented on issue #26771: [SPARK-30143][SS] Add a timeout on
stopping a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350957
Merged build finished. Test PASSed.
This is an auto
SparkQA commented on issue #26771: [SPARK-30143][SS] Add a timeout on stopping
a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350861
**[Test build #114917 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114917/testReport)*
SparkQA commented on issue #26771: [SPARK-30143][SS] Add a timeout on stopping
a streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562350455
**[Test build #114917 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/114917/testReport)**
SparkQA commented on issue #26590: [SPARK-29953][SS] Don't clean up source
files for FileStreamSource if the files belong to the output of FileStreamSink
URL: https://github.com/apache/spark/pull/26590#issuecomment-562350454
**[Test build #114918 has
started](https://amplab.cs.berkeley.edu
HeartSaVioR commented on issue #26590: [SPARK-29953][SS] Don't clean up source
files for FileStreamSource if the files belong to the output of FileStreamSink
URL: https://github.com/apache/spark/pull/26590#issuecomment-562350043
retest this, please
-
brkyvz commented on issue #26771: [SPARK-30143][SS] Add a timeout on stopping a
streaming query
URL: https://github.com/apache/spark/pull/26771#issuecomment-562349837
cc @zsxwing @tdas
This is an automated message from the A
brkyvz opened a new pull request #26771: [SPARK-30143][SS] Add a timeout on
stopping a streaming query
URL: https://github.com/apache/spark/pull/26771
### What changes were proposed in this pull request?
Add a timeout configuration for StreamingQuery.stop()
### Why are the cha
squito commented on issue #26633: [SPARK-29994][CORE] Add WILDCARD task location
URL: https://github.com/apache/spark/pull/26633#issuecomment-562346943
are you sure that in your case the slowdown is even caused by SPARK-18886?
Even when that is solved, you could still get end up with *one*
zsxwing commented on issue #26590: [SPARK-29953][SS] Don't clean up source
files for FileStreamSource if the files belong to the output of FileStreamSink
URL: https://github.com/apache/spark/pull/26590#issuecomment-562346871
LGTM.
retest this please. Triggering another test since the
srowen commented on a change in pull request #26769: [SPARK-30011][SQL] Inline
2.12 "AsIfIntegral" classes, not present in 2.13
URL: https://github.com/apache/spark/pull/26769#discussion_r354579360
##
File path: sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala
#
dongjoon-hyun commented on a change in pull request #26769: [SPARK-30011][SQL]
Inline 2.12 "AsIfIntegral" classes, not present in 2.13
URL: https://github.com/apache/spark/pull/26769#discussion_r354578040
##
File path: sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.s
dongjoon-hyun commented on a change in pull request #26769: [SPARK-30011][SQL]
Inline 2.12 "AsIfIntegral" classes, not present in 2.13
URL: https://github.com/apache/spark/pull/26769#discussion_r354578268
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/types/DoubleTy
ueshin commented on a change in pull request #26512: [WIP][SPARK-29493][SQL]
Arrow MapType support
URL: https://github.com/apache/spark/pull/26512#discussion_r354558089
##
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala
##
@@ -88,6 +90,16
ueshin commented on a change in pull request #26512: [WIP][SPARK-29493][SQL]
Arrow MapType support
URL: https://github.com/apache/spark/pull/26512#discussion_r354564602
##
File path:
sql/core/src/test/scala/org/apache/spark/sql/execution/arrow/ArrowWriterSuite.scala
##
@@
201 - 300 of 655 matches
Mail list logo