apache/rocketmq-externals

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

Open

#856 opened on Dec 14, 2021

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

Description

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:

Contributor guide

Tech stack
java
Domain
databackend
Issue type
bug
DifficultyEstimated implementation difficulty for a new contributor, from 1 for very small changes to 5 for expert-level work.
3
Estimated timeA rough time range for an experienced contributor to investigate, implement, test, and prepare a pull request.
half day
Activity statusHow available the issue appears right now: fresh, active, stale, blocked, or waiting on maintainer input.
stale
ClarityHow clearly the issue explains the expected change, acceptance criteria, and next step.
clear
Prerequisites
Familiarity with RocketMQ ConnectJava debugging skills
Newbie friendlinessA 1-100 score estimating how approachable this issue is for first-time contributors.
30
Research direction
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.