Yash Mayya

KAFKA-14147: Prevent deferredTaskUpdates map from growing monotonically in KafkaConfigBackingStore

1

- https://issues.apache.org/jira/browse/KAFKA-14147 - Similar to https://issues.apache.org/jira/browse/KAFKA-8869, but without the rebalancing implications.

KAFKA-14162: HoistField SMT should not return an immutable map for schemaless key/value

1

- https://issues.apache.org/jira/browse/KAFKA-14162 - The HoistField SMT currently returns an immutable map for schemaless keys and values - https://github.com/apache/kafka/blob/22007fba7c7346c5416f4db4e104434fdab265ee/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java#L62 - This can cause failures in connectors if they attempt to modify...

KAFKA-13809: Propagate full connector configuration to tasks in FileStream connectors

3

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* - https://issues.apache.org/jira/browse/KAFKA-13809 :...

KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

1

- https://issues.apache.org/jira/browse/KAFKA-13952: RetryWithToleranceOperator doesn't respect infinite retries config - i.e. when `errors.retry.timeout` is set to `-1` - From https://cwiki.apache.org/confluence/display/KAFKA/KIP-298%3A+Error+Handling+in+Connect: >errors.retry.timeout: [-1, 0, 1, ... Long.MAX_VALUE], where -1 means infinite duration....

Add hadoop-client-runtime dependency to fix quickstart NoClassDefFoundError issue

1

- Currently, a number of quickstarts (`GenericQuickstart`, `MultistageEngineQuickStart` etc.) encounter errors while ingesting data into some tables: ``` java.lang.RuntimeException: Caught exception during running - org.apache.pinot.plugin.ingestion.batch.standalone.SegmentGenerationJobRunner at org.apache.pinot.spi.ingestion.batch.IngestionJobLauncher.kickoffIngestionJob(IngestionJobLauncher.java:152) ~[classes/:?] at org.apache.pinot.spi.ingestion.batch.IngestionJobLauncher.runIngestionJob(IngestionJobLauncher.java:121)...

Add IGNORE NULLS option to FIRST_VALUE and LAST_VALUE window functions

1

- The SQL standard defines a `RESPECT NULLS` or `IGNORE NULLS` option for the window functions `LEAD`, `LAG`, `FIRST_VALUE`, `LAST_VALUE`, and `NTH_VALUE` (although Pinot currently doesn't support this function). The...

Fix window frame upper bound offset extraction in PinotWindowExchangeNodeInsertRule

1

- This is a bug fix for window frame upper bound offset extraction in `PinotWindowExchangeNodeInsertRule` (from changes recently merged in https://github.com/apache/pinot/pull/14273). - This patch also adds a unit test for...

Add all supported types to return type inference from string literal for JSON extract functions in the multi-stage query engine

1

- Currently, a query like `SELECT JSON_EXTRACT_SCALAR(payload_commits, '$[*].author.name', 'STRING_ARRAY') FROM github_events` fails on the multi-stage query engine with an error like: `Invalid type: STRING_ARRAY`. - This is because the type...

Rename multi-stage engine's explain asking servers to explain include segment plan

2

- https://github.com/apache/pinot/pull/13733 - The broker config was renamed from `pinot.query.explain.ask.servers` to `pinot.query.multistage.explain.include.segment.plan` during the course of review. This patch updates the corresponding query option to match the name for a...

Short circuit queries where no rows will be returned

1

- There are numerous types of queries where it is guaranteed that no rows will be returned. For instance - selection only queries with `LIMIT 0`, group by aggregation queries...