Aljoscha Krettek created FLINK-6116:
---
Summary: Watermarks don't work when unioning with same DataStream
Key: FLINK-6116
URL: https://issues.apache.org/jira/browse/FLINK-6116
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6116:
Priority: Blocker (was: Major)
> Watermarks don't work when unioning with same DataStream
>
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931600#comment-15931600
]
Luke Hutchison commented on FLINK-6115:
---
More generally, why is it not possible to s
Luke Hutchison created FLINK-6115:
-
Summary: Need more helpful error message when trying to serialize
a tuple with a null field
Key: FLINK-6115
URL: https://issues.apache.org/jira/browse/FLINK-6115
Pr
[
https://issues.apache.org/jira/browse/FLINK-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jingzhang closed FLINK-6067.
Resolution: Fixed
> DataSetCalc which contains filterCondition and projects would not be choose
> as best p
[
https://issues.apache.org/jira/browse/FLINK-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931593#comment-15931593
]
jingzhang commented on FLINK-6067:
--
[~ykt836], it works, thanks a lot. I would close this
Luke Hutchison created FLINK-6114:
-
Summary: Type checking fails with generics, even when concrete
type of field is not needed
Key: FLINK-6114
URL: https://issues.apache.org/jira/browse/FLINK-6114
Pro
[
https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931569#comment-15931569
]
sunjincheng edited comment on FLINK-6074 at 3/19/17 4:53 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931569#comment-15931569
]
sunjincheng commented on FLINK-6074:
When I using more test data,I find the cause of t
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3559#discussion_r106797445
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala
---
@@ -100,6 +101,7 @@ class FlinkPlannerImpl
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3559#discussion_r106796945
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala
---
@@ -100,6 +101,7 @@ class FlinkPlannerImpl(
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931540#comment-15931540
]
ASF GitHub Bot commented on FLINK-5183:
---
Github user GEOFBOT commented on the issue:
Github user GEOFBOT commented on the issue:
https://github.com/apache/flink/pull/3232
Resolved merge conflicts
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes
[
https://issues.apache.org/jira/browse/FLINK-5174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-5174.
-
Resolution: Duplicate
> Fix memory leak in the CEP library.
> ---
Github user mtunique commented on the issue:
https://github.com/apache/flink/pull/3565
@KurtYoung I sorry about it, I will change it. Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have t
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931247#comment-15931247
]
zhijiang commented on FLINK-4545:
-
[~StephanEwen], thank you for so rich information!
I a
[
https://issues.apache.org/jira/browse/FLINK-6111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6111.
---
Resolution: Fixed
3e767b5a4a0846c8d53a8167d6236dbd9657eb2f
> Remove sleep after python proces
Chen Qin created FLINK-6113:
---
Summary: Implement split/select with OutputTag
Key: FLINK-6113
URL: https://issues.apache.org/jira/browse/FLINK-6113
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931232#comment-15931232
]
ASF GitHub Bot commented on FLINK-5413:
---
Github user mtunique commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3406
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3406
Seems good to merge now, merging...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enable
[
https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931214#comment-15931214
]
Luke Hutchison commented on FLINK-6110:
---
Chesnay: Sorry, I couldn't find that dup, a
Tao Meng created FLINK-6112:
---
Summary: Support new numerical functions when calcite release
Key: FLINK-6112
URL: https://issues.apache.org/jira/browse/FLINK-6112
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Meng updated FLINK-6112:
Summary: Support new numerical functions when calcite release 1.12 (was:
Support new numerical functions wh
[
https://issues.apache.org/jira/browse/FLINK-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6108.
-
Resolution: Duplicate
> Add sum(fieldName) to sum based on named POJO fields
> ---
[
https://issues.apache.org/jira/browse/FLINK-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6108:
--
Component/s: (was: Core)
DataSet API
> Add sum(fieldName) to sum based on named POJ
[
https://issues.apache.org/jira/browse/FLINK-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6108:
--
Issue Type: New Feature (was: Bug)
> Add sum(fieldName) to sum based on named POJO fields
> ---
[
https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6110.
-
Resolution: Duplicate
> Flink unnecessarily repeats shared work triggered by different blocking
> sinks,
[
https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931202#comment-15931202
]
Chesnay Schepler commented on FLINK-6110:
-
This is certainly useful, nevertheless
Chesnay Schepler created FLINK-6111:
---
Summary: Remove sleep after python process generation
Key: FLINK-6111
URL: https://issues.apache.org/jira/browse/FLINK-6111
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931172#comment-15931172
]
ASF GitHub Bot commented on FLINK-5413:
---
GitHub user mtunique opened a pull request:
GitHub user mtunique opened a pull request:
https://github.com/apache/flink/pull/3565
[FLINK-5413] [table] Convert TableEnvironmentITCases to unit tests
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideratio
[
https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931147#comment-15931147
]
ASF GitHub Bot commented on FLINK-6089:
---
GitHub user hequn8128 opened a pull request
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/3564
[FLINK-6089] [table] Implement decoration phase for rewriting predicated
logical plan after volcano optimization phase
At present, there is no chance to modify the DataStreamRel tree after the
vo
[
https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6110:
--
Description:
After a blocking sink (collect() or count()) is called, all already-computed
inter
[
https://issues.apache.org/jira/browse/FLINK-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931138#comment-15931138
]
Kurt Young commented on FLINK-6067:
---
Hi can you check again this issue on latest master?
[
https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6110:
--
Description:
After a blocking sink (collect() or count()) is called, all already-computed
inter
Luke Hutchison created FLINK-6110:
-
Summary: Flink unnecessarily repeats shared work triggered by
different blocking sinks, leading to massive inefficiency
Key: FLINK-6110
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6109:
---
Description:
This is a feature discussed in this ML:
http://apache-flink-user-mailing
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776518
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776563
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776658
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776304
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776621
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776349
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931129#comment-15931129
]
ASF GitHub Bot commented on FLINK-6018:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776326
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776607
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106775966
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776351
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776283
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776232
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -82,13 +90,19 @@
import static org.mockito.Mocki
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3562#discussion_r106776337
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -162,22 +176,422 @@ protected CheckpointStreamFactory
[
https://issues.apache.org/jira/browse/FLINK-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931127#comment-15931127
]
ASF GitHub Bot commented on FLINK-5713:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3535
@StephanEwen do you think this is enough for Flink 1.2.1 or should we do
the full https://issues.apache.org/jira/browse/FLINK-5972 that throws an error
if users have shrinking merging windows?
---
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5808.
---
Resolution: Fixed
Fixed on release-1.2 in
b563f0ae2e7b7233e29e03fbb2cf18b0d853c0ca
d3b275f4b7d
Github user chenqin commented on the issue:
https://github.com/apache/flink/pull/2982
Wow, finally in!
It was fun and thanks for you help along every step of the journey!
Chen
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6109:
---
Description:
This is a feature discussed in this ML:
http://apache-flink-user-mailing
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6109:
---
Description:
This is a feature discussed in this ML:
http://apache-flink-user-mailing
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6109:
---
Description:
This is a feature discussed in this ML:
http://apache-flink-user-mailing
Tzu-Li (Gordon) Tai created FLINK-6109:
--
Summary: Add "consumer lag" report metric to FlinkKafkaConsumer
Key: FLINK-6109
URL: https://issues.apache.org/jira/browse/FLINK-6109
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931107#comment-15931107
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user chenqin closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931106#comment-15931106
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user chenqin commented on the issue:
Github user chenqin closed the pull request at:
https://github.com/apache/flink/pull/2982
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is ena
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4460.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Implemented in
e134d27589ead89882d94969edeeb171e
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2982
@chenqin I finally merged it. Could you please also close this PR?
And thanks again for working on this for so long! ð
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931104#comment-15931104
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931103#comment-15931103
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/3484
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is en
Luke Hutchison created FLINK-6108:
-
Summary: Add sum(fieldName) to sum based on named POJO fields
Key: FLINK-6108
URL: https://issues.apache.org/jira/browse/FLINK-6108
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6108:
--
Description:
Currently it is possible to do
{code}
dataSet.groupBy(0).sum(1)
{code}
but not
{
Aljoscha Krettek created FLINK-6107:
---
Summary: Add custom checkstyle for flink-streaming-java
Key: FLINK-6107
URL: https://issues.apache.org/jira/browse/FLINK-6107
Project: Flink
Issue Type
72 matches
Mail list logo
