This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 88d0ee0 [FLINK-18545][table] Specify job name by `pipeline.name` for
sql job
add fad84798 [FLINK-20241][hive] Improve exception message when hive deps
are missing on JM/TM
No new revisions were added by this update.
Summary of changes:
...stemFactory.java => CachedSerializedValue.java} | 29 +--
.../flink/connectors/hive/HiveTablePartition.java | 17 +-
.../flink/connectors/hive/JobConfWrapper.java | 27 ++-
.../hive/read/HiveCompactReaderFactory.java | 16 +-
.../connectors/hive/read/HiveTableInputFormat.java | 98 ++-------
.../hive/read/TimestampedHiveInputSplit.java | 237 ---------------------
.../connectors/hive/write/HiveWriterFactory.java | 12 +-
.../hive/HiveDeserializeExceptionTest.java | 110 ++++++++++
8 files changed, 199 insertions(+), 347 deletions(-)
copy
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{HadoopFileSystemFactory.java
=> CachedSerializedValue.java} (58%)
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDeserializeExceptionTest.java
