ksql

ksql copied to clipboard

### Description _What behavior do you want to change, why, how does your patch achieve the changes?_ ### Testing done _Describe the testing strategy. Unit and integration tests are expected...

jnh5y

Clearer behavior when using UDAFs with *

3

Currently, using `*` in a UDAF defaults to the `ROWTIME` column. For example, if you run: ``` CREATE STREAM test (ID STRING) WITH (KAFKA_TOPIC='test', PARTITIONS=1, VALUE_FORMAT='JSON'); CREATE TABLE test_result AS...

reneesoika

Error trying to update schema changing the number of partitions

4

We're receiving the following error trying to update the number of partitions of a schema `Cannot upgrade data source: DataSource '`XXX__STREAM`' has topic = KsqlTopic{kafkaTopicName='xxx__updated', keyFormat=KeyFormat{format=FormatInfo{format=KAFKA, properties={}}, features=[], window=Optional.empty}, valueFormat=ValueFormat{format=FormatInfo{format=PROTOBUF,...

xnog

Insert Into queries fail when source record map is missing keys that are inserted into target record map for protobuf schema

2

**Describe the bug** Insert Into queries fail when source record map is missing keys that are inserted into target record map for protobuf schema The query throws NPE **To Reproduce**...

SamiShaikh

### Description The goal is to speed up the Jenkins CI job. ### Testing done Manually checking out the CI job to make sure that it is running things sanely...

jnh5y

### Description _What behavior do you want to change, why, how does your patch achieve the changes?_ ### Testing done _Describe the testing strategy. Unit and integration tests are expected...

jnh5y

### Description _What behavior do you want to change, why, how does your patch achieve the changes?_ ### Testing done _Describe the testing strategy. Unit and integration tests are expected...

jnh5y

### Description _What behavior do you want to change, why, how does your patch achieve the changes?_ ### Testing done _Describe the testing strategy. Unit and integration tests are expected...

jnh5y

### Description _What behavior do you want to change, why, how does your patch achieve the changes?_ ### Testing done _Describe the testing strategy. Unit and integration tests are expected...

jnh5y

chore: Put interpreter use of lambdas behind the flag ksql.lambdas.enabled

2

### Description Now throws an error if the use of lambdas in the interpreter is attempted without setting `ksql.lambdas.enabled=true` ### Testing done Added RQTT ### Reviewer checklist - [ ]...

AlanConfluent