GitHub user gallenvara opened a pull request:
https://github.com/apache/flink/pull/3110
[FLINK-2184] Cannot get last element with maxBy/minBy.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
Github user gallenvara closed the pull request at:
https://github.com/apache/flink/pull/1975
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2991
+1 to merge this for 1.2 and master
---
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
enab
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3109
[FLINK-5329] Fix metric list being cut off
This PR fixes the metric list in the WebFrontend job page being cut off.
This bug was introduced in bd62fe14ac3e8c382b72c7c16ce1f0a6ee7db77d.
To fi
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3102
I guess I could try and add an operator that implements
``CheckpointedRestoring`` to our ``RescalingITCase``.
---
If your project is set up for it, you can reply to this email and have your
r
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3102
Although it feels like a good test is missing for this since no test caught
it. @StefanRRichter Do you think it's feasible to add one?
---
If your project is set up for it, you can reply to this email a
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3102
Yep.
---
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
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3106
Yeah, I think counting the buffers is the better way to go.
---
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
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3106
Then we could count per buffer. I'd rather not count per record since the
deserializer are kind of complicated :(
---
If your project is set up for it, you can reply to this email and have your
reply
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3102
I think this should work. Could you go ahead and merge, @uce ?
---
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 no
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3108
[FLINK-5155] Deprecate ValueStateDescriptor constructors with default value
I left usage of this in a lot of places to ensure that we don't break
anything. The rest of places where the default-valu
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3075
Thanks @aljoscha . Will do that.
---
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 wi
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3075
---
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 enable
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3075
Thanks for your work! ð
Could you please close this PR? I merged it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3106
Instead of counting bytesOut in the serializer we could do it one level up
in the RecordWriter.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Till Rohrmann created FLINK-5476:
Summary: Fail fast if trying to submit a job to a non-existing
Flink cluster
Key: FLINK-5476
URL: https://issues.apache.org/jira/browse/FLINK-5476
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821266#comment-15821266
]
Stephan Ewen commented on FLINK-4973:
-
I think the problem is the following: An inner
[
https://issues.apache.org/jira/browse/FLINK-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821262#comment-15821262
]
Robert Metzger commented on FLINK-5473:
---
That would be the best user experience, yes
[
https://issues.apache.org/jira/browse/FLINK-5470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5470.
---
Resolution: Duplicate
> Requesting non-existing log/stdout file from TM crashes the TM
> -
Till Rohrmann created FLINK-5475:
Summary: Extend DC/OS documentation
Key: FLINK-5475
URL: https://issues.apache.org/jira/browse/FLINK-5475
Project: Flink
Issue Type: Sub-task
Compo
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3106
Good catch. I was wondering whether it is better to count in a consistent
way, too, e.g. count the size of each buffer or each record on both A and B
(now we have per record on the output side and per bu
Till Rohrmann created FLINK-5474:
Summary: Extend DC/OS documentation
Key: FLINK-5474
URL: https://issues.apache.org/jira/browse/FLINK-5474
Project: Flink
Issue Type: Sub-task
Compo
[
https://issues.apache.org/jira/browse/FLINK-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821254#comment-15821254
]
Stefan Richter commented on FLINK-5473:
---
We could try to automatically set the old p
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3104
Good catch!
---
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 fe
[
https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821249#comment-15821249
]
ASF GitHub Bot commented on FLINK-5150:
---
Github user uce commented on the issue:
Robert Metzger created FLINK-5473:
-
Summary: setMaxParallelism() higher than 1 is possible on
non-parallel operators
Key: FLINK-5473
URL: https://issues.apache.org/jira/browse/FLINK-5473
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821239#comment-15821239
]
ASF GitHub Bot commented on FLINK-5118:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821232#comment-15821232
]
ASF GitHub Bot commented on FLINK-5118:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5470:
-
Summary: Requesting non-existing log/stdout file from TM crashes the TM
(was: Requesting non-exis
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3106#discussion_r95812448
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java
---
@@ -99,7 +99,7 @@ public Serializat
Till Rohrmann created FLINK-5472:
Summary: Flink's web server does not support https requests
Key: FLINK-5472
URL: https://issues.apache.org/jira/browse/FLINK-5472
Project: Flink
Issue Type:
Till Rohrmann created FLINK-5471:
Summary: Properly inform JobClientActor about terminated Mesos
framework
Key: FLINK-5471
URL: https://issues.apache.org/jira/browse/FLINK-5471
Project: Flink
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3093
Thanks! LGTM, going to merge this now.
---
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 a
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3093
---
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
[
https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821183#comment-15821183
]
ASF GitHub Bot commented on FLINK-5444:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821199#comment-15821199
]
ASF GitHub Bot commented on FLINK-5444:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5444.
--
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
Fixed in
dff58df, 80f1517 (releas
Till Rohrmann created FLINK-5470:
Summary: Requesting non-existing log/stdout file from TM crashes
the it
Key: FLINK-5470
URL: https://issues.apache.org/jira/browse/FLINK-5470
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5466.
--
Resolution: Fixed
Assignee: Ufuk Celebi
Fix Version/s: 1.1.5
1.3.0
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3100
---
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
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5118:
Fix Version/s: 1.3.0
1.2.0
> Inconsistent records sent/received metrics
>
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5118:
Affects Version/s: 1.3.0
1.2.0
> Inconsistent records sent/received m
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821166#comment-15821166
]
Chesnay Schepler commented on FLINK-5118:
-
PR at https://github.com/apache/flink/p
[
https://issues.apache.org/jira/browse/FLINK-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821161#comment-15821161
]
ASF GitHub Bot commented on FLINK-5466:
---
Github user asfgit closed the pull request
Chesnay Schepler created FLINK-5469:
---
Summary: build_docs.sh -p fails on Windows Subsystem for Linux
Key: FLINK-5469
URL: https://issues.apache.org/jira/browse/FLINK-5469
Project: Flink
Iss
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2991
@StephanEwen Could you take another look?
---
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
ena
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3871:
-
Assignee: Ivan Mushketyk
> Add Kafka TableSource with Avro serialization
> --
[
https://issues.apache.org/jira/browse/FLINK-5321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821128#comment-15821128
]
ASF GitHub Bot commented on FLINK-5321:
---
Github user zentol commented on the issue:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/3107
[FLINK-5441] [table] Directly allow SQL queries on a Table
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821118#comment-15821118
]
ASF GitHub Bot commented on FLINK-5441:
---
GitHub user wuchong opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821103#comment-15821103
]
ASF GitHub Bot commented on FLINK-5466:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3100
+1 to merge and backport. This is a big improvement when accessing the web
UI over a slow connection.
---
If your project is set up for it, you can reply to this email and have your
reply appear o
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3106
[FLINK-] FIx inconsistent numBytesIn/Out metrics
This PR fixes _some_ jira issue (i can't find the correct issue ID right
now since JIRA is being stupid) regarding inconsistent numBytesIn/Out met
[
https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821007#comment-15821007
]
ASF GitHub Bot commented on FLINK-5444:
---
Github user joerg84 commented on the issue:
Github user joerg84 commented on the issue:
https://github.com/apache/flink/pull/3093
@sachingoel0101 PTAL
---
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,
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3071
When viewing the documentation in firefox there is now a lot of whitespace
above the diagram. The dimensions have slightly changed as well :/
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820953#comment-15820953
]
ASF GitHub Bot commented on FLINK-5417:
---
Github user zentol commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3102
I'm not aware of all implications of this change, but this fixes the
problem I had. The operator does not checkpoint any legacy operator state.
+1 to merge from my side.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820936#comment-15820936
]
ASF GitHub Bot commented on FLINK-5467:
---
Github user uce commented on the issue:
Github user joerg84 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3093#discussion_r95783168
--- Diff:
flink-runtime-web/web-dashboard/app/scripts/modules/submit/submit.ctrl.coffee
---
@@ -167,7 +167,7 @@ angular.module('flinkApp')
$
[
https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820921#comment-15820921
]
ASF GitHub Bot commented on FLINK-5444:
---
Github user joerg84 commented on a diff in
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3071
I will take a look at these changes.
Just a small note: We are not getting notified of pushed changes, a small
comment is always good to get attention ;)
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820913#comment-15820913
]
ASF GitHub Bot commented on FLINK-5417:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3090#discussion_r95782207
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -282,7 +282,7 @@ pri
[
https://issues.apache.org/jira/browse/FLINK-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820907#comment-15820907
]
ASF GitHub Bot commented on FLINK-5421:
---
Github user StefanRRichter closed the pull
[
https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820908#comment-15820908
]
ASF GitHub Bot commented on FLINK-5432:
---
Github user zentol commented on a diff in t
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/3074
---
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
GitHub user chermenin opened a pull request:
https://github.com/apache/flink/pull/3105
[FLINK-4641] Support branching CEP patterns
Support for branched CEP patterns was added in this PR.
After merging that we will be able to use follow code to define more
complex patterns:
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820897#comment-15820897
]
Till Rohrmann commented on FLINK-4973:
--
I think that exactly for these cases it is no
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820896#comment-15820896
]
ASF GitHub Bot commented on FLINK-4641:
---
GitHub user chermenin opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5380:
Priority: Blocker (was: Major)
> Number of outgoing records not reported in web interface
>
[
https://issues.apache.org/jira/browse/FLINK-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820882#comment-15820882
]
Aljoscha Krettek commented on FLINK-5421:
-
Implemented on master in:
aaf8e09d8f9ee
[
https://issues.apache.org/jira/browse/FLINK-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820881#comment-15820881
]
ASF GitHub Bot commented on FLINK-5421:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3074
Thanks for your work! ð
I merged, could you please close this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3104
[FLINK-5150] [webui] Store metrics in sessionStorage
This PR modifies the webfrontend to no longer store the metrics setup
(selected metrics + their values) in localStorage but sessionStorage instead
[
https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820872#comment-15820872
]
ASF GitHub Bot commented on FLINK-5150:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5150:
---
Assignee: Chesnay Schepler
> WebUI metric-related resource leak
> ---
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3103
[FLINK-5464] [metrics] Prevent some NPEs
This PR prevents some NullPointerExceptions from occurring in the metric
system.
- When registering a metric that is null the metric is ignored, and
[
https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820823#comment-15820823
]
ASF GitHub Bot commented on FLINK-5464:
---
GitHub user zentol opened a pull request:
Robert Metzger created FLINK-5468:
-
Summary: Restoring from a semi async rocksdb statebackend (1.1) to
1.2 fails with ClassNotFoundException
Key: FLINK-5468
URL: https://issues.apache.org/jira/browse/FLINK-5468
[
https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820801#comment-15820801
]
Chesnay Schepler commented on FLINK-5464:
-
There are 2 possible cases for this: Ei
[
https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820796#comment-15820796
]
ASF GitHub Bot commented on FLINK-4920:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3080#discussion_r95773028
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala
---
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820791#comment-15820791
]
ASF GitHub Bot commented on FLINK-5467:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820790#comment-15820790
]
ASF GitHub Bot commented on FLINK-5467:
---
GitHub user StefanRRichter opened a pull re
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/3102
[FLINK-5467] Avoid legacy state for CheckpointedRestoring operators
This PR fixes [FLINK-5467].
You can merge this pull request into a Git repository by running:
$ git pull https://githu
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3102
cc @uce @aljoscha
---
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
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3088
Changes look very good! I fixed the formatting of the newly added methods
in `TestingCluster` to conform to Scala coding guidelines.
I rebased on master, will wait for Travis to give the gre
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820786#comment-15820786
]
ASF GitHub Bot commented on FLINK-5407:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5464:
---
Assignee: Chesnay Schepler
> MetricQueryService throws NullPointerException on JobMan
[
https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820769#comment-15820769
]
ASF GitHub Bot commented on FLINK-5406:
---
GitHub user godfreyhe opened a pull request
GitHub user godfreyhe opened a pull request:
https://github.com/apache/flink/pull/3101
[FLINK-5406] [table] add normalization phase for predicate logical plan
rewriting
Normalization phase is for predicate logical plan rewriting and is
independent of cost module. The rules in norma
[
https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820764#comment-15820764
]
ASF GitHub Bot commented on FLINK-5432:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3090
The changes look very good! I think it would be good to add a test for
nested reading in `ContinuousFileProcessingTest`.
---
If your project is set up for it, you can reply to this email and have y
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5467:
-
Assignee: Stefan Richter
> Stateless chained tasks set legacy operator state
> --
Ufuk Celebi created FLINK-5467:
--
Summary: Stateless chained tasks set legacy operator state
Key: FLINK-5467
URL: https://issues.apache.org/jira/browse/FLINK-5467
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820658#comment-15820658
]
ASF GitHub Bot commented on FLINK-5466:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3100
+1 to merge.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820648#comment-15820648
]
ASF GitHub Bot commented on FLINK-5466:
---
Github user joerg84 commented on the issue:
Github user joerg84 commented on the issue:
https://github.com/apache/flink/pull/3100
LGTM, thanks for fixing this!
---
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 wi
1 - 100 of 125 matches
Mail list logo