[ 
https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041614#comment-17041614
 ] 

Jark Wu commented on FLINK-15400:
---------------------------------

Thanks for sharing this great proposal [~Leonard Xu], I like it. 
Just some suggestions: 
 - I think we can still use 'connector.index', if it has a "{}" in it, then it 
is a dynamic index. (I think "{}" is not allowed in es index name, right?). So 
that we don't need to introduce 'connect.dynamicindex' at all.
 - We can have another property 'connector.index-alias' to declare the alias, 
because if the index is not a dynamic index, it should also can have an alias. 

Hi [~libenchao], thanks for your inputs. I think it's an orthogonal feature 
which we can call them metadata handling. We already have an issue to track 
that problem, see FLINK-15869

> elasticsearch sink support dynamic index.
> -----------------------------------------
>
>                 Key: FLINK-15400
>                 URL: https://issues.apache.org/jira/browse/FLINK-15400
>             Project: Flink
>          Issue Type: New Feature
>          Components: Connectors / ElasticSearch, Table SQL / Ecosystem
>    Affects Versions: 1.11.0
>            Reporter: ouyangwulin
>            Priority: Major
>              Labels: usability
>             Fix For: 1.11.0
>
>
> From 
> [email protected]([https://lists.apache.org/thread.html/ac4e0c068baeb3b070f0213a2e1314e6552b226b8132a4c49d667ecd%40%3Cuser-zh.flink.apache.org%3E]),
>   Becuase the es 6/7 not support ttl. so User need clean the index by 
> timestamp. Add dynamic index is a useful function.  Add with properties 
> 'dynamicIndex' as a switch for open dynamicIndex. Add with  properties 
> 'indexField'  for the extract time field, Add properties 'indexInterval' for 
> change cycle mode.
>  
> ||With property||discribe||default||Required||
> |dynamicIndex|Dynamic or not|false(true/false)|false|
> |indexField|extract index field| none|dynamicIndex is true , then indexField 
> is required,only supported type "timestamp","date","long" |
> |indexInterval|mode for  cycle|d|ddynamicIndex is true , this field is 
> required ,the value optional is:
>  d:day
>  m:mouth
>  w:week|
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to