[jira] [Created] (FLINK-12817) Correct the import in Processing function example

2019-06-12 Thread TANG Wen-hui (JIRA)
TANG Wen-hui created FLINK-12817: Summary: Correct the import in Processing function example Key: FLINK-12817 URL: https://issues.apache.org/jira/browse/FLINK-12817 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11661) Implement HadoopReduceCombineFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11661: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopReduceCombineFunctionITCase for

[jira] [Assigned] (FLINK-11658) Implement HadoopMapreduceITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11658: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopMapreduceITCase for new Hadoop

[jira] [Assigned] (FLINK-11659) Implement HadoopMapFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11659: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopMapFunctionITCase for new Hadoo

[jira] [Assigned] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11660: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopReduceFunctionITCase for new Ha

[jira] [Assigned] (FLINK-11698) Add readMapRedTextFile API for HadoopInputs

2019-02-22 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11698: Assignee: TANG Wen-hui (was: vinoyang) > Add readMapRedTextFile API for HadoopInputs > -

[jira] [Updated] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Summary: Add readMapReduceTextFile API for HadoopInputs (was: Add readTextFile API for org.apac

[jira] [Updated] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Description: Considering that {{TextInputFormat}} is a very common {{InputFormat}}, I think it's

[jira] [Updated] (FLINK-11697) Add readTextFile API for org.apache.hadoop.mapreduce.lib.input.TextInputFormat in HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Description: Considering that {{TextInputFormat}} is a very common {{InputFormat}}, I think it's

[jira] [Updated] (FLINK-11697) Add readTextFile API for org.apache.hadoop.mapreduce.lib.input.TextInputFormat in HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Summary: Add readTextFile API for org.apache.hadoop.mapreduce.lib.input.TextInputFormat in Hadoo

[jira] [Updated] (FLINK-11697) Add readTextFile API for HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Summary: Add readTextFile API for HadoopInputs (was: Add readMapReduceTextFile API for HadoopIn

[jira] [Updated] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Summary: Add readMapReduceTextFile API for HadoopInputs (was: Add readTextFile API for HadoopIn

[jira] [Assigned] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11697: Assignee: TANG Wen-hui (was: vinoyang) > Add readMapReduceTextFile API for HadoopInputs

[jira] [Updated] (FLINK-11697) Add readTextFile API for HadoopInputs

2019-02-21 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui updated FLINK-11697: - Summary: Add readTextFile API for HadoopInputs (was: Add readMapReduceTextFile API for HadoopIn

[jira] [Assigned] (FLINK-11616) Flink official document has an error

2019-02-20 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11616: Assignee: TANG Wen-hui (was: xulinjie) > Flink official document has an error >

[jira] [Assigned] (FLINK-11616) Flink official document has an error

2019-02-20 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11616: Assignee: xulinjie (was: TANG Wen-hui) > Flink official document has an error >

[jira] [Assigned] (FLINK-11399) Parsing nested ROW()s in SQL

2019-02-01 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11399: Assignee: TANG Wen-hui > Parsing nested ROW()s in SQL > > >

[jira] [Assigned] (FLINK-11433) JOIN on a table having a column of type MULTISET gives a NPE

2019-02-01 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11433: Assignee: TANG Wen-hui > JOIN on a table having a column of type MULTISET gives a NPE >

[jira] [Assigned] (FLINK-10183) Processing-Time based windows aren't emitted when a finite stream ends

2019-02-01 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-10183: Assignee: TANG Wen-hui > Processing-Time based windows aren't emitted when a finite strea

[jira] [Created] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException

2019-01-15 Thread TANG Wen-hui (JIRA)
TANG Wen-hui created FLINK-11326: Summary: Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException Key: FLINK-11326 URL: https://issues.apache.org/jira/browse/FLINK-11326 Pr

[jira] [Assigned] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

2019-01-06 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-8951: --- Assignee: TANG Wen-hui > Support OVER windows PARTITION BY (rounded) timestamp > ---

[jira] [Assigned] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic

2019-01-06 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-10489: Assignee: TANG Wen-hui > Inconsistent window information for streams with EventTime chara