[jira] [Created] (FLINK-20768) Support routing field for Elasticsearch connector

2020-12-25 Thread wangsan (Jira)
wangsan created FLINK-20768: --- Summary: Support routing field for Elasticsearch connector Key: FLINK-20768 URL: https://issues.apache.org/jira/browse/FLINK-20768 Project: Flink Issue Type:

[jira] [Created] (FLINK-20768) Support routing field for Elasticsearch connector

2020-12-25 Thread wangsan (Jira)
wangsan created FLINK-20768: --- Summary: Support routing field for Elasticsearch connector Key: FLINK-20768 URL: https://issues.apache.org/jira/browse/FLINK-20768 Project: Flink Issue Type:

[jira] [Created] (FLINK-20624) Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-16 Thread wangsan (Jira)
wangsan created FLINK-20624: --- Summary: Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule Key: FLINK-20624 URL: https://issues.apache.org/jira/browse/FLINK-20624 Project:

[jira] [Created] (FLINK-20624) Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-16 Thread wangsan (Jira)
wangsan created FLINK-20624: --- Summary: Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule Key: FLINK-20624 URL: https://issues.apache.org/jira/browse/FLINK-20624 Project:

[jira] [Commented] (FLINK-18596) Derive format schema from table schema may get error result

2020-07-14 Thread wangsan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157334#comment-17157334 ] wangsan commented on FLINK-18596: - I would like to fix this issue > Derive format schema from table

[jira] [Updated] (FLINK-18596) Derive format schema from table schema may get error result

2020-07-14 Thread wangsan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan updated FLINK-18596: Description: If rowtime attribute references a regular field, derive format schema from table schema may

[jira] [Created] (FLINK-18596) Derive format schema from table schema may get error result

2020-07-14 Thread wangsan (Jira)
wangsan created FLINK-18596: --- Summary: Derive format schema from table schema may get error result Key: FLINK-18596 URL: https://issues.apache.org/jira/browse/FLINK-18596 Project: Flink Issue

[jira] [Created] (FLINK-18596) Derive format schema from table schema may get error result

2020-07-14 Thread wangsan (Jira)
wangsan created FLINK-18596: --- Summary: Derive format schema from table schema may get error result Key: FLINK-18596 URL: https://issues.apache.org/jira/browse/FLINK-18596 Project: Flink Issue

[jira] [Commented] (FLINK-16710) Log Upload blocks Main Thread in TaskExecutor

2020-03-29 Thread wangsan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070661#comment-17070661 ] wangsan commented on FLINK-16710: - Hi [~gjy], I can help with this issue if no one is working on this.

[jira] [Created] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

2020-01-10 Thread wangsan (Jira)
wangsan created FLINK-15548: --- Summary: Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator Key: FLINK-15548 URL:

[jira] [Created] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

2020-01-10 Thread wangsan (Jira)
wangsan created FLINK-15548: --- Summary: Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator Key: FLINK-15548 URL:

[jira] [Created] (FLINK-13823) Incorrect debug log in CompileUtils

2019-08-23 Thread wangsan (Jira)
wangsan created FLINK-13823: --- Summary: Incorrect debug log in CompileUtils Key: FLINK-13823 URL: https://issues.apache.org/jira/browse/FLINK-13823 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13823) Incorrect debug log in CompileUtils

2019-08-23 Thread wangsan (Jira)
wangsan created FLINK-13823: --- Summary: Incorrect debug log in CompileUtils Key: FLINK-13823 URL: https://issues.apache.org/jira/browse/FLINK-13823 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-11687) Remove useless code in StreamingJobGraphGenerator

2019-02-20 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan closed FLINK-11687. --- Resolution: Fixed > Remove useless code in StreamingJobGraphGenerator >

[jira] [Created] (FLINK-11687) Remove useless code in StreamingJobGraphGenerator

2019-02-20 Thread wangsan (JIRA)
wangsan created FLINK-11687: --- Summary: Remove useless code in StreamingJobGraphGenerator Key: FLINK-11687 URL: https://issues.apache.org/jira/browse/FLINK-11687 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11687) Remove useless code in StreamingJobGraphGenerator

