clear query| facets| time Search criteria: .   Results from 1 to 10 from 100 (0.0s).
Loading phrases to help you
refine your search...
[SPARK-29438] Failed to get state store in stream-stream join - Spark - [issue]
...Now, Spark use the `TaskPartitionId` to determine the StateStore path.TaskPartitionId   \ StateStoreVersion  --> StoreProviderId -> StateStoreStateStoreName    / &n...    Author: Genmao Yu , 2020-02-13, 06:40
[SPARK-29543] Support Structured Streaming UI - Spark - [issue]
...Open this jira to support structured streaming UI...    Author: Genmao Yu , 2020-02-03, 07:47
[SPARK-29683] Job failed due to executor failures all available nodes are blacklisted - Spark - [issue]
...My streaming job will fail due to executor failures all available nodes are blacklisted. This exception is thrown only when all node is blacklisted:def isAllNodeBlacklisted: Boolean = curren...    Author: Genmao Yu , 2020-01-21, 17:16
[SPARK-27355] make query execution more sensitive to epoch message late or lost - Spark - [issue]
...In SPARK-23503, we enforce sequencing of committed epochs for Continuous Execution. In case a message for epoch n is lost and epoch (n + 1) is ready for commit before epoch n is, epoch (n + ...    Author: Genmao Yu , 2020-01-01, 00:05
[SPARK-27413] Keep the same epoch pace between driver and executor. - Spark - [issue]
...The pace of epoch generation in driver and epoch pulling in executor is different. It will result in many empty epochs for partition if the epoch pulling interval is larger than epoch genera...    Author: Genmao Yu , 2020-01-01, 00:05
[SPARK-27717] support UNION in continuous processing - Spark - [issue]    Author: Genmao Yu , 2019-12-30, 00:06
[SPARK-28256] Failed to initialize FileContextBasedCheckpointFileManager with uri without authority - Spark - [issue]
...reproduce codeCREATE TABLE `user_click_count` (`userId` STRING, `click` BIGINT)USING org.apache.spark.sql.jsonOPTIONS (path 'hdfs:///tmp/test');error:java.lang.RuntimeException:    Author: Genmao Yu , 2019-12-28, 00:07
[SPARK-29973] Use nano time to calculate 'processedRowsPerSecond' to avoid 'NaN'/'Infinity' - Spark - [issue]
...The "processingTimeSec" of batch may be less than 1 millis.  As "processingTimeSec" is calculated in millis, so "processingTimeSec" equals 0L. If there is no data in this batch, the "process...    Author: Genmao Yu , 2019-11-25, 01:52
[SPARK-28158] Hive UDFs supports UDT type - Spark - [issue]    Author: Genmao Yu , 2019-10-30, 07:47
[SPARK-27715] SQL query details in UI dose not show in correct format. - Spark - [issue]    Author: Genmao Yu , 2019-09-27, 04:07