streaming-jupyter-integrations

[0.15.1] - 2023-11-09

Added

• Do not inline SQL queries. Error message shows correct line and column.

[0.15.0] - 2023-11-02

Added

• Support Flink 1.18

[0.14.5] - 2023-10-03

Fixed

• Improved performance of flink_show_table_tree command by parallelism.

[0.14.4] - 2023-09-22

Fixed

• Hide pandas FutureWarnings.

[0.14.3] - 2023-09-18

Fixed

• Fix pandas DataFrame row numbers.

[0.14.2] - 2023-09-15

Added

• Search environment variables when resolving user variables.

[0.14.1] - 2023-06-28

Fixed

• Use pandas concat instead of deprecated append.

[0.14.0] - 2023-05-19

Added

• Add %flink_execute_sql_set command which allows to run multiple inserts in statement set

[0.13.5] - 2023-03-13

Fixed

• Fixed displaying results of metadata queries.

Added

• Add type parameter for %flink_show_table_tree, either tree (default) or json.

[0.13.4] - 2023-02-24

Fixed

• Fixed query interruption.

[0.13.3] - 2023-02-08

Fixed

• Fixed init order

[0.13.2] - 2023-01-23

Fixed

• Skip curly brackets with digits

[0.13.1] - 2023-01-20

Fixed

• Fixed connecting to a remote cluster when pipeline.jars property is empty.

[0.13.0] - 2023-01-17

Added

• Apache Flink 1.16

Fixed

• Jar paths in pipeline.jars property are parsed and passed when creating remote execution environment.
• fixed dependencies version in requirements.txt

[0.12.1] - 2023-01-05

Added

• Try to load flink-conf.yaml from FLINK_CONF_DIR first.

Fixed

• Fix execution of SHOW, EXPLAIN and DESCRIBE commands.
• Speed up results display.
• Do not truncate results when SHOW, EXPLAIN or DESCRIBE command is executed.

[0.12.0] - 2022-11-30

Added

• Support Java 8.
• Parallelism argument for flink_execute_sql.
• Add %flink_execute and %flink_execute_file command which allows to execute low-level Python Flink API.

Fixed

• Add a workaround for displaying TIMESTAMP_LTZ field.

[0.11.0] - 2022-11-03

Added

• Add row_kind column to the results.
• Allow specifying port in local execution target (--local-port).

Fixed

• In yarn-session execution target only RUNNING yarn applications are taken into account.

[0.10.0] - 2022-10-25

Added

• Support for execution targets: local, remote, yarn-session.

Changed

• Accept Apache Flink versions 1.15.X.

[0.9.1] - 2022-10-25

Added

• Show functions & change icon for views in %flink_show_table_tree

Fixed

• Skip curly brackets without variable

[0.9.0] - 2022-10-20

Added

• Support for batch mode

Fixed

• Add backticks to escape table/database/catalog names.
• Print error if query execution fails.
• Fix TableResult#wait() timeout parameter.
• Fix for batch queries with an empty result.