Grzegorz Liter
Grzegorz Liter
We should have mock for SQL Gateway (ether mock client or provide web server mock) with utility methods so we can create component tests. It would be worth considering to...
Without backticks quotation Flink will try to interprete column names as key words, example given when column name is "timestamp" it will fail. ``` Flink SQL> create table clickstream (timestamp...
When running `dbt run` we are typically ending with some pipelines. There is a `dbt clean` it is worth investigating what it is for and maybe if we should use...
Currently when we run `dbt run` twice in the same session we will get exceptions that table already exist ``` Caused by: org.apache.flink.table.catalog.exceptions.TableAlreadyExistException: Table (or view) default_database.joined_data already exists in...
Views are named with __dbt_tmp suffix ``` create view joined_data__dbt_tmp /** mode('streaming')*/ as ( select cs.event_timestamp, cs.user_id, cs.event, trx.source, trx.target, trx.amount, trx.deposit_balance_after_trx, trx.credit_balance_after_trx from clickstream as cs join trx as...
We should be able to define primary key for source table https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/create/#primary-key It is for example needed for event time temporal joins https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/joins/#event-time-temporal-join Example: ``` select * > from clickstream...
## What is the purpose of the change Use ForkJoinPool when enumerating files to greatly increase speed. Especially in cases when majority of time is wasted waiting for remote storage...
Binding does not work with Gree Clivia device ## Expected Behavior Binding binds to an AC ## Current Behavior Binding fails with: ``` 2024-06-22 19:45:00.126 [ERROR] [ng.gree.internal.handler.GreeHandler] - ac_sypialnia_gl: Thing...
Binding does not work with Gree Clivia. The AC does respond to scan package but then does not respond to bind package. Wireshark shows no response.