AloysZhang

support setting bundle number for default namespace when set up cluster

3

### Motivation In the actual production environment, users may only use one default namespace (public/default). The number of bundles in this namespace is a default value of 16. 1. if...

[fix][broker][schema]fix creating lots of ledgers for the same schema

2

Fixes #18292 ### Motivation fix creating lots of ledgers for the same schema ### Modifications when putting schema to zk failed, do not retry directly, but read the latest persistent...

[cleanup][broker]remove legacy code

1

### Motivation remove legacy code ### Modifications remove legacy code ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of...

[Bug] Too much schemas ledgers are created when multi producer start concurrently

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.8.1 ### Minimal reproduce step 1. create a new topic 2. start up...

### Description Currently, we can't set the subscription name for the pulsar source, Flink connector will generate a subscription name combining `flink-sql-connector-pulsar` prefix with a random string suffix. This may...

- Fixes #9876 ### Motivation optimize the format of error message ### Modifications optimize the format of error message. With this pul request, the error msg will be `Request to...

### What happened Manager-client print error message when met exception like : ```shell java.lang.IllegalArgumentException: Request to Inlong Inlong group already exists failed: null at org.apache.inlong.manager.common.util.Preconditions.expectTrue(Preconditions.java:138) at org.apache.inlong.manager.client.api.util.ClientUtils.assertRespSuccess(ClientUtils.java:121) at org.apache.inlong.manager.client.api.inner.client.InlongGroupClient.createGroup(InlongGroupClient.java:166) at...

### Description Support submit flink job for offline data sync ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit...

## Motivation Currently, InLong provides real-time data synchronization based on the Flink engine, which has the advantage of low latency. Compared to real-time synchronization, offline data synchronization(not supported yet) pays...

Fixes #10091 ### Motivation Add JSON format for 1.18, and make sure the inlong-sort module can be built with profile v1.18 ### Modifications - add `format-json-v1.18` module - resolve flink...