[jira] [Commented] (FLINK-34633) Support unnesting array constants

[ https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853436#comment-17853436 ] Jeyhun Karimov commented on FLINK-34633: Hi [~fanrui]  Yes, considering that pa

[jira] [Comment Edited] (FLINK-34633) Support unnesting array constants

[ https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853436#comment-17853436 ] Jeyhun Karimov edited comment on FLINK-34633 at 6/8/24 9:35 PM: --

[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

[ https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848618#comment-17848618 ] Jeyhun Karimov commented on FLINK-35417: Hi [~melin], I echo the comments above.

[jira] [Commented] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846759#comment-17846759 ] Jeyhun Karimov commented on FLINK-35289:   {code:java} carData.assignTimestampsA

[jira] [Commented] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846631#comment-17846631 ] Jeyhun Karimov commented on FLINK-35289: Hi [~ekanthi] could you please provide

[jira] [Reopened] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reopened FLINK-34379: Reopening because of patch needed, as a result of the comment: https://github.com/apache/flin

[jira] [Commented] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840752#comment-17840752 ] Jeyhun Karimov commented on FLINK-34902: Hi [~twalthr] sure, I will check the is

[jira] [Commented] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format

[ https://issues.apache.org/jira/browse/FLINK-35098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836868#comment-17836868 ] Jeyhun Karimov commented on FLINK-35098: Hi [~empathy87] sorry, I have been work

[jira] [Commented] (FLINK-31163) Unexpected correlate variable $cor0 in the plan error in where clause

[ https://issues.apache.org/jira/browse/FLINK-31163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835878#comment-17835878 ] Jeyhun Karimov commented on FLINK-31163: When I tried to reproduce the issue (as

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833919#comment-17833919 ] Jeyhun Karimov commented on FLINK-32513: Hi [~martijnvisser]  Thanks for reporti

[jira] [Updated] (FLINK-34924) Support partition pushdown for join queries

[ https://issues.apache.org/jira/browse/FLINK-34924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34924: --- Description: Consider the following tables:  {code:java} create table partitionedTable1 (

[jira] [Created] (FLINK-34924) Support partition pushdown for join queries

Jeyhun Karimov created FLINK-34924: -- Summary: Support partition pushdown for join queries Key: FLINK-34924 URL: https://issues.apache.org/jira/browse/FLINK-34924 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-32367) lead function second param cause ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-32367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825031#comment-17825031 ] Jeyhun Karimov commented on FLINK-32367: Hi [~zhou_yb] when I tried to reproduce

[jira] [Commented] (FLINK-33579) Join sql error

[ https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825027#comment-17825027 ] Jeyhun Karimov commented on FLINK-33579: Hi [~waywtdcc] when I tried to reproduc

[jira] [Commented] (FLINK-32679) Filter conditions cannot be pushed to JOIN in some case

[ https://issues.apache.org/jira/browse/FLINK-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824995#comment-17824995 ] Jeyhun Karimov commented on FLINK-32679: Hi [~grandfisher] the mentioned query d

[jira] [Comment Edited] (FLINK-32998) if function result not correct

[ https://issues.apache.org/jira/browse/FLINK-32998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824988#comment-17824988 ] Jeyhun Karimov edited comment on FLINK-32998 at 3/9/24 10:25 PM: -

[jira] [Commented] (FLINK-32998) if function result not correct

[ https://issues.apache.org/jira/browse/FLINK-32998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824988#comment-17824988 ] Jeyhun Karimov commented on FLINK-32998: [~martijnvisser] I verified that as of

[jira] [Commented] (FLINK-34535) Support JobPlanInfo for the explain result

[ https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822456#comment-17822456 ] Jeyhun Karimov commented on FLINK-34535: Hi [~heigebupahei] +1 for FLIP, since t

[jira] [Commented] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822311#comment-17822311 ] Jeyhun Karimov commented on FLINK-29370: Hi [~tanjialiang] you might need to con

[jira] [Commented] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818489#comment-17818489 ] Jeyhun Karimov commented on FLINK-34459: Yes that makes sense. Sure thing > Res

[jira] [Comment Edited] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818440#comment-17818440 ] Jeyhun Karimov edited comment on FLINK-34459 at 2/19/24 10:15 AM:

[jira] [Commented] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818440#comment-17818440 ] Jeyhun Karimov commented on FLINK-34459: Hi [~martijnvisser] yes, there are some

[jira] [Updated] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34459: --- Description: When printing {{SQL SELECT}} results, Flink will output generated expression n

[jira] [Created] (FLINK-34459) Results column names should match SELECT clause expression names

Jeyhun Karimov created FLINK-34459: -- Summary: Results column names should match SELECT clause expression names Key: FLINK-34459 URL: https://issues.apache.org/jira/browse/FLINK-34459 Project: Flink

[jira] [Updated] (FLINK-34446) SqlValidatorException with LATERAL TABLE and JOIN

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Description: found one regression issue. Query working Flink 1.17.2, but failing with Flink

[jira] [Updated] (FLINK-34446) SqlValidatorException with LATERAL TABLE and JOIN

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Description: found one regression issue. Query working Flink 1.17.2, but failing with Flink

[jira] [Updated] (FLINK-34446) SqlValidatorException with LATERAL TABLE and JOIN

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Summary: SqlValidatorException with LATERAL TABLE and JOIN (was: SqlValidatorException with

[jira] [Updated] (FLINK-34446) SqlValidatorException with

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Summary: SqlValidatorException with (was: regression: alias is not supported in lateral jo

[jira] [Updated] (FLINK-34446) SqlValidatorException with Lateral Table and CROSS JOIN

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Summary: SqlValidatorException with Lateral Table and CROSS JOIN (was: SQL) > SqlValidatorE

[jira] [Updated] (FLINK-34446) SQL

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Summary: SQL (was: regression: alias is not in lateral join) > SQL > --- > >

[jira] [Updated] (FLINK-34446) regression: alias is not in lateral join

[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34446: --- Description: found one regression issue. Query working Flink 1.17.2, but failing with Flink

[jira] [Updated] (FLINK-34442) Support optimizations for pre-partitioned [external] data sources

[ https://issues.apache.org/jira/browse/FLINK-34442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34442: --- Description: There are some use-cases in which data sources are pre-partitioned: - Kafka br

[jira] [Created] (FLINK-34442) Support optimizations for pre-partitioned [external] data sources

Jeyhun Karimov created FLINK-34442: -- Summary: Support optimizations for pre-partitioned [external] data sources Key: FLINK-34442 URL: https://issues.apache.org/jira/browse/FLINK-34442 Project: Flink

[jira] [Commented] (FLINK-34378) Minibatch join disrupted the original order of input records

[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816252#comment-17816252 ] Jeyhun Karimov commented on FLINK-34378: Hi [~xuyangzhong] the ordering is diffe

[jira] [Commented] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816250#comment-17816250 ] Jeyhun Karimov commented on FLINK-34129: Hi [~loserwang1024], [~xuyangzhong] I

[jira] [Comment Edited] (FLINK-34366) Add support to group rows by column ordinals

[ https://issues.apache.org/jira/browse/FLINK-34366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814898#comment-17814898 ] Jeyhun Karimov edited comment on FLINK-34366 at 2/6/24 5:10 PM: --

[jira] [Commented] (FLINK-34366) Add support to group rows by column ordinals

[ https://issues.apache.org/jira/browse/FLINK-34366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814898#comment-17814898 ] Jeyhun Karimov commented on FLINK-34366: Hi [~martijnvisser] I worked on this is

[jira] [Commented] (FLINK-33790) Upsert statement filter unique key field colume in mysql dielact

[ https://issues.apache.org/jira/browse/FLINK-33790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814125#comment-17814125 ] Jeyhun Karimov commented on FLINK-33790: Hi [~lijingwei.5018] thanks for reporti

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813995#comment-17813995 ] Jeyhun Karimov commented on FLINK-33989: Hi [~flaviu.cicio], with the latest ver

[jira] [Commented] (FLINK-33996) Support disabling project rewrite when multiple exprs in the project reference the same sub project field.

[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811594#comment-17811594 ] Jeyhun Karimov commented on FLINK-33996: Hi [~libenchao] Thanks for your comment

[jira] [Commented] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810104#comment-17810104 ] Jeyhun Karimov commented on FLINK-34135: Hi [~mapohl] yes CI seems stable again,

[jira] [Closed] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov closed FLINK-34135. -- Resolution: Fixed > A number of ci failures with Access to the path > '.../_work/_temp/contai

[jira] [Closed] (FLINK-34098) Not enough Azure Pipeline CI runners available?

[ https://issues.apache.org/jira/browse/FLINK-34098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov closed FLINK-34098. -- Resolution: Fixed It was a disk-full issue. I reported the recurring error (that leads to the

[jira] [Commented] (FLINK-34155) Recurring SqlExecutionException

[ https://issues.apache.org/jira/browse/FLINK-34155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808539#comment-17808539 ] Jeyhun Karimov commented on FLINK-34155: Hi [~lincoln.86xy] for example {{org.a

[jira] [Created] (FLINK-34155) Recurring SqlExecutionException

Jeyhun Karimov created FLINK-34155: -- Summary: Recurring SqlExecutionException Key: FLINK-34155 URL: https://issues.apache.org/jira/browse/FLINK-34155 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-33996) Support disabling project rewrite when multiple exprs in the project reference the same sub project field.

[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803626#comment-17803626 ] Jeyhun Karimov commented on FLINK-33996: Thanks for reporting the issue [~hacker

[jira] [Commented] (FLINK-33446) SubQueryAntiJoinTest#testMultiNotExistsWithCorrelatedOnWhere_NestedCorrelation doesn't produce the correct plan

[ https://issues.apache.org/jira/browse/FLINK-33446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802090#comment-17802090 ] Jeyhun Karimov commented on FLINK-33446: Hi [~fsk119] I scanned through the issu

[jira] [Commented] (FLINK-33756) Missing record with CUMULATE/HOP windows using an optimization

[ https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796939#comment-17796939 ] Jeyhun Karimov commented on FLINK-33756: [~jhughes] Yes it is just printing/logg

[jira] [Commented] (FLINK-33756) Missing record with CUMULATE/HOP windows using an optimization

[ https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796372#comment-17796372 ] Jeyhun Karimov commented on FLINK-33756: Hi [~jhughes] I had a chance to look at

[jira] [Commented] (FLINK-33622) table.optimizer.reuse-sub-plan-enabled doesn't work when a Table is converted to a DataStream

[ https://issues.apache.org/jira/browse/FLINK-33622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794590#comment-17794590 ] Jeyhun Karimov commented on FLINK-33622: Hi [~sap1ens] thanks for reporting the

[jira] [Commented] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793590#comment-17793590 ] Jeyhun Karimov commented on FLINK-33666: Hi [~twalthr] can you please assign thi

[jira] [Commented] (FLINK-33670) Public operators cannot be reused in multi sinks

[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793232#comment-17793232 ] Jeyhun Karimov commented on FLINK-33670: Hi [~zicat] I tried with Flink master b

[jira] [Commented] (FLINK-32986) The new createTemporaryFunction has some regression of type inference compare to the deprecated registerFunction

[ https://issues.apache.org/jira/browse/FLINK-32986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792406#comment-17792406 ] Jeyhun Karimov commented on FLINK-32986: Hi [~lincoln.86xy]  could you please as

[jira] [Commented] (FLINK-31481) Support enhanced show databases syntax

[ https://issues.apache.org/jira/browse/FLINK-31481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792404#comment-17792404 ] Jeyhun Karimov commented on FLINK-31481: Hi [~taoran] could you please assign th

[jira] [Commented] (FLINK-33523) DataType ARRAY fails to cast into Object[]

[ https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789113#comment-17789113 ] Jeyhun Karimov commented on FLINK-33523: Hi [~prabhujoseph] thanks for reporting

[jira] [Commented] (FLINK-33547) SQL primitive array type after upgrading to Flink 1.18.0

[ https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789111#comment-17789111 ] Jeyhun Karimov commented on FLINK-33547: Hi [~xccui], the mismatch occurs depend

[jira] [Commented] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF

[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778478#comment-17778478 ] Jeyhun Karimov commented on FLINK-32940: Hi [~vsowrirajan] [~337361...@qq.com] [

[jira] [Updated] (FLINK-3177) Add Stream Operator that Discards Late Elements

[ https://issues.apache.org/jira/browse/FLINK-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-3177: -- Assignee: (was: Jeyhun Karimov) > Add Stream Operator that Discards Late Elements >

[jira] [Updated] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

[ https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-2390: -- Assignee: (was: Jeyhun Karimov) > Replace iteration timeout with algorithm for detecting ter

[jira] [Updated] (FLINK-2184) Cannot get last element with maxBy/minBy

[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-2184: -- Assignee: (was: Jeyhun Karimov) > Cannot get last element with maxBy/minBy > ---

[jira] [Updated] (FLINK-1509) Streaming Group Reduce Combiner

[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-1509: -- Assignee: (was: Jeyhun Karimov) > Streaming Group Reduce Combiner >

[jira] [Issue Comment Deleted] (FLINK-1509) Streaming Group Reduce Combiner

[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-1509: -- Comment: was deleted (was: I will give a try to this problem) > Streaming Group Reduce Combiner

[jira] [Assigned] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

[ https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned FLINK-2390: - Assignee: Jeyhun Karimov > Replace iteration timeout with algorithm for detecting termina

[jira] [Assigned] (FLINK-3177) Add Stream Operator that Discards Late Elements

[ https://issues.apache.org/jira/browse/FLINK-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned FLINK-3177: - Assignee: Jeyhun Karimov > Add Stream Operator that Discards Late Elements >

[jira] [Assigned] (FLINK-1509) Streaming Group Reduce Combiner

[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned FLINK-1509: - Assignee: Jeyhun Karimov > Streaming Group Reduce Combiner >

[jira] [Commented] (FLINK-1509) Streaming Group Reduce Combiner

[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123577#comment-15123577 ] Jeyhun Karimov commented on FLINK-1509: --- I will give a try to this problem > Stream

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123469#comment-15123469 ] Jeyhun Karimov commented on FLINK-2184: --- If no one is working on this issue, I can g

[jira] [Issue Comment Deleted] (FLINK-3089) OperatorState timeout

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-3089: -- Comment: was deleted (was: If nobody works on this issue, I would like to give a try.) > Operat

[jira] [Commented] (FLINK-3089) OperatorState timeout

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123391#comment-15123391 ] Jeyhun Karimov commented on FLINK-3089: --- If nobody works on this issue, I would like