Kanthi

Kubernetes decorator

11

Decorator to execute functions in k8s using KubernetesPodOperator closes: #19135 ``` @task.kubernetes(image='python:3.8-slim-buster', name='k8s_test', namespace='default') def k8s_decorator_func(): print("decorator func") ``` If no parameters passed, defaults are set in kubernetes.py ``` #...

Support custom UDF

2

Tried to mount two files to support custom UDF's in clickhouse-operator https://chowdera.com/2022/03/202203311616432455.html, see below the yaml file. Couple of issues, 1) The UDF code(Python file) looks like has to be...

[17198] Removed LIKE restriction in StatementRestrictions

Insert batch - JSON error

2

``` java.sql.BatchUpdateException: Code: 48. DB::Exception: Method getDefault() is not implemented for data type Object('json'). (NOT_IMPLEMENTED) (version 22.7.1.2484 (official build)) sink | , server ClickHouseNode [uri=http://clickhouse:8123/test, options={client_name=Agent_1}]@-1529990687 sink | at com.clickhouse.jdbc.SqlExceptionUtils.batchUpdateError(SqlExceptionUtils.java:109)...

Kafka Connect - Apicurio out of bounds exception.

2

We are getting an exception when the Kafka connect sink connector is created with the following configuration ``` "key.converter": "io.apicurio.registry.utils.converter.AvroConverter", "value.converter": "io.apicurio.registry.utils.converter.AvroConverter", "key.converter.apicurio.registry.url": "http://schemaregistry:8080/apis/registry/v2", "key.converter.apicurio.registry.auto-register": "true", "key.converter.apicurio.registry.find-latest": "true", "value.converter.apicurio.registry.url": "http://schemaregistry:8080/apis/registry/v2",...

DateTime/Date limits not compatible with CH server limits

4

``` DATETIME64_MAX = LocalDateTime.of(LocalDate.of(2283, 11, 11), LocalTime.MAX).toEpochSecond(ZoneOffset.UTC); ``` In Java 11, the nanosecond part is lost because of converting to `LocalDateTime`, maybe it should be kept as `Instant`. Also the...

…tainers.

Add support for setting column type in Clickhouse.

17

Added support for setting column type in clickhouse Relates to #15515 ## Release notes (x) Release notes are required, with the following suggested text: ```markdown # ClickHouse * Add support...

Table with transaction column name not parsed

2

### Describe the bug Table with transaction column name not parsed ``` create table test_execute_batch(a Int32, transaction String)engine=Memory ``` ### Expected behaviour It should be parsed and the table should...

Proposal to use ReplacingMergeTree for handling updates/deletes.

1

We have an implemention in the https://github.com/Altinity/clickhouse-sink-connector Kafka sink connector where updates/deletes are handled in ReplacingMergeTree. Deletes can be handled on the newer ReplacingMergeTree with the `is_deleted` column. Happy to...