Skip to content

Commit

Permalink
Resolved #444.
Browse files Browse the repository at this point in the history
  • Loading branch information
j3-signalroom committed Nov 11, 2024
1 parent 08527ba commit 38616b4
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 3 deletions.
1 change: 0 additions & 1 deletion linux-docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ services:
- 8081:8081
- 9092:9092
- 8443:443
- 8501:8501
command: jobmanager
environment:
- |
Expand Down
1 change: 0 additions & 1 deletion mac-docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ services:
- 8081:8081
- 9092:9092
- 8443:443
- 8501:8501
command: jobmanager
environment:
- |
Expand Down
2 changes: 1 addition & 1 deletion python/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ To access the Flink JobManager (`apache_flink-kickstarter-jobmanager-1`) contain
docker exec -it -u root -w /opt/flink/python_apps/src apache_flink-kickstarter-jobmanager-1 /bin/bash
```
Jump right into the container and take charge! You’ll have full control to run commands, explore the file system, and tackle any tasks you need. You’ll land directly in the `/opt/flink/python_apps` directory—this is the headquarters for all the Python scripts in the repo.
Jump right into the container and take charge! You’ll have full control to run commands, explore the file system, and tackle any tasks you need. You’ll land directly in the `/opt/flink/python_apps/src` directory—this is the headquarters for all the Python scripts in the repo.
Ready to launch one of those cool Java-to-Python Flink apps? Just use the [`flink run`](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/cli/) command with the correct options, and kick off the Python Flink app script with its corresponding parameters below. Adventure awaits!
Expand Down
3 changes: 3 additions & 0 deletions python/src/kickstarter/flight_importer_app.py
Original file line number Diff line number Diff line change
Expand Up @@ -133,6 +133,9 @@ def main(args):
# table
flight_table_path = ObjectPath(tbl_env.get_current_database(), "flight")

# Print the current table name
print(f"Current table: {flight_table_path.get_full_name()}")

# Check if the table exists. If not, create it
try:
if not catalog.table_exists(flight_table_path):
Expand Down

0 comments on commit 38616b4

Please sign in to comment.