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

2024-05-15 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846631#comment-17846631 ] Jeyhun Karimov commented on FLINK-35289: Hi [~ekanthi] could you please provide a concrete

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

2024-05-15 Thread Jeyhun Karimov (Jira)
[ 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:

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

2024-04-25 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840752#comment-17840752 ] Jeyhun Karimov commented on FLINK-34902: Hi [~twalthr] sure, I will check the issue > INSERT

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

2024-04-13 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836868#comment-17836868 ] Jeyhun Karimov commented on FLINK-35098: Hi [~empathy87] sorry, I have been working on the issue

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

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

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

2024-04-04 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833919#comment-17833919 ] Jeyhun Karimov commented on FLINK-32513: Hi [~martijnvisser]  Thanks for reporting it. Would it

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

2024-03-23 Thread Jeyhun Karimov (Jira)
[ 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

2024-03-23 Thread Jeyhun Karimov (Jira)
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:

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

2024-03-10 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825031#comment-17825031 ] Jeyhun Karimov commented on FLINK-32367: Hi [~zhou_yb] when I tried to reproduce with the

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

2024-03-10 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825027#comment-17825027 ] Jeyhun Karimov commented on FLINK-33579: Hi [~waywtdcc] when I tried to reproduce locally as of

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

2024-03-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824995#comment-17824995 ] Jeyhun Karimov commented on FLINK-32679: Hi [~grandfisher] the mentioned query does pushes the

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

2024-03-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2024-03-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824988#comment-17824988 ] Jeyhun Karimov commented on FLINK-32998: [~martijnvisser] I verified that as of master

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

2024-03-01 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822456#comment-17822456 ] Jeyhun Karimov commented on FLINK-34535: Hi [~heigebupahei] +1 for FLIP, since the issue is

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

2024-02-29 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822311#comment-17822311 ] Jeyhun Karimov commented on FLINK-29370: Hi [~tanjialiang] you might need to consider [this

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

2024-02-19 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818489#comment-17818489 ] Jeyhun Karimov commented on FLINK-34459: Yes that makes sense. Sure thing > Results column

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

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

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

2024-02-19 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818440#comment-17818440 ] Jeyhun Karimov commented on FLINK-34459: Hi [~martijnvisser] yes, there are some tradeoffs.

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

2024-02-18 Thread Jeyhun Karimov (Jira)
[ 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

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

2024-02-18 Thread Jeyhun Karimov (Jira)
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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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

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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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

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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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) >

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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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

2024-02-15 Thread Jeyhun Karimov (Jira)
[ 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

2024-02-13 Thread Jeyhun Karimov (Jira)
[ 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

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

2024-02-13 Thread Jeyhun Karimov (Jira)
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

2024-02-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816252#comment-17816252 ] Jeyhun Karimov commented on FLINK-34378: Hi [~xuyangzhong] the ordering is different even with

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

2024-02-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816250#comment-17816250 ] Jeyhun Karimov commented on FLINK-34129: Hi [~loserwang1024], [~xuyangzhong] I am not sure if

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

2024-02-06 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814898#comment-17814898 ] Jeyhun Karimov edited comment on FLINK-34366 at 2/6/24 5:10 PM: Hi

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

2024-02-06 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814898#comment-17814898 ] Jeyhun Karimov commented on FLINK-34366: Hi [~martijnvisser] I worked on this issue. Could you

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

2024-02-04 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814125#comment-17814125 ] Jeyhun Karimov commented on FLINK-33790: Hi [~lijingwei.5018] thanks for reporting this issue.

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

2024-02-03 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813995#comment-17813995 ] Jeyhun Karimov commented on FLINK-33989: Hi [~flaviu.cicio], with the latest version of

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

2024-01-27 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811594#comment-17811594 ] Jeyhun Karimov commented on FLINK-33996: Hi [~libenchao] Thanks for your comment. I agree that

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

2024-01-23 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810104#comment-17810104 ] Jeyhun Karimov commented on FLINK-34135: Hi [~mapohl] yes CI seems stable again, we can close

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

2024-01-23 Thread Jeyhun Karimov (Jira)
[ 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 >

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

2024-01-23 Thread Jeyhun Karimov (Jira)
[ 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

2024-01-19 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808539#comment-17808539 ] Jeyhun Karimov commented on FLINK-34155: Hi [~lincoln.86xy] for example

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

2024-01-18 Thread Jeyhun Karimov (Jira)
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.

2024-01-05 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803626#comment-17803626 ] Jeyhun Karimov commented on FLINK-33996: Thanks for reporting the issue [~hackergin] and thanks

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

2024-01-03 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17802090#comment-17802090 ] Jeyhun Karimov commented on FLINK-33446: Hi [~fsk119] I scanned through the issue a bit. I can

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

2023-12-14 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796939#comment-17796939 ] Jeyhun Karimov commented on FLINK-33756: [~jhughes] Yes it is just printing/logging on various

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

2023-12-13 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796372#comment-17796372 ] Jeyhun Karimov commented on FLINK-33756: Hi [~jhughes] I had a chance to look at the issue. I

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

2023-12-08 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794590#comment-17794590 ] Jeyhun Karimov commented on FLINK-33622: Hi [~sap1ens] thanks for reporting the issue. First,

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

2023-12-06 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793590#comment-17793590 ] Jeyhun Karimov commented on FLINK-33666: Hi [~twalthr] can you please assign this task to me or

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

2023-12-05 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793232#comment-17793232 ] Jeyhun Karimov commented on FLINK-33670: Hi [~zicat] I tried with Flink master branch, below is

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

2023-12-02 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792406#comment-17792406 ] Jeyhun Karimov commented on FLINK-32986: Hi [~lincoln.86xy]  could you please assign this task

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

2023-12-02 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792404#comment-17792404 ] Jeyhun Karimov commented on FLINK-31481: Hi [~taoran] could you please assign this task to me or

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

2023-11-23 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789113#comment-17789113 ] Jeyhun Karimov commented on FLINK-33523: Hi [~prabhujoseph] thanks for reporting the issue. The

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

2023-11-23 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789111#comment-17789111 ] Jeyhun Karimov commented on FLINK-33547: Hi [~xccui], the mismatch occurs depending on the input

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

2023-10-22 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778478#comment-17778478 ] Jeyhun Karimov commented on FLINK-32940: Hi [~vsowrirajan] [~337361...@qq.com] [~lsy] [~jark],

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

2016-02-01 Thread Jeyhun Karimov (JIRA)
[ 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

2016-02-01 Thread Jeyhun Karimov (JIRA)
[ 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

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

2016-02-01 Thread Jeyhun Karimov (JIRA)
[ 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-3177) Add Stream Operator that Discards Late Elements

2016-02-01 Thread Jeyhun Karimov (JIRA)
[ 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

2016-02-01 Thread Jeyhun Karimov (JIRA)
[ 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

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

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123577#comment-15123577 ] Jeyhun Karimov commented on FLINK-1509: --- I will give a try to this problem > Streaming Group Reduce

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

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123469#comment-15123469 ] Jeyhun Karimov commented on FLINK-2184: --- If no one is working on this issue, I can give a try >

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

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123391#comment-15123391 ] Jeyhun Karimov commented on FLINK-3089: --- If nobody works on this issue, I would like to give a try.

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

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ 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.) >

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

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ 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] [Assigned] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ 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