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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 6/22/23 9:42 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 6/22/23 9:42 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 6/22/23 9:41 AM: --

[jira] [Closed] (FLINK-27411) Move lookup table source cache logic to flink-table-runtime module

[ https://issues.apache.org/jira/browse/FLINK-27411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov closed FLINK-27411. - Resolution: Workaround > Move lookup table source cache logic to flink-table-runtime mod

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/17/23 4:07 AM: --

[jira] [Comment Edited] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709232#comment-17709232 ] Alexander Smirnov edited comment on FLINK-31729 at 4/6/23 8:02 AM: ---

[jira] [Comment Edited] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709232#comment-17709232 ] Alexander Smirnov edited comment on FLINK-31729 at 4/6/23 7:56 AM: ---

[jira] [Comment Edited] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709232#comment-17709232 ] Alexander Smirnov edited comment on FLINK-31729 at 4/6/23 7:54 AM: ---

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: (was: image-2023-04-06-13-56-21-971.png) > Unexpected UPDATE_BEFORE ou

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: (was: image-2023-04-06-13-55-42-242.png) > Unexpected UPDATE_BEFORE ou

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: (was: image-2023-04-06-13-56-08-998.png) > Unexpected UPDATE_BEFORE ou

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: (was: image-2023-04-06-14-01-07-871.png) > Unexpected UPDATE_BEFORE ou

[jira] [Comment Edited] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709232#comment-17709232 ] Alexander Smirnov edited comment on FLINK-31729 at 4/6/23 7:02 AM: ---

[jira] [Commented] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709232#comment-17709232 ] Alexander Smirnov commented on FLINK-31729: --- [~luoyuxia] Yes, according to the

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: image-2023-04-06-13-56-21-971.png > Unexpected UPDATE_BEFORE output record

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: image-2023-04-06-13-56-08-998.png > Unexpected UPDATE_BEFORE output record

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Attachment: image-2023-04-06-13-55-42-242.png > Unexpected UPDATE_BEFORE output record

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/5/23 7:42 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/5/23 7:42 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/5/23 7:42 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/5/23 7:41 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/5/23 7:41 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov commented on FLINK-17337: --- Hi [~jark]! I've found a [bug|ht

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

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727 ] Alexander Smirnov edited comment on FLINK-17337 at 4/5/23 7:40 AM: ---

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't emit

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't emit

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't emit

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't emit

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't emit

[jira] [Created] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

Alexander Smirnov created FLINK-31729: - Summary: Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Key: FLINK-31729 URL: https://issues.apache.org/jira/browse/FLINK-31729 Project: Flink

[jira] [Created] (FLINK-30778) Add Configuration into FunctionContext

Alexander Smirnov created FLINK-30778: - Summary: Add Configuration into FunctionContext Key: FLINK-30778 URL: https://issues.apache.org/jira/browse/FLINK-30778 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637236#comment-17637236 ] Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 1:37 PM: -

[jira] [Comment Edited] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637236#comment-17637236 ] Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 1:37 PM: -

[jira] [Comment Edited] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637236#comment-17637236 ] Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 12:48 PM:

[jira] [Comment Edited] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637236#comment-17637236 ] Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 12:47 PM:

[jira] [Comment Edited] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637236#comment-17637236 ] Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 12:47 PM:

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637236#comment-17637236 ] Alexander Smirnov commented on FLINK-29427: --- Hi everyone! First of all, I'm ve

[jira] [Comment Edited] (FLINK-19822) Remove redundant shuffle for streaming

[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624953#comment-17624953 ] Alexander Smirnov edited comment on FLINK-19822 at 10/27/22 8:38 AM: -

[jira] [Comment Edited] (FLINK-19822) Remove redundant shuffle for streaming

[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624953#comment-17624953 ] Alexander Smirnov edited comment on FLINK-19822 at 10/27/22 8:37 AM: -

[jira] [Commented] (FLINK-19822) Remove redundant shuffle for streaming

[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624953#comment-17624953 ] Alexander Smirnov commented on FLINK-19822: --- Hi [~godfreyhe]! I was wondering

[jira] [Commented] (FLINK-19822) Remove redundant shuffle for streaming

[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609812#comment-17609812 ] Alexander Smirnov commented on FLINK-19822: --- Hi [~godfreyhe]! I'm wondering wh

[jira] [Commented] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

[ https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600685#comment-17600685 ] Alexander Smirnov commented on FLINK-29093: --- Hi [~hxb]. I made a PR that shoul