[
https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168827#comment-16168827
]
Michael Fong commented on FLINK-4498:
-
I would like to help updating the documents for
[
https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168733#comment-16168733
]
Elias Levy commented on FLINK-7266:
---
I am curious what the state of this is. It is stil
[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168489#comment-16168489
]
ASF GitHub Bot commented on FLINK-7402:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168490#comment-16168490
]
ASF GitHub Bot commented on FLINK-7625:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168491#comment-16168491
]
ASF GitHub Bot commented on FLINK-7494:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4575
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4676
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4641
---
[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-7402:
--
Fix Version/s: 1.4.0
> Ineffective null check in NettyMessage#write()
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4562
---
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168434#comment-16168434
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r139237307
--- Diff: flink-core/pom.xml ---
@@ -80,6 +80,13 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168430#comment-16168430
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r139237144
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala
---
@@ -211,6 +218,14 @@ class FlinkTypeFactory(
[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168414#comment-16168414
]
ASF GitHub Bot commented on FLINK-7402:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4562
Merging ...
---
[
https://issues.apache.org/jira/browse/FLINK-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168395#comment-16168395
]
ASF GitHub Bot commented on FLINK-7625:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4676
Merging ...
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4575
Merging ...
---
[
https://issues.apache.org/jira/browse/FLINK-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168337#comment-16168337
]
ASF GitHub Bot commented on FLINK-7494:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4641
Merging ...
---
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168158#comment-16168158
]
Kostas Kloudas commented on FLINK-7606:
---
Now that I think about it, can you check yo
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168099#comment-16168099
]
Kostas Kloudas edited comment on FLINK-7606 at 9/15/17 4:38 PM:
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168099#comment-16168099
]
Kostas Kloudas commented on FLINK-7606:
---
Also, on another note, I read that you have
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168090#comment-16168090
]
Kostas Kloudas commented on FLINK-7606:
---
Yes [~i...@paolorendano.it]. This holds for
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168072#comment-16168072
]
ASF GitHub Bot commented on FLINK-7410:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4624#discussion_r139187009
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -41,7 +41,7 @@ abstract class UserD
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r139186699
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java
---
@@ -115,6 +115,13 @@ public Configuration ge
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168055#comment-16168055
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168056#comment-16168056
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4574#discussion_r139185112
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -1900,7 +1900,8 @@ private boolean isValidPojoField(Field
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4574#discussion_r139184023
--- Diff: docs/dev/types_serialization.md ---
@@ -115,6 +115,8 @@ conditions are fulfilled:
or have a public getter- and a setter- method that follow
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168025#comment-16168025
]
Paolo Rendano commented on FLINK-7606:
--
Hi [~kkl0u],
from your comment I understand t
[
https://issues.apache.org/jira/browse/FLINK-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-7273.
-
Resolution: Fixed
master: 9437a0ffc04318f6a1a2d19c59f2ae6651b26507
> Gelly tests with empty graphs
>
[
https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-7199:
--
Fix Version/s: 1.4.0
> Graph simplification does not set parallelism
> -
[
https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-7199.
-
Resolution: Fixed
master: 2ac09c084320f1803c623c719dca8b4776c8110f
> Graph simplification does not set pa
[
https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167976#comment-16167976
]
Greg Hogan commented on FLINK-7447:
---
The timezone is of little benefit for real-time com
[
https://issues.apache.org/jira/browse/FLINK-7563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167967#comment-16167967
]
ASF GitHub Bot commented on FLINK-7563:
---
Github user yestinchen commented on the iss
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4632
I added the test case to the `CEP Operator` and addressed the line. Thanks
so much.
---
[
https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167955#comment-16167955
]
Wei-Che Wei commented on FLINK-7630:
Hi [~aljoscha]
FYI. If there is any feedback, ple
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167954#comment-16167954
]
Kostas Kloudas commented on FLINK-7606:
---
It should be cleared.
In event time, we d
Wei-Che Wei created FLINK-7630:
--
Summary: Allow passing a File or an InputStream to
ParameterTool.fromPropertiesFile()
Key: FLINK-7630
URL: https://issues.apache.org/jira/browse/FLINK-7630
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4346
---
[
https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167895#comment-16167895
]
ASF GitHub Bot commented on FLINK-7199:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4405
---
[
https://issues.apache.org/jira/browse/FLINK-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167896#comment-16167896
]
ASF GitHub Bot commented on FLINK-7273:
---
Github user asfgit closed the pull request
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139111867
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167875#comment-16167875
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167873#comment-16167873
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167878#comment-16167878
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167877#comment-16167877
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167871#comment-16167871
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r138918828
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167870#comment-16167870
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167872#comment-16167872
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139149693
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
---
@@ -49,6 +51,8 @@ object WordCoun
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r138919667
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167880#comment-16167880
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167876#comment-16167876
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167881#comment-16167881
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139113529
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139109060
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r138919099
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139112514
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139150623
--- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/Types.scala
---
@@ -0,0 +1,363 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167866#comment-16167866
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167868#comment-16167868
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139150559
--- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/Types.scala
---
@@ -0,0 +1,363 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139148230
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r138921417
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167867#comment-16167867
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139112027
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139150367
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -20,60 +20,123 @@ package org.apache.flink.table.api
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167869#comment-16167869
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139113352
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167874#comment-16167874
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167879#comment-16167879
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139109685
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ---
@@ -19,56 +19,408 @@
package org.apache.flink.api.common.typeinfo
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4673
Hi @dawidwys , Thanks for the tip, that's what I tried to add. Sorry for
the missing times().
---
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167804#comment-16167804
]
ASF GitHub Bot commented on FLINK-7567:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4655
Thanks! This doesn't help us with our situation, though.
---
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167800#comment-16167800
]
ASF GitHub Bot commented on FLINK-7567:
---
Github user mlipkovich commented on the iss
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
Thansk, Aljoscha
Probably I've forgotten to run `clean`.
The method `iterate$default$3` is a method which automatically created by
Scala for calculation of default value for parameter `ke
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167791#comment-16167791
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , I have submitted the updates.
---
[
https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michael Fong reassigned FLINK-4498:
---
Assignee: Michael Fong
> Better Cassandra sink documentation
> --
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/4665
@aljoscha yes, i review the code this day, it will jude each window whether
late , so the previous method i use will counts more lost data than the actual
situation , i have fix the error and re-push
Gabor Gevay created FLINK-7629:
--
Summary: Scala stream aggregations should support nested field
expressions
Key: FLINK-7629
URL: https://issues.apache.org/jira/browse/FLINK-7629
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167685#comment-16167685
]
ASF GitHub Bot commented on FLINK-7567:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4655
A local build of `mvn clean verify` fails for me because the japicmp plugin
is complaining. The relevant section of the diff output from japicmp is
```
***! MODIFIED CLASS: PUBLIC org.apache.
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4796.
---
Resolution: Won't Fix
Introducing a new SinkInterface will make the workaround of the hybrid p
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-4796:
-
> Add new Sink interface with access to more meta data
> -
[
https://issues.apache.org/jira/browse/FLINK-7563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167644#comment-16167644
]
ASF GitHub Bot commented on FLINK-7563:
---
Github user dawidwys commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167643#comment-16167643
]
Aljoscha Krettek commented on FLINK-7589:
-
I don't think we want to do that, no. H
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4632
Hi @yestinchen,
Thanks for working on this issue. Unfortunately your changes do not fix the
semantics. Have a look at this failing test:
@Test
public void testCEPWatermarkSem
[
https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167638#comment-16167638
]
Aljoscha Krettek commented on FLINK-4814:
-
Yes, those are things I'm aware of and
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167635#comment-16167635
]
Aljoscha Krettek commented on FLINK-7606:
-
How do you mean? They could get the tim
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4673
Hi @yestinchen ,
thanks for spotting the mistake. Good catch. However the test you provided
does not prove the fix. It passes with and without the fix. Please correct it.
You can e.g. extend the
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4665
@Aitozi I meant that the place where you're currently counting dropped
elements will not yield a correct count because one element might be in several
windows. The place were we side-output late dat
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167593#comment-16167593
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user NicoK commented on a diff in th
1 - 100 of 136 matches
Mail list logo
