[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148513#comment-17148513
]
Leonard Xu commented on FLINK-14567:
I close this issue because defining primary keys in sink table
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991087#comment-16991087
]
Jark Wu commented on FLINK-14567:
-
[~twalthr], in the storage, the HBase rowkey is always stored in
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989792#comment-16989792
]
Timo Walther commented on FLINK-14567:
--
I'm not very familiar with HBase. Is the key always a
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987697#comment-16987697
]
Jark Wu commented on FLINK-14567:
-
[~ykt836], could we just use the key constraint in
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987675#comment-16987675
]
Kurt Young commented on FLINK-14567:
Basically yes. But this would involve the discussion about how
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987644#comment-16987644
]
Jark Wu commented on FLINK-14567:
-
Hi [~twalthr] [~ykt836], do you mean if the key information of sink
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987637#comment-16987637
]
Timo Walther commented on FLINK-14567:
--
In general, I think the key information should come from
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976296#comment-16976296
]
Kurt Young commented on FLINK-14567:
It depends on how we see this problem. IMO if we want to emit
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976242#comment-16976242
]
Jark Wu commented on FLINK-14567:
-
But adding an operator to convert into upsert stream is an
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975930#comment-16975930
]
Kurt Young commented on FLINK-14567:
Even if the framework can't derive primary key information of
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975898#comment-16975898
]
Jark Wu commented on FLINK-14567:
-
Another soution is letting sink concats keys. For example, an HBase
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974992#comment-16974992
]
Kevin Zhang commented on FLINK-14567:
-
I basically agree with [~jackylau]. In the proposed scenario
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968216#comment-16968216
]
jackylau commented on FLINK-14567:
--
i means that the framework can not solve it. .User use concat_ws,
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966641#comment-16966641
]
Jark Wu commented on FLINK-14567:
-
[~jackylau] the problem is how. I don't have a clear idea right now.
[
https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966499#comment-16966499
]
jackylau commented on FLINK-14567:
--
Is it proper to deliver to the user who knows that the data format
15 matches
Mail list logo