Chengxiang Li created FLINK-3139:
Summary: NULL values handling in Table API
Key: FLINK-3139
URL: https://issues.apache.org/jira/browse/FLINK-3139
Project: Flink
Issue Type: Task
Matthias J. Sax created FLINK-3142:
--
Summary: CheckpointCoordinatorTest fails
Key: FLINK-3142
URL: https://issues.apache.org/jira/browse/FLINK-3142
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046476#comment-15046476
]
ASF GitHub Bot commented on FLINK-2928:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046483#comment-15046483
]
ASF GitHub Bot commented on FLINK-3077:
---
Github user sachingoel0101 commented on the pull request:
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1418#issuecomment-162796587
Ping.
Also, what is the procedure for creating a release artifact locally[without
GPG keys, Apache id, etc.] so I can check that this works okay for those
Chengxiang Li created FLINK-3141:
Summary: Design of NULL values handling in operation
Key: FLINK-3141
URL: https://issues.apache.org/jira/browse/FLINK-3141
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046511#comment-15046511
]
Matthias J. Sax commented on FLINK-3096:
https://travis-ci.org/mjsax/flink/jobs/95439204
>
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046534#comment-15046534
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user chiwanpark commented on the pull request:
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-162804155
@nikste, Yes that is what I mean.
---
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
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1421#issuecomment-162796105
That sounds great. @iampeter thanks for the suggestion. :)
I will see if I can update the PR today.
---
If your project is set up for it, you can reply to
Chengxiang Li created FLINK-3140:
Summary: NULL value data layout in Row Serializer/Comparator
Key: FLINK-3140
URL: https://issues.apache.org/jira/browse/FLINK-3140
Project: Flink
Issue
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-162528807
Hi @nikste. Pinging again :) What do you think about my suggestion?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044965#comment-15044965
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3124.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via e8734b2452e31e7a35a20faaf6eb37fe59b6eff1
[
https://issues.apache.org/jira/browse/FLINK-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2524.
-
Resolution: Fixed
Fixed via e8734b2452e31e7a35a20faaf6eb37fe59b6eff1
Thank you for the
[
https://issues.apache.org/jira/browse/FLINK-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2524.
---
> Add "getTaskNameWithSubtasks()" to RuntimeContext
> -
>
[
https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045035#comment-15045035
]
ASF GitHub Bot commented on FLINK-2897:
---
Github user StephanEwen commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1435#issuecomment-162550891
`DataDistribution` is actually adapted and used in the range partition PR
#1255.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045061#comment-15045061
]
ASF GitHub Bot commented on FLINK-2828:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1237#issuecomment-162553706
Yes, we should, this has been lying around for a while now.
I have been thinking about this for a while now and I'm afraid I cannot
recommend to merge this in
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-162556835
I am a bit biased towards having two environments, like @chiwanpark and
@mxm suggest.
We could also keep calling the batch environment `env` and the stream
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045086#comment-15045086
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1427#discussion_r46833253
--- Diff:
flink-annotations/src/main/java/org/apache/flink/annotation/PublicExperimental.java
---
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-2963.
---
Resolution: Fixed
Fix Version/s: 1.0.0
> Dependence on
[
https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045112#comment-15045112
]
Robert Metzger commented on FLINK-2963:
---
I see. My check was only there for commons.lang, not for
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r46819698
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,16 +122,73 @@ abstract class ApplicationMasterBase {
Robert Metzger created FLINK-3129:
-
Summary: Add tooling to ensure interface stability
Key: FLINK-3129
URL: https://issues.apache.org/jira/browse/FLINK-3129
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044937#comment-15044937
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a diff in the pull
Ufuk Celebi created FLINK-3131:
--
Summary: Expose checkpoint metrics
Key: FLINK-3131
URL: https://issues.apache.org/jira/browse/FLINK-3131
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3124.
---
> Introduce a TaskInfo object to better represent task name, index, attempt
> number etc.
>
[
https://issues.apache.org/jira/browse/FLINK-3112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044980#comment-15044980
]
ASF GitHub Bot commented on FLINK-3112:
---
Github user fhueske commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1434#issuecomment-162534463
@aljoscha I like your proposal. I will rename it accordingly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045000#comment-15045000
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045083#comment-15045083
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff in the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1434#issuecomment-162526253
I think save point is the way to go, see here:
https://en.wikipedia.org/wiki/Saved_game#Save_point :smile:
---
If your project is set up for it, you can reply to
Ufuk Celebi created FLINK-3130:
--
Summary: Visualize throughput of tasks
Key: FLINK-3130
URL: https://issues.apache.org/jira/browse/FLINK-3130
Project: Flink
Issue Type: Improvement
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1439
[contrib, connector-wikiedits] Add WikipediaEditsSource
A non-parallel source that parses a live stream of Wikipedia edits.
Meta data about the edits is mirrored to the IRC channel
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044948#comment-15044948
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044968#comment-15044968
]
Till Rohrmann commented on FLINK-3128:
--
I've assigned the issue to you.
> Add Isotonic Regression To
Github user nikste commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-162534231
Hey @mxm, my survey among two people was inconclusive. I can see both
versions working, I'm more tending towards the version that is implemented now,
I might be a bit
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-162529724
I also prefer multiple environments during startup of the shell. I'm adding
YARN session support of the shell. If there is another startup mode,
implementation could
[
https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045031#comment-15045031
]
Greg Hogan commented on FLINK-2897:
---
Thanks for checking that. I saw the "Yes, +1 for merging" and
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46832880
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044915#comment-15044915
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r46819640
--- Diff: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ---
@@ -196,4 +198,35 @@ public static String hostAndPortToUrlString(String
host,
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044972#comment-15044972
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user chiwanpark commented on the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1386
---
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
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2488.
---
> Expose attemptNumber in RuntimeContext
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2488.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via e8734b2452e31e7a35a20faaf6eb37fe59b6eff1
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1437#issuecomment-162525731
Aside from minor comments and the style issue it looks good. I'm not too
familiar with the internals of Kafka (which we are touching here, a bit),
though.
---
If
[
https://issues.apache.org/jira/browse/FLINK-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045048#comment-15045048
]
ASF GitHub Bot commented on FLINK-3113:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045098#comment-15045098
]
Chesnay Schepler commented on FLINK-3118:
-
can you try passing a MissingTypeInfo as input type to
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045110#comment-15045110
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044916#comment-15044916
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r46820392
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,16 +122,73 @@ abstract class ApplicationMasterBase {
[
https://issues.apache.org/jira/browse/FLINK-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044971#comment-15044971
]
Fabian Hueske commented on FLINK-3116:
--
Hi [~jaoki],
good finding of the {{RecordModelPostPass}} in
[
https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045029#comment-15045029
]
ASF GitHub Bot commented on FLINK-2897:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1292#discussion_r46828124
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputEmitter.java
---
@@ -143,16 +148,24 @@ public
[
https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045078#comment-15045078
]
ASF GitHub Bot commented on FLINK-3023:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045080#comment-15045080
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user StephanEwen commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r46821027
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,16 +122,73 @@ abstract class ApplicationMasterBase {
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045091#comment-15045091
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3128:
-
Assignee: Fridtjof Sander
> Add Isotonic Regression To ML Library
>
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1435#issuecomment-162549415
+1, please merge
Should we also remove the DataDistribution class? We can revamp it in a
better form with the global sorting pull request...
---
If your
[
https://issues.apache.org/jira/browse/FLINK-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045071#comment-15045071
]
ASF GitHub Bot commented on FLINK-3113:
---
Github user StephanEwen commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1436#issuecomment-162530467
Good catch, @jaoki and thanks for making me aware of this @zentol.
`Plan` was originally implemented for the Record API. For the later DataSet
API, `JavaPlan`
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044988#comment-15044988
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044999#comment-15044999
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user nikste commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045013#comment-15045013
]
Fridtjof Sander commented on FLINK-3128:
The algorithm is called "Pool Adjacent Violators", which
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044945#comment-15044945
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1416#issuecomment-162527425
Thanks for your work @rmetzger. I had some minor comments/questions for
clarification.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044974#comment-15044974
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user asfgit closed the pull request at:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1434#issuecomment-162532182
Very nice, I haven't yet gone through the code in detail but from the
description and doc it looks very good.
One thing I was confused about is the naming of
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1292#issuecomment-162547544
Will merge 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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1435#issuecomment-162555049
Makes sense...
---
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
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-162559507
Are inner classes of a class tagged as `PublicInterface` also marked as
public/stable?
---
If your project is set up for it, you can reply to this email and have
Ufuk Celebi created FLINK-3132:
--
Summary: Restructure streaming guide
Key: FLINK-3132
URL: https://issues.apache.org/jira/browse/FLINK-3132
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045054#comment-15045054
]
ASF GitHub Bot commented on FLINK-3113:
---
Github user fhueske commented on the pull request:
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1032#issuecomment-162550968
Hi @chiwanpark, thanks for picking this up. :)
Since a `Vector` might contain discrete fields as well as continuous
fields, we need to have a
[
https://issues.apache.org/jira/browse/FLINK-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045057#comment-15045057
]
ASF GitHub Bot commented on FLINK-2379:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045067#comment-15045067
]
Martin Junghanns commented on FLINK-3118:
-
If there is no objection, I would continue and
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045084#comment-15045084
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-162557821
Should we also change names of stuff or open separate Jiras, PRs. I'm
asking, for example, because of `CheckpointNotifier` which should be called
`CheckpointListener`
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045101#comment-15045101
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-2963:
-
Assignee: Robert Metzger
> Dependence on SerializationUtils#deserialize() should be
Maximilian Michels created FLINK-3133:
-
Summary: Introduce collect()/coun()/print() methods in DataStream
API
Key: FLINK-3133
URL: https://issues.apache.org/jira/browse/FLINK-3133
Project: Flink
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46837508
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045135#comment-15045135
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46837656
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Fetcher.java
---
@@ -61,15
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045162#comment-15045162
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46841698
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java
---
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045233#comment-15045233
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46845520
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/HeapStateStore.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045129#comment-15045129
]
ASF GitHub Bot commented on FLINK-2928:
---
Github user iampeter commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045128#comment-15045128
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045147#comment-15045147
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff in the pull
Fabian Hueske created FLINK-3135:
Summary: Add chainable driver for UNARY_NO_OP strategy
Key: FLINK-3135
URL: https://issues.apache.org/jira/browse/FLINK-3135
Project: Flink
Issue Type:
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46841544
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java
---
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045207#comment-15045207
]
Stephan Ewen commented on FLINK-3133:
-
They suggest very similar things (get an object from execute()
[
https://issues.apache.org/jira/browse/FLINK-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045214#comment-15045214
]
ASF GitHub Bot commented on FLINK-2928:
---
Github user StephanEwen commented on the pull request:
1 - 100 of 254 matches
Mail list logo
