apache/rocketmq-externals

[rocketmq-connect-hudi] sinkConnectConfig topicRouteMap not set value

Open

#856 opened on 2021年12月14日

GitHub で見る
 (0 comments) (0 reactions) (0 assignees)Java (4,513 stars) (3,084 forks)batch import
good first issue

説明

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

  1. Please describe the issue you observed:
  • What did you do (The steps to reproduce)?

org.apache.rocketmq.connect.hudi.connector.HudiSinkConnector

defaultKeyValue.put(HudiConnectConfig.CONN_TOPIC_ROUTE_INFO, JSONObject.toJSONString(sinkConnectConfig.getTopicRouteMap()));

image

  • What did you expect to see? sinkConnectConfig.getTopicRouteMap() should set org.apache.rocketmq.connect.hudi.connector.HudiSinkConnector#topicRouteMap

  • What did you see instead? sinkConnectConfig.topicRouteMap no set value

  1. Please tell us about your environment:

  2. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

  1. Please describe the feature you are requesting.

  2. Provide any additional detail on your proposed use case for this feature.

  3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

  4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

コントリビューターガイド

技術スタック
java
領域
databackend
Issue 種別
bug
難度新しい貢献者にとっての実装難度です。1 は非常に小さな変更、5 は専門的な作業です。
3
推定時間経験ある貢献者が調査、実装、テスト、pull request 準備にかけるおおよその時間範囲です。
half day
活動状況Issue が今どれだけ取り組みやすいかを示します。新しい、活発、古い、ブロック中、またはメンテナー入力待ちなどです。
stale
明確さ期待される変更、受け入れ条件、次の手順がどれだけ明確かを示します。
clear
前提条件
Familiarity with RocketMQ ConnectJava debugging skills
初心者向け度初回貢献者にどれだけ取り組みやすいかを 1-100 で推定したスコアです。
30
調査方針
Examine the HudiSinkConnector class in the rocketmq connect hudi module. The issue reports that sinkConnectConfig.topicRouteMap is not being assigned to the connector's topicRouteMap field. Check the start() or configure() method to ensure the field is properly populated from configuration. The fix likely involves adding an assignment like this.topicRouteMap = sinkConnectConfig.getTopicRouteMap() in the appropriate initialization block.
[rocketmq-connect-hudi] sinkConnectConfig topicRouteMap not set value · apache/rocketmq-externals#856 | Good First Issue