[hive] Support hive-conf-dir and hadoop-conf-dir option in hive catalog#831
Merged
JingsongLi merged 10 commits intoapache:masterfrom Apr 7, 2023
Merged
[hive] Support hive-conf-dir and hadoop-conf-dir option in hive catalog#831JingsongLi merged 10 commits intoapache:masterfrom
JingsongLi merged 10 commits intoapache:masterfrom
Conversation
JingsongLi
reviewed
Apr 4, 2023
paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java
Outdated
Show resolved
Hide resolved
JingsongLi
reviewed
Apr 4, 2023
...hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactoryOptions.java
Outdated
Show resolved
Hide resolved
...hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactoryOptions.java
Outdated
Show resolved
Hide resolved
...hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactoryOptions.java
Outdated
Show resolved
Hide resolved
added 4 commits
April 5, 2023 13:37
JingsongLi
reviewed
Apr 6, 2023
...hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactoryOptions.java
Outdated
Show resolved
Hide resolved
docs/layouts/shortcodes/generated/hive_catalog_factory_configuration.html
Show resolved
Hide resolved
paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java
Show resolved
Hide resolved
JingsongLi
reviewed
Apr 6, 2023
JingsongLi
reviewed
Apr 6, 2023
paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java
Show resolved
Hide resolved
JingsongLi
reviewed
Apr 6, 2023
paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogOptions.java
Outdated
Show resolved
Hide resolved
JingsongLi
approved these changes
Apr 7, 2023
Contributor
JingsongLi
left a comment
JingsongLi
left a comment
There was a problem hiding this comment.
+1 Thanks @Alibaba-HZY
Alibaba-HZY
pushed a commit
to Alibaba-HZY/incubator-paimon
that referenced
this pull request
Apr 11, 2023
[core] Renaming streaming-read-from to streaming-read-mode (apache#778) parent 4a56565 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681139027 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681194324 +0800 parent 4a56565 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681139027 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681194307 +0800 [core] Renaming streaming-read-from to streaming-read-mode(apache#778) [core] Renaming streaming-read-from to streaming-read-mode (apache#778) [core] generate doc (apache#778) [core] add test (apache#778) Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> [core] add test (apache#778) [core] commit (apache#778) [doc] Move Watermark and Bounded Stream to Append only table page [deploy] Publish paimon-shade to snapshot [core] Introduce SecurityContext (apache#834) [deps] Use paimon-shade dependencies (apache#838) [Document] Adds the Trino feature that create/drop table, create/drop database in the overview document (apache#835) [docs] Add document for MySqlSyncTableAction (apache#828) [doc] Document file format (apache#840) [ci] Add licensing check (apache#839) [common] Use caffeine to replace with guava cache (apache#665) [release] Added incubating name in release file (apache#845) [doc] add flink 1.17 version in Engines Overview (apache#847) [hive] Dropping table deletes table directory to avoid schema in filesystem exists (apache#772) [hive] Support hive-conf-dir and hadoop-conf-dir option in hive catalog (apache#831) [hotfix] Do not swallow InterruptedException in SnapshotManager [core][flink] Refactor BucketComputer and StreamPartitioner to gather bucketing / partitioning core logic in the same class (apache#844) [doc] Document Java API (apache#849) [README] Document mark generated-sources as Sources Root [flink][bug] MergeIntoAction and DeleteAction work abnormally with partial update merge engine (apache#829) [hotfix] Set directExecutor to caffeine Cache Resolve the problem which Sonar reported that InterruptedException need to re-throw or re-interrupt (apache#862) [hotfix] Enable StreamingReadWriteTableWithKafkaLogITCase.testReadInsertOnlyChangelogFromEnormousTimestamp (apache#854) [test] Migrate MinioTestContainer to paimon-s3 (apache#869) [flink] Assign splits evenly in StaticFileStoreSplitEnumerator (apache#856) [core] Compacted StartingScanner is incorrect (apache#857) [core] revert flink.md(apache#778) [core] change dose to does (apache#778)
Alibaba-HZY
pushed a commit
to Alibaba-HZY/incubator-paimon
that referenced
this pull request
Apr 11, 2023
[core] Add streaming read mode from option (apache#778) [core] Renaming streaming-read-from to streaming-read-mode (apache#778) parent 4a56565 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681139027 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681194324 +0800 parent 4a56565 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681139027 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681194307 +0800 [core] Renaming streaming-read-from to streaming-read-mode(apache#778) [core] Renaming streaming-read-from to streaming-read-mode (apache#778) [core] generate doc (apache#778) [core] add test (apache#778) Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> [core] add test (apache#778) [core] commit (apache#778) [doc] Move Watermark and Bounded Stream to Append only table page [deploy] Publish paimon-shade to snapshot [core] Introduce SecurityContext (apache#834) [deps] Use paimon-shade dependencies (apache#838) [Document] Adds the Trino feature that create/drop table, create/drop database in the overview document (apache#835) [docs] Add document for MySqlSyncTableAction (apache#828) [doc] Document file format (apache#840) [ci] Add licensing check (apache#839) [common] Use caffeine to replace with guava cache (apache#665) [release] Added incubating name in release file (apache#845) [doc] add flink 1.17 version in Engines Overview (apache#847) [hive] Dropping table deletes table directory to avoid schema in filesystem exists (apache#772) [hive] Support hive-conf-dir and hadoop-conf-dir option in hive catalog (apache#831) [hotfix] Do not swallow InterruptedException in SnapshotManager [core][flink] Refactor BucketComputer and StreamPartitioner to gather bucketing / partitioning core logic in the same class (apache#844) [doc] Document Java API (apache#849) [README] Document mark generated-sources as Sources Root [flink][bug] MergeIntoAction and DeleteAction work abnormally with partial update merge engine (apache#829) [hotfix] Set directExecutor to caffeine Cache Resolve the problem which Sonar reported that InterruptedException need to re-throw or re-interrupt (apache#862) [hotfix] Enable StreamingReadWriteTableWithKafkaLogITCase.testReadInsertOnlyChangelogFromEnormousTimestamp (apache#854) [test] Migrate MinioTestContainer to paimon-s3 (apache#869) [flink] Assign splits evenly in StaticFileStoreSplitEnumerator (apache#856) [core] Compacted StartingScanner is incorrect (apache#857) [core] revert flink.md(apache#778) [core] change dose to does (apache#778) parent 2a62022 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681226598 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681226783 +0800 parent 2a62022 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681226598 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681226730 +0800 parent 2a62022 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681226598 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681226598 +0800 [core] Add streaming read from option (apache#778) [core] add test (apache#778) Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-core/src/main/java/org/apache/paimon/CoreOptions.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> Update paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java Co-authored-by: Nicholas Jiang <programgeek@163.com> [core] add test (apache#778) merger sdda 这是一个 3 个提交的组合。 [core] commit1 (apache#778) [core] commit2 (apache#778) [core] commit3 (apache#778) [core] do commit 1(apache#778) [core] do commit 2(apache#778) sdda 这是一个 3 个提交的组合。 [core] commit1 (apache#778) [core] commit2 (apache#778) [core] commit3 (apache#778) [core] Add streaming read mode option (apache#778) parent 3acede2 author Alibaba-HZY <daowu.hzy@cainiao.com> 1681226824 +0800 committer Alibaba-HZY <daowu.hzy@cainiao.com> 1681226824 +0800 [core] Add streaming read from option (apache#778) [core] revert flink.md (apache#778) Delete AbstractChannelComputer.java delete
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Purpose
User can configure hive-site.xml files for kerberos login. #823
Tests
HiveCatalogITCaseBase
Hive23CatalogITCase
Hive31CatalogITCase