Skip to content

[hotfix] [doc] [action] Adding line breaks to action and fix document for migration #5071

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
JingsongLi merged 3 commits into from
Feb 20, 2025
Merged

[hotfix] [doc] [action] Adding line breaks to action and fix document for migration #5071

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
7dd02bb
[hotfix] [action] Adding line breaks to migrate_iceberg_table action …
yangjf2019 Feb 13, 2025
0afac91
fix
yangjf2019 Feb 13, 2025
073776e
adding line breaks to clear_consumers action
yangjf2019 Feb 14, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 6 additions & 5 deletions docs/content/migration/migration-from-hive.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ If your flink version is below 1.17, you can use flink action to achieve this:
```bash
<FLINK_HOME>/bin/flink run \
/path/to/paimon-flink-action-{{< version >}}.jar \
migrate_table
migrate_table \
--warehouse <warehouse-path> \
--source_type hive \
--table <database.table-name> \
Expand All @@ -84,12 +84,13 @@ migrate_table

Example:
```bash
<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar migrate_table \
<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar \
migrate_table \
--warehouse /path/to/warehouse \
--catalog_conf uri=thrift://localhost:9083 \
--catalog_conf metastore=hive \
--source_type hive \
--table default.hive_or_paimon \
--table default.hive_or_paimon
```

**Migrate Hive Database**
Expand Down Expand Up @@ -123,7 +124,7 @@ If your flink version is below 1.17, you can use flink action to achieve this:
```bash
<FLINK_HOME>/bin/flink run \
/path/to/paimon-flink-action-{{< version >}}.jar \
migrate_databse
migrate_databse \
--warehouse <warehouse-path> \
--source_type hive \
--database <database> \
Expand All @@ -138,7 +139,7 @@ Example:
--catalog_conf uri=thrift://localhost:9083 \
--catalog_conf metastore=hive \
--source_type hive \
--database default \
--database default
```

**Migrate Hive File**
Expand Down
7 changes: 5 additions & 2 deletions ...flink-common/src/main/java/org/apache/paimon/flink/action/ClearConsumerActionFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,8 +60,11 @@ public void printHelp() {

System.out.println("Syntax:");
System.out.println(
" clear_consumers --warehouse <warehouse_path> --database <database_name> "
+ "--table <table_name> [--including_consumers <including_pattern> --excluding_consumers <excluding_pattern>]");
" clear_consumers \\\n"
+ "--warehouse <warehouse_path> \\\n"
+ "--database <database_name> \\\n"
+ "--table <table_name> \\\n"
+ "[--including_consumers <including_pattern> --excluding_consumers <excluding_pattern>]");

System.out.println();
System.out.println("Note:");
Expand Down
8 changes: 4 additions & 4 deletions ...common/src/main/java/org/apache/paimon/flink/action/MigrateIcebergTableActionFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,10 +61,10 @@ public void printHelp() {

System.out.println("Syntax:");
System.out.println(
" migrate_iceberg_table"
+ "--table <database.table_name> "
+ "--iceberg_options <key>=<value>[,<key>=<value>,...]"
+ "[--catalog_conf <key>=<value] "
" migrate_iceberg_table \\\n"
+ "--table <database.table_name> \\\n"
+ "--iceberg_options <key>=<value>[,<key>=<value>,...] \\\n"
+ "[--catalog_conf <key>=<value] \\\n"
+ "[--options <key>=<value>,<key>=<value>,...]");
}
}
Loading