[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2020-06-30 Thread Leonard Xu (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-12-08 Thread Jark Wu (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-12-06 Thread Timo Walther (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-12-04 Thread Jark Wu (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-12-04 Thread Kurt Young (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-12-04 Thread Jark Wu (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-12-04 Thread Timo Walther (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-17 Thread Kurt Young (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-17 Thread Jark Wu (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-16 Thread Kurt Young (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-16 Thread Jark Wu (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-15 Thread Kevin Zhang (Jira)
[ 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

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-06 Thread jackylau (Jira)
[ 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,

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-04 Thread Jark Wu (Jira)
[ 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.

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-04 Thread jackylau (Jira)
[ 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