affe (Yufei Zhang)
affe (Yufei Zhang)
More context here: https://streamnative.slack.com/archives/C01V6HYFVMF/p1650437936469119
Avro schema is not supported in current pulsar-sink
 producedDataType set twice, we can delete one line of it
**Describe the bug**  Currently the new catalog design should already support multiple topics and topic patterns. **To Reproduce** Steps to reproduce the behavior: 1. Go to '...' 2. Click...
**Describe the bug** Original Report : https://github.com/apache/pulsar/issues/12693 Quick Description: FlinkPulsarSink can't complete checkpoint if one of pulsar broker goes down. And when it reaches checkpoint restart limit, it will trigger...
The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **BUG REPORT** 1. currently the consumer/producer client ip...
**FEATURE REQUEST** **1. Please describe the feature you are requesting.** 1. Currently the RocketMQ connect runtime supports 6 task state : NEW, PENDING, RUNNING, STOPPING, STOPPED, ERROR. But we need...
The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **BUG REPORT** 1. Please describe the issue you...
The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **FEATURE REQUEST** This is a recorder for issues...
I noticed in removeConnectorConfig(), ``` @Override public void removeConnectorConfig(String connectorName) { ConnectKeyValue config = new ConnectKeyValue(); config.put(RuntimeConfigDefine.UPDATE_TIMESATMP, System.currentTimeMillis()); config.put(RuntimeConfigDefine.CONFIG_DELETED, 1); Map connectorConfig = new HashMap(); connectorConfig.put(connectorName, config); List taskConfigList =...