[jira] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

[ https://issues.apache.org/jira/browse/FLINK-28530 ] Alexander Trushev deleted comment on FLINK-28530: --- was (Author: trushev): Please assign this ticket to me > Improvement of extraction of conditions that can be pushed into join inputs

[jira] [Closed] (FLINK-28567) Introduce predicate inference from one side of join to the other

[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev closed FLINK-28567. - Resolution: Duplicate > Introduce predicate inference from one side of join to the other

[jira] [Commented] (FLINK-28567) Introduce predicate inference from one side of join to the other

[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579524#comment-17579524 ] Alexander Trushev commented on FLINK-28567: --- It looks like [~godfreyhe] have i

[jira] [Comment Edited] (FLINK-28567) Introduce predicate inference from one side of join to the other

[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579524#comment-17579524 ] Alexander Trushev edited comment on FLINK-28567 at 8/15/22 4:31 AM: --

[jira] [Commented] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

[ https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569238#comment-17569238 ] Alexander Trushev commented on FLINK-28530: --- Please assign this ticket to me

[jira] [Commented] (FLINK-24342) Filesystem sink does not escape right bracket in partition name

[ https://issues.apache.org/jira/browse/FLINK-24342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567792#comment-17567792 ] Alexander Trushev commented on FLINK-24342: --- Can this ticket be reviewed pleas

[jira] [Updated] (FLINK-24342) Filesystem sink does not escape right bracket in partition name

[ https://issues.apache.org/jira/browse/FLINK-24342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-24342: -- Priority: Minor (was: Not a Priority) > Filesystem sink does not escape right bracket

[jira] [Updated] (FLINK-24342) Filesystem sink does not escape right bracket in partition name

[ https://issues.apache.org/jira/browse/FLINK-24342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-24342: -- Description: h3. How to reproduce the problem In the following code snippet filesyste

[jira] [Updated] (FLINK-28567) Introduce predicate inference from one side of join to the other

[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-28567: -- Description: h2. Context There is JoinPushTransitivePredicatesRule in Calcite that in

[jira] [Updated] (FLINK-28567) Introduce predicate inference from one side of join to the other

[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-28567: -- Description: h2. Context There is JoinPushTransitivePredicatesRule in Calcite that in

[jira] [Created] (FLINK-28567) Introduce predicate inference from one side of join to the other

Alexander Trushev created FLINK-28567: - Summary: Introduce predicate inference from one side of join to the other Key: FLINK-28567 URL: https://issues.apache.org/jira/browse/FLINK-28567 Project: F

[jira] [Updated] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

[ https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-28530: -- Description: Conditions extraction in batch mode was introduced here FLINK-12509 and i

[jira] [Updated] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

[ https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-28530: -- Description: Conditions extraction in batch mode was introduced here FLINK-12509 and i

[jira] [Updated] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

[ https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-28530: -- Summary: Improvement of extraction of conditions that can be pushed into join inputs

[jira] [Created] (FLINK-28530) Improvement of conditions extraction that can be pushed into join inputs

Alexander Trushev created FLINK-28530: - Summary: Improvement of conditions extraction that can be pushed into join inputs Key: FLINK-28530 URL: https://issues.apache.org/jira/browse/FLINK-28530 Pr

[jira] [Created] (FLINK-24459) Performance improvement of file sink on Nexmark

Alexander Trushev created FLINK-24459: - Summary: Performance improvement of file sink on Nexmark Key: FLINK-24459 URL: https://issues.apache.org/jira/browse/FLINK-24459 Project: Flink Iss

[jira] [Created] (FLINK-24342) Filesystem sink does not escape right bracket in partition name

Alexander Trushev created FLINK-24342: - Summary: Filesystem sink does not escape right bracket in partition name Key: FLINK-24342 URL: https://issues.apache.org/jira/browse/FLINK-24342 Project: Fl

[jira] [Updated] (FLINK-24139) Push down more predicates through Join in stream mode

[ https://issues.apache.org/jira/browse/FLINK-24139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-24139: -- Description: h3. Context Rule {{JoinDependentConditionDerivationRule}} is introduced

[jira] [Created] (FLINK-24139) Push down more predicates through Join in stream mode

Alexander Trushev created FLINK-24139: - Summary: Push down more predicates through Join in stream mode Key: FLINK-24139 URL: https://issues.apache.org/jira/browse/FLINK-24139 Project: Flink

[jira] [Comment Edited] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243716#comment-17243716 ] Alexander Trushev edited comment on FLINK-20208 at 12/4/20, 6:15 AM: -

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243716#comment-17243716 ] Alexander Trushev commented on FLINK-20208: --- [~gaoyunhaii], very thank you for

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240693#comment-17240693 ] Alexander Trushev commented on FLINK-20208: --- Is there anything to add to the p

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237296#comment-17237296 ] Alexander Trushev commented on FLINK-20208: --- Hi [~gaoyunhaii] . I have checked

[jira] [Updated] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-20208: -- Description: Assume a job has StreamingFileSink with OnCheckpointRollingPolicy In the

[jira] [Comment Edited] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235441#comment-17235441 ] Alexander Trushev edited comment on FLINK-20208 at 11/19/20, 1:02 PM:

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235441#comment-17235441 ] Alexander Trushev commented on FLINK-20208: --- [~gaoyunhaii]  You are right. I n

[jira] [Comment Edited] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235419#comment-17235419 ] Alexander Trushev edited comment on FLINK-20208 at 11/19/20, 12:48 PM: ---

[jira] [Comment Edited] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235419#comment-17235419 ] Alexander Trushev edited comment on FLINK-20208 at 11/19/20, 12:48 PM: ---

[jira] [Comment Edited] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235419#comment-17235419 ] Alexander Trushev edited comment on FLINK-20208 at 11/19/20, 12:41 PM: ---

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235419#comment-17235419 ] Alexander Trushev commented on FLINK-20208: --- The first issue. I tested my pro

[jira] [Updated] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-20208: -- Description: Assume a job has StreamingFileSink with OnCheckpointRollingPolicy In the

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234844#comment-17234844 ] Alexander Trushev commented on FLINK-20208: --- Hello [~gaoyunhaii]. The second

[jira] [Created] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

Alexander Trushev created FLINK-20208: - Summary: Remove outdated in-progress files in StreamingFileSink Key: FLINK-20208 URL: https://issues.apache.org/jira/browse/FLINK-20208 Project: Flink