[jira] [Commented] (FLINK-11605) Translate the "Dataflow Programming Model" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878948#comment-16878948 ] xueyu commented on FLINK-11605: --- Hi, [~jark], I was busy recently and un-asssinged, thanks ~ > Translate

[jira] [Assigned] (FLINK-11605) Translate the "Dataflow Programming Model" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11605: - Assignee: (was: xueyu) > Translate the "Dataflow Programming Model" page into Chinese >

[jira] [Created] (FLINK-11709) Bump jline version

xueyu created FLINK-11709: - Summary: Bump jline version Key: FLINK-11709 URL: https://issues.apache.org/jira/browse/FLINK-11709 Project: Flink Issue Type: Improvement Components: SQL

[jira] [Assigned] (FLINK-11605) Translate the "Dataflow Programming Model" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11605: - Assignee: xueyu > Translate the "Dataflow Programming Model" page into Chinese >

[jira] [Assigned] (FLINK-11560) Translate "Flink Applications" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11560: - Assignee: xueyu > Translate "Flink Applications" page into Chinese >

[jira] [Commented] (FLINK-11506) 通过sql-client.sh登录后，执行sql语句报IO异常，然后客户端中断退出

[ https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16758030#comment-16758030 ] xueyu commented on FLINK-11506: --- Hi, [~chenzun], please update the issue title using English..Could you

[jira] [Commented] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757275#comment-16757275 ] xueyu commented on FLINK-11451: --- Hi, [~hequn8128] [~twalthr] I submitted the PR to move QueryConfig,

[jira] [Comment Edited] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757275#comment-16757275 ] xueyu edited comment on FLINK-11451 at 1/31/19 2:24 PM: Hi, [~hequn8128]

[jira] [Commented] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756073#comment-16756073 ] xueyu commented on FLINK-11451: --- Hi, [~hequn8128], please let me evaluate the degree of difficulties of

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754994#comment-16754994 ] xueyu commented on FLINK-11065: --- I see..Thanks for your point, [~twalthr] > Migrate flink-table runtime

[jira] [Assigned] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11451: - Assignee: xueyu > Move *QueryConfig and TableDescriptor to flink-table-api-java >

[jira] [Assigned] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-7697: Assignee: xueyu > Add metrics for Elasticsearch Sink > -- > >

[jira] [Assigned] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-11155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11155: - Assignee: xueyu > HadoopFreeFsFactoryTest fails with ClassCastException >

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750891#comment-16750891 ] xueyu commented on FLINK-11046: --- It looks that this kind of IndexRequest could result in reponse

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750025#comment-16750025 ] xueyu commented on FLINK-11046: --- Hi, [~dawidwys][~tzulitai], I don't know how to make elastic6 response

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747831#comment-16747831 ] xueyu commented on FLINK-11046: --- Hi, [~dawidwys], sorry that I only writed the codes and didn't write any

[jira] [Commented] (FLINK-10593) Add support for ALL ROWS PER MATCH

[ https://issues.apache.org/jira/browse/FLINK-10593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742184#comment-16742184 ] xueyu commented on FLINK-10593: --- Hi, [~dian.fu], I have changed Assignee to you > Add support for ALL

[jira] [Assigned] (FLINK-10593) Add support for ALL ROWS PER MATCH

[ https://issues.apache.org/jira/browse/FLINK-10593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10593: - Assignee: Dian Fu (was: xueyu) > Add support for ALL ROWS PER MATCH >

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742179#comment-16742179 ] xueyu commented on FLINK-11046: --- Hi, [~dawidwys], have you worked on this issue? If not could you please

[jira] [Commented] (FLINK-8921) Split code generated call expression

[ https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742134#comment-16742134 ] xueyu commented on FLINK-8921: -- hi, [~tivan], I updated and added your test case in this

[jira] [Assigned] (FLINK-10467) Upgrade commons-compress to 1.18

[ https://issues.apache.org/jira/browse/FLINK-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10467: - Assignee: xueyu > Upgrade commons-compress to 1.18 > > >

[jira] [Commented] (FLINK-11104) LEFT JOIN with Table Function not working

[ https://issues.apache.org/jira/browse/FLINK-11104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712978#comment-16712978 ] xueyu commented on FLINK-11104: --- It looks that the doc uses LEFT JOIN LATERAL TABLE..., and your sql

[jira] [Created] (FLINK-11093) Migrate flink-table runtime Function classes

xueyu created FLINK-11093: - Summary: Migrate flink-table runtime Function classes Key: FLINK-11093 URL: https://issues.apache.org/jira/browse/FLINK-11093 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11092) Migrate flink-table runtime Selector and Collector classes

xueyu created FLINK-11092: - Summary: Migrate flink-table runtime Selector and Collector classes Key: FLINK-11092 URL: https://issues.apache.org/jira/browse/FLINK-11092 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712306#comment-16712306 ] xueyu commented on FLINK-11065: --- hi, [~hequn8128], I totally agree with you. Last time when I port UDF

[jira] [Assigned] (FLINK-10593) Add support for ALL ROWS PER MATCH

[ https://issues.apache.org/jira/browse/FLINK-10593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10593: - Assignee: xueyu > Add support for ALL ROWS PER MATCH > -- > >

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709815#comment-16709815 ] xueyu commented on FLINK-11065: --- hi, [~twalthr], how about create one sub-issue which ports

[jira] [Assigned] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11065: - Assignee: (was: xueyu) > Migrate flink-table runtime classes > ---

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708679#comment-16708679 ] xueyu commented on FLINK-11065: --- I see..Thanks for reminding, [~twalthr] > Migrate flink-table runtime

[jira] [Assigned] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-11065: - Assignee: xueyu > Migrate flink-table runtime classes > --- > >

[jira] [Commented] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692586#comment-16692586 ] xueyu commented on FLINK-10926: --- hi, [~x1q1j1], Version 1.6.2 does not support timestampdiff. This

[jira] [Commented] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691873#comment-16691873 ] xueyu commented on FLINK-10926: --- which version did you use? you could refer testTimestampDiff in

[jira] [Commented] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691588#comment-16691588 ] xueyu commented on FLINK-10926: --- hi, [~x1q1j1], you could try this: {{select TIMESTAMPDIFF (MINUTE,

[jira] [Commented] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682913#comment-16682913 ] xueyu commented on FLINK-10847: --- It looks that when select multiple distinct aggregate with different

[jira] [Assigned] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10845: - Assignee: xueyu > Support DISTINCT aggregates for batch > - > >

[jira] [Assigned] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10846: - Assignee: xueyu > Add support for IS DISTINCT FROM in code generator >

[jira] [Updated] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu updated FLINK-10689: -- External issue URL: https://github.com/apache/flink/pull/7059 Labels: pull-request-available

[jira] [Comment Edited] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672778#comment-16672778 ] xueyu edited comment on FLINK-10689 at 11/2/18 8:55 AM: Thanks

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672778#comment-16672778 ] xueyu commented on FLINK-10689: --- Thanks [~phoenixjiangnan], It looks that

[jira] [Commented] (FLINK-10731) Support AVG on Date fields

[ https://issues.apache.org/jira/browse/FLINK-10731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669900#comment-16669900 ] xueyu commented on FLINK-10731: --- what behavior would you expect, [~f.pompermaier], convert the date to int

[jira] [Commented] (FLINK-10731) Support AVG on Date fields

[ https://issues.apache.org/jira/browse/FLINK-10731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669769#comment-16669769 ] xueyu commented on FLINK-10731: --- Could you please give your concrete use case, e.g. your sql or table api

[jira] [Assigned] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-8953: Assignee: xueyu > Resolve unresolved field references in FieldComputer expressions >

[jira] [Assigned] (FLINK-10689) Port Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10689: - Assignee: xueyu > Port Table API extension points to flink-table-common >

[jira] [Commented] (FLINK-8921) Split code generated call expression

[ https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662419#comment-16662419 ] xueyu commented on FLINK-8921: -- It looks this issue has not been started for a little long time. I submitted

[jira] [Created] (FLINK-10642) CodeGen split fields errors when maxGeneratedCodeLength equals 1

xueyu created FLINK-10642: - Summary: CodeGen split fields errors when maxGeneratedCodeLength equals 1 Key: FLINK-10642 URL: https://issues.apache.org/jira/browse/FLINK-10642 Project: Flink Issue

[jira] [Commented] (FLINK-10088) error when trying to run flink-sql-client on windows

[ https://issues.apache.org/jira/browse/FLINK-10088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639764#comment-16639764 ] xueyu commented on FLINK-10088: --- hi, [~anubhavtarar], did you run sql-client.sh using the command " sh

[jira] [Assigned] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-8865: Assignee: xueyu > Add CLI query code completion in SQL Client >

[jira] [Assigned] (FLINK-7360) Support Scala map type in Table API

[ https://issues.apache.org/jira/browse/FLINK-7360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-7360: Assignee: xueyu > Support Scala map type in Table API > --- > >

[jira] [Commented] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

[ https://issues.apache.org/jira/browse/FLINK-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16608412#comment-16608412 ] xueyu commented on FLINK-7271: -- It looks that this issue has alread been resolved, I don't know whether I

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601803#comment-16601803 ] xueyu commented on FLINK-10261: --- In addition, `DataStreamSortRule` seems require the first sort attributes

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601797#comment-16601797 ] xueyu commented on FLINK-10261: --- It was caused by calcite validate rewrite and change SqlNode in some

[jira] [Assigned] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10261: - Assignee: xueyu > INSERT INTO does not work with ORDER BY clause >

[jira] [Commented] (FLINK-7360) Support Scala map type in Table API

[ https://issues.apache.org/jira/browse/FLINK-7360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16597513#comment-16597513 ] xueyu commented on FLINK-7360: -- It looks that flink scala does not support java.util.Map too, such as scala

[jira] [Created] (FLINK-10174) getbytes with no charsets test error for hex and toBase64

xueyu created FLINK-10174: - Summary: getbytes with no charsets test error for hex and toBase64 Key: FLINK-10174 URL: https://issues.apache.org/jira/browse/FLINK-10174 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-10174) getbytes with no charsets test error for hex and toBase64

[ https://issues.apache.org/jira/browse/FLINK-10174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10174: - Assignee: xueyu > getbytes with no charsets test error for hex and toBase64 >

[jira] [Commented] (FLINK-10032) Rework SQL DATE_FORMAT function

[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582574#comment-16582574 ] xueyu commented on FLINK-10032: --- whether or not we also support date_format with string type parameter

[jira] [Commented] (FLINK-9984) Add a byte array table format factory

[ https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560779#comment-16560779 ] xueyu commented on FLINK-9984: -- I would like to work on this issue, it looks that I can't change assingee to

[jira] [Created] (FLINK-9907) add CRC32 checksum in table Api and sql

xueyu created FLINK-9907: Summary: add CRC32 checksum in table Api and sql Key: FLINK-9907 URL: https://issues.apache.org/jira/browse/FLINK-9907 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9853) add hex support in table api and sql

xueyu created FLINK-9853: Summary: add hex support in table api and sql Key: FLINK-9853 URL: https://issues.apache.org/jira/browse/FLINK-9853 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4301) Parameterize Flink version in Quickstart bash script

[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520309#comment-16520309 ] xueyu commented on FLINK-4301: -- thanks [~fhueske], I have submitted pr for both flink and flink-web git >

[jira] [Commented] (FLINK-4301) Parameterize Flink version in Quickstart bash script

[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519949#comment-16519949 ] xueyu commented on FLINK-4301: -- Does this refer to the script https://flink.apache.org/q/quickstart.sh? If

[jira] [Comment Edited] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518099#comment-16518099 ] xueyu edited comment on FLINK-6846 at 6/20/18 1:36 PM: --- I want to submit a PR for

[jira] [Commented] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518099#comment-16518099 ] xueyu commented on FLINK-6846: -- I want to submit a PR for this function, would you mind change Assignee to