[
https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11142:
---
Assignee: Hequn Cheng
> Undefined behavior in the conversion from DataStream/DataSet to
[
https://issues.apache.org/jira/browse/FLINK-11066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718741#comment-16718741
]
Hequn Cheng commented on FLINK-11066:
-
Hi [~twalthr] , as for {{AppendStreamTableSink}} and
[
https://issues.apache.org/jira/browse/FLINK-11066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718741#comment-16718741
]
Hequn Cheng edited comment on FLINK-11066 at 12/12/18 10:22 AM:
Hi
Hequn Cheng created FLINK-11131:
---
Summary: Enable unused import checkstyle on flink-core and
flink-runtime tests
Key: FLINK-11131
URL: https://issues.apache.org/jira/browse/FLINK-11131
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716146#comment-16716146
]
Hequn Cheng commented on FLINK-11090:
-
Hi [~aljoscha] thanks for telling the differences between
Hequn Cheng created FLINK-11125:
---
Summary: Remove useless import
Key: FLINK-11125
URL: https://issues.apache.org/jira/browse/FLINK-11125
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716116#comment-16716116
]
Hequn Cheng commented on FLINK-10543:
-
[~fhueske] Hi, would be nice if you can take a look at the
Hequn Cheng created FLINK-11124:
---
Summary: Add private[flink] to TemporalTableFunction.create()
Key: FLINK-11124
URL: https://issues.apache.org/jira/browse/FLINK-11124
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716015#comment-16716015
]
Hequn Cheng commented on FLINK-11070:
-
[~fhueske] Thanks for your quick reply!
Ok, I got your
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715884#comment-16715884
]
Hequn Cheng commented on FLINK-11070:
-
[~fhueske] Hi, thanks for the feedback and sharing the
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715884#comment-16715884
]
Hequn Cheng edited comment on FLINK-11070 at 12/11/18 1:06 AM:
---
[~fhueske]
Hequn Cheng created FLINK-11090:
---
Summary: Unused parameter in WindowedStream.aggregate()
Key: FLINK-11090
URL: https://issues.apache.org/jira/browse/FLINK-11090
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712251#comment-16712251
]
Hequn Cheng commented on FLINK-11065:
-
[~twalthr] Sounds great. Smaller PRs are better and easier to
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710889#comment-16710889
]
Hequn Cheng commented on FLINK-11065:
-
[~twalthr] Hi, thanks for driving this. I think we would
[
https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709612#comment-16709612
]
Hequn Cheng commented on FLINK-10776:
-
[~yanghua] Hi, thanks for your contribution. However, I've
[
https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708682#comment-16708682
]
Hequn Cheng commented on FLINK-10978:
-
The code of this task is ready now. I implement it base on
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11070:
Description:
Currently, we don't reorder join and rely on the order provided by the user.
This
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11070:
Description:
Currently, we don't reorder join and rely on the order provided by the user.
This
[
https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708626#comment-16708626
]
Hequn Cheng commented on FLINK-11020:
-
[~fhueske] Opening another Jira is a good idea. Sorry that I
Hequn Cheng created FLINK-11070:
---
Summary: Add stream-stream non-window cross join
Key: FLINK-11070
URL: https://issues.apache.org/jira/browse/FLINK-11070
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-10977:
Summary: Add FlatAggregate operator to unbounded streaming Table API (was:
Add UnBounded
[
https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-10978:
Summary: Add FlatAggregate operator to batch Table API (was: Add UnBounded
FlatAggregate
[
https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708095#comment-16708095
]
Hequn Cheng commented on FLINK-11020:
-
Hi [~fhueske] [~twalthr] Yes, I agree that we should not do
[
https://issues.apache.org/jira/browse/FLINK-11051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11051:
---
Assignee: Hequn Cheng
> Add Bounded(Group Window) FlatAggregate operator to streaming
[
https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706580#comment-16706580
]
Hequn Cheng commented on FLINK-11020:
-
Maybe we can implement cross join with parallelism of 1? For
[
https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706574#comment-16706574
]
Hequn Cheng commented on FLINK-6441:
I tested it in an ITCase. It seems the issue has not been fixed?
[
https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11045:
Description:
We should use {{UserCodeClassLoader}} when new a {{RuntimeUDFContext}}.
i.e.,
Hequn Cheng created FLINK-11045:
---
Summary: UserCodeClassLoader has not been set correctly for
RuntimeUDFContext in CollectionExecutor
Key: FLINK-11045
URL: https://issues.apache.org/jira/browse/FLINK-11045
Hequn Cheng created FLINK-11001:
---
Summary: Window rowtime attribute can't be renamed in Java
Key: FLINK-11001
URL: https://issues.apache.org/jira/browse/FLINK-11001
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695946#comment-16695946
]
Hequn Cheng commented on FLINK-10982:
-
[~hongyuzhou] I can't reproduce the exception with your code
[
https://issues.apache.org/jira/browse/FLINK-10983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-10983:
Component/s: Queryable State
> NonHAQueryableStateFsBackendITCase failed when run mvn install
>
Hequn Cheng created FLINK-10983:
---
Summary: NonHAQueryableStateFsBackendITCase failed when run mvn
install
Key: FLINK-10983
URL: https://issues.apache.org/jira/browse/FLINK-10983
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10977:
---
Assignee: Hequn Cheng
> Add UnBounded FlatAggregate operator to streaming Table API
>
[
https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10978:
---
Assignee: Hequn Cheng
> Add UnBounded FlatAggregate operator to batch Table API
>
[
https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10976:
---
Assignee: Hequn Cheng
> Add Aggregate operator to Table API
>
[
https://issues.apache.org/jira/browse/FLINK-10965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695445#comment-16695445
]
Hequn Cheng commented on FLINK-10965:
-
{{getResultType}} has a higher priority than the result type
[
https://issues.apache.org/jira/browse/FLINK-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-10956.
---
Resolution: Duplicate
> Reuse same rexCall during codegen
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694759#comment-16694759
]
Hequn Cheng commented on FLINK-10956:
-
[~twalthr] Done. Thanks for the reminder.
> Reuse same
[
https://issues.apache.org/jira/browse/FLINK-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-7403:
---
Description:
Currently, we expand local references before code generation. This means that
[
https://issues.apache.org/jira/browse/FLINK-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-7403:
--
Assignee: Hequn Cheng
> Remove expandLocalRef() before code generation
>
Hequn Cheng created FLINK-10957:
---
Summary: Adapt documents about DataStream to Table conversion
Key: FLINK-10957
URL: https://issues.apache.org/jira/browse/FLINK-10957
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694199#comment-16694199
]
Hequn Cheng commented on FLINK-10873:
-
[~fhueske] Thanks for your information. I have tested it with
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694115#comment-16694115
]
Hequn Cheng commented on FLINK-10834:
-
Hi, thanks for your discussion and suggestions.
As for
[
https://issues.apache.org/jira/browse/FLINK-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-10956:
Description:
Currently, same rexCalls have not been reused during codegen. I think we can
add
Hequn Cheng created FLINK-10956:
---
Summary: Reuse same rexCall during codegen
Key: FLINK-10956
URL: https://issues.apache.org/jira/browse/FLINK-10956
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691839#comment-16691839
]
Hequn Cheng commented on FLINK-10871:
-
[~fhueske] Good questions. I'm in a dilemma about how to
[
https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688120#comment-16688120
]
Hequn Cheng commented on FLINK-10871:
-
[~fhueske] Hi, thanks for your reply. You are right. I think
[
https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688115#comment-16688115
]
Hequn Cheng commented on FLINK-10873:
-
[~fhueske] Hi, thanks a lot for your reply. Yes, it is not
[
https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10873:
---
Assignee: Hequn Cheng
> Remove tableEnv in DataSetConversions#toTable and
>
[
https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686118#comment-16686118
]
Hequn Cheng commented on FLINK-10871:
-
A singleton Environment makes sense too. I think we can
[
https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10871:
---
Assignee: Hequn Cheng
> ExecutionEnvironment & TableEnvironment should be singleton
>
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683913#comment-16683913
]
Hequn Cheng commented on FLINK-10851:
-
Hi, you can take a look at the {{testStreamSQL()}} in
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683743#comment-16683743
]
Hequn Cheng edited comment on FLINK-10851 at 11/12/18 12:51 PM:
[~frank
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683743#comment-16683743
]
Hequn Cheng commented on FLINK-10851:
-
[~frank wang] Hi, thanks for creating this jira and bring up
[
https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683138#comment-16683138
]
Hequn Cheng commented on FLINK-10847:
-
[~xueyu] Hi, that would be cool if FLINK-10845 can also solve
[
https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10847:
---
Assignee: Hequn Cheng
> Add support for IS NOT DISTINCT FROM in code generator
>
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10834:
---
Assignee: Hequn Cheng
> TableAPI flatten() calculated value error
>
[
https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679407#comment-16679407
]
Hequn Cheng commented on FLINK-10814:
-
[~yanghua] Oh, sorry that haven't seen your reply. I have
[
https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679868#comment-16679868
]
Hequn Cheng commented on FLINK-10826:
-
I think we can echo some messages in the script when the test
[
https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10826:
---
Assignee: Hequn Cheng
> Heavy deployment end-to-end test produces no output on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10814:
---
Assignee: Hequn Cheng
> Kafka examples modules need scala suffix
>
[
https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676791#comment-16676791
]
Hequn Cheng commented on FLINK-10795:
-
Hi, I had looked into this issue. I think it is a precision
[
https://issues.apache.org/jira/browse/FLINK-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10779:
---
Assignee: Hequn Cheng
> Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7
>
[
https://issues.apache.org/jira/browse/FLINK-10780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10780:
---
Assignee: Hequn Cheng
> Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for
[
https://issues.apache.org/jira/browse/FLINK-10781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10781:
---
Assignee: Hequn Cheng
> Update BucketingSinkMigrationTest for Flink 1.7
>
[
https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16673911#comment-16673911
]
Hequn Cheng edited comment on FLINK-10766 at 11/3/18 3:35 AM:
--
[~jark] Hi,
[
https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16673911#comment-16673911
]
Hequn Cheng commented on FLINK-10766:
-
[~jark] Hi, thanks for the proposal. It is a good idea! There
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672495#comment-16672495
]
Hequn Cheng commented on FLINK-10711:
-
[~twalthr] Hi, I haven't started yet. Take it as you wish.
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668852#comment-16668852
]
Hequn Cheng commented on FLINK-10711:
-
Agree, `set -euo pipefail` is better.
>
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668796#comment-16668796
]
Hequn Cheng commented on FLINK-10711:
-
How about start scripts with `set -eo pipefail`. Errors can
[
https://issues.apache.org/jira/browse/FLINK-10691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667370#comment-16667370
]
Hequn Cheng commented on FLINK-10691:
-
Would it be ok if we replace {{BucketingSink}} with
[
https://issues.apache.org/jira/browse/FLINK-10691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10691:
---
Assignee: Hequn Cheng
> StreamSQL E2E test relies on hadoop
>
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10711:
---
Assignee: Hequn Cheng
> flink-end-to-end-tests can fail silently
>
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665302#comment-16665302
]
Hequn Cheng commented on FLINK-10678:
-
Sure. I haven't started yet.
> Add a switch to run_test to
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665259#comment-16665259
]
Hequn Cheng commented on FLINK-10678:
-
I think it is also useful for tests that contain a lot of
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10678:
---
Assignee: Hequn Cheng
> Add a switch to run_test to configure if logs should be checked
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665245#comment-16665245
]
Hequn Cheng edited comment on FLINK-10668 at 10/26/18 2:26 PM:
---
[~gjy] Hi,
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665245#comment-16665245
]
Hequn Cheng commented on FLINK-10668:
-
[~gjy] Hi, I see two options to solve the problem:
- Exclude
[
https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16664527#comment-16664527
]
Hequn Cheng commented on FLINK-10680:
-
[~Paul Lin] Hi, thanks for your contribution. I think we have
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663794#comment-16663794
]
Hequn Cheng commented on FLINK-10668:
-
[~gjy] Hi, thanks for the information about how to reproduce
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663566#comment-16663566
]
Hequn Cheng commented on FLINK-10676:
-
[~Zentol] Hi, could I assign the task to myself?:)
> Add
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663530#comment-16663530
]
Hequn Cheng commented on FLINK-10676:
-
[~sunjincheng121] Thanks for proposing the improvement. It is
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10676:
---
Assignee: Hequn Cheng
> Add 'as' method for OverWindowWithOrderBy in Java API
>
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10668:
---
Assignee: Hequn Cheng
> Streaming File Sink E2E test fails because not all legitimate
[
https://issues.apache.org/jira/browse/FLINK-10667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10667:
---
Assignee: Hequn Cheng
> Clean up Scala 2.10 remnants
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660071#comment-16660071
]
Hequn Cheng commented on FLINK-10639:
-
[~sunjincheng121] Thanks for reporting this error in Flink
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10463:
---
Assignee: Hequn Cheng
> Null literal cannot be properly parsed in Java Table API function
[
https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10543:
---
Assignee: Hequn Cheng
> Leverage efficient timer deletion in relational operators
>
[
https://issues.apache.org/jira/browse/FLINK-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650443#comment-16650443
]
Hequn Cheng commented on FLINK-8578:
> Upsert Order
Yes, a non-timestamp order filed can cover more
[
https://issues.apache.org/jira/browse/FLINK-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650352#comment-16650352
]
Hequn Cheng commented on FLINK-8578:
[~fhueske] Thanks for your suggestions. You are right. I think
[
https://issues.apache.org/jira/browse/FLINK-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-8578:
---
Description:
Flink-8577 implements upsert from stream under proctime. This task is going to
solve
[
https://issues.apache.org/jira/browse/FLINK-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648915#comment-16648915
]
Hequn Cheng commented on FLINK-10220:
-
Should we continue to look into this problem or close it? It
[
https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-7999.
--
Resolution: Won't Fix
> Variable Join Window Boundaries
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645931#comment-16645931
]
Hequn Cheng commented on FLINK-7999:
I think
[
https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-5584.
--
Resolution: Duplicate
> Support Sliding-count row-window on streaming sql
>
[
https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645907#comment-16645907
]
Hequn Cheng commented on FLINK-5584:
I think this has been solved by
[
https://issues.apache.org/jira/browse/FLINK-9200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-9200.
--
Resolution: Duplicate
> SQL E2E test failed on travis
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-9200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645879#comment-16645879
]
Hequn Cheng edited comment on FLINK-9200 at 10/11/18 3:02 AM:
--
This is
[
https://issues.apache.org/jira/browse/FLINK-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10220:
---
Assignee: Hequn Cheng
> StreamSQL E2E test fails on travis
>
[
https://issues.apache.org/jira/browse/FLINK-9200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645879#comment-16645879
]
Hequn Cheng commented on FLINK-9200:
Do we still have this problem? Should I close it?
> SQL E2E
901 - 1000 of 1202 matches
Mail list logo
