0.15.1 - 2023-11-09
- Do not inline SQL queries. Error message shows correct line and column.
0.15.0 - 2023-11-02
- Support Flink 1.18
0.14.5 - 2023-10-03
- Improved performance of flink_show_table_tree command by parallelism.
0.14.4 - 2023-09-22
- Hide pandas FutureWarnings.
0.14.3 - 2023-09-18
- Fix pandas DataFrame row numbers.
0.14.2 - 2023-09-15
- Search environment variables when resolving user variables.
0.14.1 - 2023-06-28
- Use pandas concat instead of deprecated append.
0.14.0 - 2023-05-19
- Add
%flink_execute_sql_set
command which allows to run multiple inserts in statement set
0.13.5 - 2023-03-13
- Fixed displaying results of metadata queries.
- Add
type
parameter for%flink_show_table_tree
, eithertree
(default) orjson
.
0.13.4 - 2023-02-24
- Fixed query interruption.
0.13.3 - 2023-02-08
- Fixed init order
0.13.2 - 2023-01-23
- Skip curly brackets with digits
0.13.1 - 2023-01-20
- Fixed connecting to a remote cluster when
pipeline.jars
property is empty.
0.13.0 - 2023-01-17
- Apache Flink 1.16
- 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
- Try to load
flink-conf.yaml
fromFLINK_CONF_DIR
first.
- 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
- 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.
- Add a workaround for displaying
TIMESTAMP_LTZ
field.
0.11.0 - 2022-11-03
- Add
row_kind
column to the results. - Allow specifying port in local execution target (
--local-port
).
- In yarn-session execution target only RUNNING yarn applications are taken into account.
0.10.0 - 2022-10-25
- Support for execution targets: local, remote, yarn-session.
- Accept Apache Flink versions 1.15.X.
0.9.1 - 2022-10-25
- Show functions & change icon for views in
%flink_show_table_tree
- Skip curly brackets without variable
0.9.0 - 2022-10-20
- Support for batch mode
- 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.
0.8.2 - 2022-10-07
- Update Apache Flink dependency to 1.15.2.
0.8.1 - 2022-10-07
- Do not add comments to the inline query
0.8.0 - 2022-10-05
- Enable users to display catalogs, databases, tables and columns as an expandable tree by running
%flink_show_table_tree
command.
0.7.0 - 2022-09-23
- Support for python 3.7
0.6.2 - 2022-09-14
- Do not throw if
secrets
is nonexistent in the streaming CLI config file.
0.6.1 - 2022-09-14
- Ensure
_secrets
variable is set at the beginning of magics initialization.
0.6.0 - 2022-09-13
- Read variable marked with
${VARIABLE_NAME}
from environment variables, if it exists. Otherwise, ask user usinggetpass
module.
- Ensure that
jars
directory exists before plugins loading.
0.5.0 - 2022-09-12
- Use
getpass
to read variables marked with${VARIABLE_NAME}
from user input. - Load secret from file using
%load_secret_file
magic. - Load secrets from files listed in
.streaming_config.yml
file.
0.4.0 - 2022-08-25
- Make Jupyter update DataFrame with the data polled by Flink in real time.
0.3.0 - 2022-08-22
- Using init.sql as the initialization script.
- Use plugin to run jar providers on initialization.
- Make SQL syntax highlighting available in JupyterLab.
- Make Magics recognize DESCRIBE and SHOW keywords as queries.
0.2.1 - 2022-08-02
- Update Apache Flink dependency to 1.15.1.
0.2.0 - 2022-07-06
- Update Apache Flink dependency to 1.15.
0.1.6 - 2022-06-17
- StreamingEnvironment uses
flink-conf.yaml
properties.
0.1.5 - 2022-05-11
0.1.4 - 2022-05-10
0.1.3 - 2022-05-09
- First release