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:
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:
wangsan created FLINK-20624:
---
Summary: Refactor StreamExecJoinRule、StreamExecIntervalJoinRule
and StreamExecTemporalJoinRule
Key: FLINK-20624
URL: https://issues.apache.org/jira/browse/FLINK-20624
Project:
wangsan created FLINK-20624:
---
Summary: Refactor StreamExecJoinRule、StreamExecIntervalJoinRule
and StreamExecTemporalJoinRule
Key: FLINK-20624
URL: https://issues.apache.org/jira/browse/FLINK-20624
Project:
[
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
[
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
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
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
[
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.
wangsan created FLINK-15548:
---
Summary: Make KeyedCoProcessOperatorWithWatermarkDelay extends
KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator
Key: FLINK-15548
URL:
wangsan created FLINK-15548:
---
Summary: Make KeyedCoProcessOperatorWithWatermarkDelay extends
KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator
Key: FLINK-15548
URL:
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
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
[
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
>
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
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
[
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.
>
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
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
[
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
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
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
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
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
[
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
>
[
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
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
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
[
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
>
[
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
>
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
31 matches
Mail list logo