[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180227#comment-16180227
]
Bowen Li commented on FLINK-7648:
-
[~till.rohrmann] [~tzulitai] I'd like to try this and contribute to the
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r140951770
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,93 @@
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180188#comment-16180188
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user shaoxuan-wang commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-5176:
-
Assignee: Shuyi Chen
> Properly wait for component shutdown in Runner components
>
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180077#comment-16180077
]
Xingcan Cui commented on FLINK-7548:
Thanks for the answers, [~fhueske]. Some extra comments.
About
[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7648:
---
Assignee: Bowen Li
> Port TaskManagersHandler to new REST endpoint
>
Bill Liu created FLINK-7688:
---
Summary: ContaineredTaskManagerParameters sets off heap memory
size incorrectly unlimited
Key: FLINK-7688
URL: https://issues.apache.org/jira/browse/FLINK-7688
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179870#comment-16179870
]
Fabian Hueske commented on FLINK-7657:
--
Hi [~kmurra], thanks for looking into this.
I'm currently
Elias Levy created FLINK-7687:
-
Summary: Clarify the master and slaves files are not necessary
unless using the cluster start/stop scripts
Key: FLINK-7687
URL: https://issues.apache.org/jira/browse/FLINK-7687
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179842#comment-16179842
]
ASF GitHub Bot commented on FLINK-7683:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4722#discussion_r140908693
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -252,6
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179836#comment-16179836
]
Fabian Hueske commented on FLINK-7548:
--
Thanks for your thoughts [~xccui].
I added a few comments to
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4688
---
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7638.
Resolution: Fixed
Fix Version/s: 1.4.0
Added via e585aed8ce751d769b56054fc1ffd4be24350e91
>
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179840#comment-16179840
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user asfgit closed the pull request at:
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4722#discussion_r140907699
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -252,6
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179835#comment-16179835
]
ASF GitHub Bot commented on FLINK-7683:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179832#comment-16179832
]
ASF GitHub Bot commented on FLINK-7683:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4722#discussion_r140907101
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -252,6
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4665
LGTM
---
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179607#comment-16179607
]
David Anderson commented on FLINK-7683:
---
Something like this has also been requested by users
Hai Zhou_UTC+8 created FLINK-7686:
-
Summary: Add Flink Forward Berlin 2017 conference slides to the
flink website
Key: FLINK-7686
URL: https://issues.apache.org/jira/browse/FLINK-7686
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179486#comment-16179486
]
ASF GitHub Bot commented on FLINK-7645:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/4693
Hey @yew1eb, I like this ð I think it really makes sense to make this
browsable from the table of contents. @zentol What do you think? I would be in
favour of merging this if you don't have any
[
https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179325#comment-16179325
]
ASF GitHub Bot commented on FLINK-7393:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4708
@tzulitai yes, only unit tests migration
---
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4702
Thank you, guys @aljoscha @chenqin !
---
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179317#comment-16179317
]
ASF GitHub Bot commented on FLINK-7635:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179318#comment-16179318
]
ASF GitHub Bot commented on FLINK-7635:
---
Github user bowenli86 closed the pull request at:
Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/4702
---
Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/4707
---
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179308#comment-16179308
]
ASF GitHub Bot commented on FLINK-5944:
---
Github user mlipkovich commented on a diff in the pull
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140831859
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -281,6 +286,73 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179305#comment-16179305
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179306#comment-16179306
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
Github user mlipkovich commented on a diff in the pull request:
https://github.com/apache/flink/pull/4683#discussion_r140833786
--- Diff: flink-core/pom.xml ---
@@ -52,6 +52,12 @@ under the License.
flink-shaded-asm
+
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140833417
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -281,6 +286,73 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179304#comment-16179304
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user jparkie commented on a diff in the pull
Github user jparkie commented on a diff in the pull request:
https://github.com/apache/flink/pull/4652#discussion_r140833539
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/functions/aggfunctions/cardinality/HyperLogLog.java
---
@@ -0,0 +1,333
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179299#comment-16179299
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user jparkie commented on a diff in the pull
Github user jparkie commented on a diff in the pull request:
https://github.com/apache/flink/pull/4652#discussion_r140832701
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/functions/aggfunctions/cardinality/HyperLogLog.java
---
@@ -0,0 +1,333
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179290#comment-16179290
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179289#comment-16179289
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140831302
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -183,18 +214,40 @@ void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140829015
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -215,6 +269,48 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179284#comment-16179284
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user jparkie commented on a diff in the pull
Github user jparkie commented on a diff in the pull request:
https://github.com/apache/flink/pull/4652#discussion_r140830364
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/functions/aggfunctions/cardinality/ICardinality.java
---
@@ -0,0 +1,80
Github user jparkie commented on a diff in the pull request:
https://github.com/apache/flink/pull/4652#discussion_r140828795
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/functions/aggfunctions/cardinality/ICardinality.java
---
@@ -0,0 +1,80
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179276#comment-16179276
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user jparkie commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179259#comment-16179259
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user jparkie commented on a diff in the pull
Github user jparkie commented on a diff in the pull request:
https://github.com/apache/flink/pull/4652#discussion_r140826158
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/functions/aggfunctions/cardinality/MurmurHash.java
---
@@ -0,0 +1,247 @@
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179245#comment-16179245
]
ASF GitHub Bot commented on FLINK-6465:
---
Github user haohui commented on a diff in the pull request:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4720
This looks pretty much like some sort of mistake. Can you please close the
PR?
---
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179246#comment-16179246
]
ASF GitHub Bot commented on FLINK-6465:
---
Github user haohui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179244#comment-16179244
]
ASF GitHub Bot commented on FLINK-6465:
---
Github user haohui commented on a diff in the pull request:
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4556#discussion_r140824914
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1406,6 +1406,61 @@ object
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4556#discussion_r140824819
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/FirstValueAggFunctionWithRetract.scala
---
@@ -0,0 +1,129
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4556#discussion_r140823719
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/FirstValueAggFunction.scala
---
@@ -0,0 +1,107 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179241#comment-16179241
]
ASF GitHub Bot commented on FLINK-7541:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4609
Merged in f1b2b83d63. Please close the PR and the JIRA.
---
Github user jparkie commented on a diff in the pull request:
https://github.com/apache/flink/pull/4652#discussion_r140823213
--- Diff: docs/dev/table/sql.md ---
@@ -2020,7 +2020,16 @@ COUNT(*)
Returns the number of input rows.
-
+
+
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179237#comment-16179237
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user jparkie commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179234#comment-16179234
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140822508
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -183,18 +214,40 @@ void
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179228#comment-16179228
]
ASF GitHub Bot commented on FLINK-7683:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179223#comment-16179223
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179224#comment-16179224
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179225#comment-16179225
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4722#discussion_r140821446
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTable.java
---
@@ -287,6 +289,14 @@ public S get(K key, N
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179226#comment-16179226
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140811033
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -100,7 +122,16 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140809272
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -70,6 +78,15 @@
*/
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140810853
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -99,8 +114,24 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4499#discussion_r140821090
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -183,18 +214,40 @@ void
[
https://issues.apache.org/jira/browse/FLINK-7619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-7619.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Merged in 5af463a9c0.
> Improve abstraction in
[
https://issues.apache.org/jira/browse/FLINK-7619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179200#comment-16179200
]
ASF GitHub Bot commented on FLINK-7619:
---
Github user StefanRRichter closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179199#comment-16179199
]
ASF GitHub Bot commented on FLINK-7619:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/4671
---
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4671
Merged in 5af463a9c0.
---
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-7524.
-
Assignee: Stefan Richter
I still found some small potential for improvement that is merged in
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179194#comment-16179194
]
ASF GitHub Bot commented on FLINK-7524:
---
Github user StefanRRichter closed the pull request at:
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/4639
---
[
https://issues.apache.org/jira/browse/FLINK-7684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179162#comment-16179162
]
ASF GitHub Bot commented on FLINK-7684:
---
GitHub user pnowojski opened a pull request:
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4723
[FLINK-7684] Avoid data copies in MergingWindowSet
## What is the purpose of the change
Previously MergingWindowSet uses ListState of tuples to persists it's
mapping. This is inefficient
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7683:
--
Description: This is required to make possible preserving backward
compatibility while changing
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179116#comment-16179116
]
ASF GitHub Bot commented on FLINK-7683:
---
GitHub user pnowojski opened a pull request:
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4722
[FLINK-7683] Iterate over keys in KeyedStateBackend
## What is the purpose of the change
This is required to make possible preserving backward compatibility while
changing state
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7683:
--
Description: This is required to make possible preserving backward
compatibility while changing
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179089#comment-16179089
]
Kostas Kloudas commented on FLINK-7606:
---
Perfect! Thanks a lot!
> CEP operator leaks state
>
Gabor Gevay created FLINK-7685:
--
Summary: CompilerException: "Bug: Logic for branching plans
(non-tree plans) has an error, and does not track the re-joining of branches
correctly"
Key: FLINK-7685
URL:
[
https://issues.apache.org/jira/browse/FLINK-7684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7684:
--
Issue Type: Improvement (was: New Feature)
> Avoid multiple data copies in MergingWindowSet
>
[
https://issues.apache.org/jira/browse/FLINK-7684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7684:
-
Assignee: Piotr Nowojski
Affects Version/s: 1.2.0
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179072#comment-16179072
]
ASF GitHub Bot commented on FLINK-7446:
---
Github user twalthr commented on the issue:
Piotr Nowojski created FLINK-7684:
-
Summary: Avoid multiple data copies in MergingWindowSet
Key: FLINK-7684
URL: https://issues.apache.org/jira/browse/FLINK-7684
Project: Flink
Issue Type:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4710
@haohui We only cast ROWTIME / PROCTIME directly to LONG during runtime,
the special types are needed during pre-flight phase and validation. We could
not come up with a better solution that ensures
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179063#comment-16179063
]
ASF GitHub Bot commented on FLINK-7446:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179065#comment-16179065
]
ASF GitHub Bot commented on FLINK-7446:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179070#comment-16179070
]
ASF GitHub Bot commented on FLINK-7446:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179071#comment-16179071
]
ASF GitHub Bot commented on FLINK-7446:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179066#comment-16179066
]
ASF GitHub Bot commented on FLINK-7446:
---
Github user twalthr commented on a diff in the pull
1 - 100 of 248 matches
Mail list logo