2019-02-20 Thread wangsan (JIRA)
wangsan created FLINK-11687: --- Summary: Remove useless code in StreamingJobGraphGenerator Key: FLINK-11687 URL: https://issues.apache.org/jira/browse/FLINK-11687 Project: Flink Issue Type: Task

[jira] [Assigned] (FLINK-10770) Some generated functions are not opened properly.

2018-11-03 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan reassigned FLINK-10770: --- Assignee: wangsan > Some generated functions are not opened properly. >

[jira] [Created] (FLINK-10770) Some generated functions are not opened properly.

2018-11-03 Thread wangsan (JIRA)
wangsan created FLINK-10770: --- Summary: Some generated functions are not opened properly. Key: FLINK-10770 URL: https://issues.apache.org/jira/browse/FLINK-10770 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10770) Some generated functions are not opened properly.

2018-11-03 Thread wangsan (JIRA)
wangsan created FLINK-10770: --- Summary: Some generated functions are not opened properly. Key: FLINK-10770 URL: https://issues.apache.org/jira/browse/FLINK-10770 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-10553) Unified sink and source table name in SQL statement

2018-10-15 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan updated FLINK-10553: Summary: Unified sink and source table name in SQL statement (was: Unified table sink and source name in

[jira] [Created] (FLINK-10553) Unified table sink and source name in SQL statement

2018-10-15 Thread wangsan (JIRA)
wangsan created FLINK-10553: --- Summary: Unified table sink and source name in SQL statement Key: FLINK-10553 URL: https://issues.apache.org/jira/browse/FLINK-10553 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10553) Unified table sink and source name in SQL statement

2018-10-15 Thread wangsan (JIRA)
wangsan created FLINK-10553: --- Summary: Unified table sink and source name in SQL statement Key: FLINK-10553 URL: https://issues.apache.org/jira/browse/FLINK-10553 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10290) Conversion error in StreamScan and BatchScan

2018-09-06 Thread wangsan (JIRA)
wangsan created FLINK-10290: --- Summary: Conversion error in StreamScan and BatchScan Key: FLINK-10290 URL: https://issues.apache.org/jira/browse/FLINK-10290 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10290) Conversion error in StreamScan and BatchScan

2018-09-06 Thread wangsan (JIRA)
wangsan created FLINK-10290: --- Summary: Conversion error in StreamScan and BatchScan Key: FLINK-10290 URL: https://issues.apache.org/jira/browse/FLINK-10290 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-10290) Conversion error in StreamScan and BatchScan

2018-09-06 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan reassigned FLINK-10290: --- Assignee: wangsan > Conversion error in StreamScan and BatchScan >

[jira] [Commented] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

2018-07-10 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539468#comment-16539468 ] wangsan commented on FLINK-9794: Hi [~yanghua], I've opened a pull request for this issue, it would be

[jira] [Created] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

2018-07-10 Thread wangsan (JIRA)
wangsan created FLINK-9794: -- Summary: JDBCOutputFormat does not consider idle connection and multithreads synchronization Key: FLINK-9794 URL: https://issues.apache.org/jira/browse/FLINK-9794 Project: Flink

[jira] [Created] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

2018-07-10 Thread wangsan (JIRA)
wangsan created FLINK-9794: -- Summary: JDBCOutputFormat does not consider idle connection and multithreads synchronization Key: FLINK-9794 URL: https://issues.apache.org/jira/browse/FLINK-9794 Project: Flink

[jira] [Resolved] (SPARK-22503) Using current processing time to generate windows in streaming processing

2018-07-10 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan resolved SPARK-22503. - Resolution: Not A Problem > Using current processing time to generate windows in streaming processing >

[jira] [Updated] (SPARK-22503) Using current processing time to generate windows in streaming processing

2017-11-12 Thread wangsan (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsan updated SPARK-22503: Affects Version/s: 2.2.0 > Using current processing time to generate windows in streaming processing >

[jira] [Created] (SPARK-22503) Using current processing time to generate windows in streaming processing

2017-11-12 Thread wangsan (JIRA)
wangsan created SPARK-22503: --- Summary: Using current processing time to generate windows in streaming processing Key: SPARK-22503 URL: https://issues.apache.org/jira/browse/SPARK-22503 Project: Spark