[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2024-03-11 Thread lincoln lee (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lincoln lee updated FLINK-17337:

Fix Version/s: (was: 1.19.0)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major, pull-request-available
> Fix For: 1.20.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2024-03-11 Thread lincoln lee (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lincoln lee updated FLINK-17337:

Fix Version/s: 1.20.0

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major, pull-request-available
> Fix For: 1.19.0, 1.20.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2023-10-13 Thread Jing Ge (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jing Ge updated FLINK-17337:

Fix Version/s: 1.19.0
   (was: 1.18.0)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major, pull-request-available
> Fix For: 1.19.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2023-04-04 Thread ASF GitHub Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-17337:
---
Labels: auto-deprioritized-major pull-request-available  (was: 
auto-deprioritized-major)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major, pull-request-available
> Fix For: 1.18.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2023-03-23 Thread Xintong Song (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xintong Song updated FLINK-17337:
-
Fix Version/s: 1.18.0
   (was: 1.17.0)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major
> Fix For: 1.18.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2022-08-22 Thread Xingbo Huang (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xingbo Huang updated FLINK-17337:
-
Fix Version/s: 1.17.0
   (was: 1.16.0)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major
> Fix For: 1.17.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2022-04-13 Thread Yun Gao (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yun Gao updated FLINK-17337:

Fix Version/s: 1.16.0

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major
> Fix For: 1.15.0, 1.16.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2021-10-21 Thread Kurt Young (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Kurt Young updated FLINK-17337:
---
Fix Version/s: 1.15.0

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major
> Fix For: 1.15.0
>
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



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

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2021-04-29 Thread Flink Jira Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Flink Jira Bot updated FLINK-17337:
---
Priority: Minor  (was: Major)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Minor
>  Labels: auto-deprioritized-major
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



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

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2021-04-29 Thread Flink Jira Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Flink Jira Bot updated FLINK-17337:
---
Labels: auto-deprioritized-major  (was: stale-major)

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Major
>  Labels: auto-deprioritized-major
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



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

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2021-04-22 Thread Flink Jira Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Flink Jira Bot updated FLINK-17337:
---
Labels: stale-major  (was: )

> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
> 
>
> Key: FLINK-17337
> URL: https://issues.apache.org/jira/browse/FLINK-17337
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / Runtime
>Reporter: Jark Wu
>Priority: Major
>  Labels: stale-major
>
> Currently, streaming join operator always send INSERT and DELETE messages for 
> simplification if it's not inner join. However, we can send UPDATE_BEFORE and 
> UPDATE_AFTER messages instead of INSERT and DELETE. For example, when we 
> recieve right record "b", then we can send {{UB[a, null]}} and {{UA[a,b]}} 
> instead of {{D[a,null]}}, {{I[a,b]}}. This is an optimization, because UB can 
> be omitted in some cases to reduce IO cost and computation. 



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