Alan Sheinberg

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 - [ ]...

MINOR: Adds KRaft versions of most streams system tests

4

Adds the annotation `@matrix(metadata_quorum=quorum.all_non_upgrade)` to many existing tests, which runs them with each of zookeeper and remote_kraft nodes. This skips tests which use various forms of Kafka versioning since those...

test: Makes PullQueryLimitHARoutingTest more reliable

1

### Description Previously, we weren't ensuring that the active was actually caught up with input, so refactored logic from RQTT to be used. Also, we didn't ensure that the reported...

test: Runs most of the remaining integration tests in parallel

2

### Description Runs most of the remaining integration tests in parallel. ### Testing done _Describe the testing strategy. Unit and integration tests are expected for any behavior changes._ ### Reviewer...

test: Up Heartbeating test timeout

1

### Description Up Heartbeating test timeout ### Testing done _Describe the testing strategy. Unit and integration tests are expected for any behavior changes._ ### Reviewer checklist - [ ] Ensure...

test: Removes race in KsqlResourceFunctionalTest and ups timeout elsewhere

1

### Description `KsqlResourceFunctionalTest` had a race where a stream would be created, and then it would be assumed it would be there. In reality, the command must be written to...

[FLINK-34027] Introduces AsyncScalarFunction as a new UDF type

6

## What is the purpose of the change This introduces `AsyncScalarFunction` a new UDF type which allows asynchronous responses. The functionality here is covered in FLIP-400: https://cwiki.apache.org/confluence/display/FLINK/FLIP-400%3A+AsyncScalarFunction+for+asynchronous+scalar+function+support ## Brief change...

test: Adds a new single-host functional test for LagReportingAgent

1

### Description Previously, we had a multi-node functional test for LagReportingAgent, but this adds a single node as well. ### Reviewer checklist - [ ] Ensure docs are updated if...

fix: Check for index before removing value in undo of COLLECT_LIST (#…

1

…6603) * fix: Check for index before removing value in undo of COLLECT_LIST ### Description _What behavior do you want to change, why, how does your patch achieve the changes?_...

test: Exposes raw streams statuses in "show query" response for stabler tests

1

### Description Currently, the RQTT tests for scalable push queries poll the query itself until it doesn't error. Rather that do this to infer that the underlying push query is...