[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611487#comment-16611487 ]
Shimin Yang commented on FLINK-10245: ------------------------------------- Hi [~hequn8128],I have been thinking about should we allow Nullable field. And if the Nullable field is allowed, then the mutations cannot be deduplicated by rowkey. Meanwhile, I also the think the deduplication is not suitable for Retract or Upsert Table SInk that I will implement in the future. But keep a memory buffer and use batch api might be a good idea. I will try to work on it. > Add DataStream HBase Sink > ------------------------- > > Key: FLINK-10245 > URL: https://issues.apache.org/jira/browse/FLINK-10245 > Project: Flink > Issue Type: Sub-task > Components: Streaming Connectors > Reporter: Shimin Yang > Assignee: Shimin Yang > Priority: Major > Labels: pull-request-available > > Design documentation: > [https://docs.google.com/document/d/1of0cYd73CtKGPt-UL3WVFTTBsVEre-TNRzoAt5u2PdQ/edit?usp=sharing] -- This message was sent by Atlassian JIRA (v7.6.3#76005)