You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hive.apache.org by Ashutosh Chauhan <ha...@apache.org> on 2020/05/27 07:41:08 UTC
Review Request 72544: Remove hcatalog streaming
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/72544/
-----------------------------------------------------------
Review request for hive and prasanthj.
Bugs: HIVE-19926
https://issues.apache.org/jira/browse/HIVE-19926
Repository: hive-git
Description
-------
Remove hcatalog streaming
Diffs
-----
hcatalog/pom.xml c1506d8dc2
hcatalog/streaming/pom.xml fef5bf75ab
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/AbstractRecordWriter.java bc99b6c824
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/ConnectionError.java 897b82634b
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/DelimitedInputWriter.java 85c3429329
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HeartBeatFailure.java 5d9b763c84
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java dc8c6636bc
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/ImpersonationFailed.java 7932077595
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/InvalidColumn.java a7af608d76
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/InvalidPartition.java 82b6db8ddd
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/InvalidTable.java 9772c5c7bd
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/InvalidTrasactionState.java 921d4dac9e
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/PartitionCreationFailed.java 1913d33542
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/QueryFailedException.java f78be7f7ff
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/RecordWriter.java 0f3c0bcfea
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/SerializationError.java 33d2ceffe7
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/StreamingConnection.java 3af9aed36b
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/StreamingException.java 421eaf079e
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/StreamingIOFailure.java 247424f185
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/StrictJsonWriter.java d588f71a5c
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/StrictRegexWriter.java 28406d38e8
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/TransactionBatch.java 96aae02170
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/TransactionBatchUnAvailable.java ae3587edc9
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/TransactionError.java d438447b18
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/HiveConfFactory.java ebe032d705
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/UgiMetaStoreClientFactory.java 615fc1a751
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/AcidTable.java 40de497b08
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/AcidTableSerializer.java 43ac527e79
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/ClientException.java 206a0ba54e
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/ConnectionException.java 2b3b299f54
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/MutatorClient.java 11664f6a7d
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/MutatorClientBuilder.java 1575d8d4a4
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/TableType.java 02c9e69605
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/Transaction.java e1c6735d6d
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/TransactionException.java 21cffa12a9
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/lock/HeartbeatFactory.java ba0fa1e149
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/lock/HeartbeatTimerTask.java 81f99de390
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/lock/Lock.java 88970da3a5
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/lock/LockException.java bce232a883
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/client/lock/LockFailureListener.java a3845ea784
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/doc-files/system-overview.dot c5a8dbdf1c
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/package.html 7bc75c0ee0
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/BucketIdException.java 040fce3ec7
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/BucketIdResolver.java 3432baaca4
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/BucketIdResolverImpl.java 1d51d8570c
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/GroupRevisitedException.java ffa8c3e552
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/GroupingValidator.java f28b8ffe60
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/MetaStorePartitionHelper.java fb88f2d081
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/Mutator.java e6f968eff5
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/MutatorCoordinator.java a90d5d3187
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/MutatorCoordinatorBuilder.java 698ba7cb35
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/MutatorFactory.java d3d3210ad4
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/MutatorImpl.java 1e0cb727ec
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/OperationType.java 3dc2886b5a
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/PartitionCreationException.java ed0c9890b5
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/PartitionHelper.java d064b0c701
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/RecordInspector.java 5d1f17513b
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/RecordInspectorImpl.java 37329c33c7
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/RecordSequenceException.java 0d3b471488
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/SequenceValidator.java 320b987b84
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/WarehousePartitionHelper.java ace329ab04
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/WorkerException.java 9eb67427d6
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/package.html a879b974ae
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/StreamingIntegrationTester.java af252aa0ab
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/TestDelimitedInputWriter.java 32eead4e0a
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/TestStreaming.java 569de706df
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/ExampleUseCase.java d38950e5fd
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/MutableRecord.java 365d20c80f
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/ReflectiveMutatorFactory.java c05ddcf983
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/StreamingAssert.java 86f762e97c
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/StreamingTestUtils.java afda7d5c71
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/TestMutations.java 3d008e67ed
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/client/TestAcidTableSerializer.java 1523a10bdb
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/client/TestMutatorClient.java 4222786d80
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/client/TestTransaction.java 4d30c253c6
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/client/lock/TestHeartbeatTimerTask.java 33e29cf924
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/client/lock/TestLock.java 156a37ebc7
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestBucketIdResolverImpl.java e890c52d6d
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestGroupingValidator.java 1d171c401e
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestMetaStorePartitionHelper.java 4a7d358698
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestMutatorCoordinator.java 297e67c40d
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestMutatorImpl.java 5219532d3e
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestRecordInspectorImpl.java 55da312a5a
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestSequenceValidator.java 2b3f79fcc0
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/mutate/worker/TestWarehousePartitionHelper.java 1011d34a61
hcatalog/streaming/src/test/sit 38cc3525e6
itests/hive-unit/pom.xml 026c465655
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorTestUtil.java e70d8783bc
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/TestCompactor.java 32fe535b2b
packaging/pom.xml 97c8cf7168
packaging/src/main/assembly/bin.xml 6bb4881ed2
Diff: https://reviews.apache.org/r/72544/diff/1/
Testing
-------
Thanks,
Ashutosh Chauhan