[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046534#comment-15046534
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user chiwanpark commented on the pul
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 does
[
https://issues.apache.org/jira/browse/FLINK-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046511#comment-15046511
]
Matthias J. Sax commented on FLINK-3096:
https://travis-ci.org/mjsax/flink/jobs/95
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
C
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 too?
[
https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046483#comment-15046483
]
ASF GitHub Bot commented on FLINK-3077:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046476#comment-15046476
]
ASF GitHub Bot commented on FLINK-2928:
---
Github user sachingoel0101 commented on the
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 thi
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: Sub-tas
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 Type:
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
Co
[
https://issues.apache.org/jira/browse/FLINK-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046159#comment-15046159
]
Ted Yu commented on FLINK-3137:
---
I want to point out that current code is prone to bug which
[
https://issues.apache.org/jira/browse/FLINK-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046040#comment-15046040
]
ASF GitHub Bot commented on FLINK-3108:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046038#comment-15046038
]
ASF GitHub Bot commented on FLINK-3112:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046039#comment-15046039
]
ASF GitHub Bot commented on FLINK-3113:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1436
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1435
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1440
---
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 jaoki commented on the pull request:
https://github.com/apache/flink/pull/1436#issuecomment-162690732
@fhueske , I'm glad to make myself a bit useful to the project. :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-3112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045901#comment-15045901
]
ASF GitHub Bot commented on FLINK-3112:
---
Github user jaoki commented on the pull req
Stephan Ewen created FLINK-3138:
---
Summary: Method References are not supported as lambda expressions
Key: FLINK-3138
URL: https://issues.apache.org/jira/browse/FLINK-3138
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045849#comment-15045849
]
ASF GitHub Bot commented on FLINK-3108:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1440#issuecomment-162681503
Thanks for fixing this so quickly @twalthr! I confirm it solves my problem
:)
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-3112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045846#comment-15045846
]
ASF GitHub Bot commented on FLINK-3112:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045847#comment-15045847
]
ASF GitHub Bot commented on FLINK-3113:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045845#comment-15045845
]
ASF GitHub Bot commented on FLINK-3108:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1435#issuecomment-162680969
Going to merge 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 your project does not have thi
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1436#issuecomment-162680884
Going to merge 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 your project does not have thi
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1440#issuecomment-162680769
Going to merge 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 your project does not have thi
[
https://issues.apache.org/jira/browse/FLINK-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045813#comment-15045813
]
ASF GitHub Bot commented on FLINK-3108:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1440#issuecomment-162676214
Good catches, thanks!
+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 pr
[
https://issues.apache.org/jira/browse/FLINK-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045751#comment-15045751
]
Ted Yu commented on FLINK-3137:
---
I see.
A comment would help people who later look at this c
[
https://issues.apache.org/jira/browse/FLINK-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3137.
Resolution: Not A Problem
Thanks for creating this issue.
The missing break is OK in this case.
Fo
Ted Yu created FLINK-3137:
-
Summary: Missing break in OutputEmitter ctor
Key: FLINK-3137
URL: https://issues.apache.org/jira/browse/FLINK-3137
Project: Flink
Issue Type: Bug
Reporter: Ted
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045666#comment-15045666
]
ASF GitHub Bot commented on FLINK-2828:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1237#issuecomment-162654340
You are right of course and I'm sorry I didn't put in the required time
earlier.
Your are also right about the Calcite thing. If we decide to use calcite
and h
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045583#comment-15045583
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1437#issuecomment-162640162
Looks pretty good.
+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 proje
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045552#comment-15045552
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1437#issuecomment-162634935
Thank you for the good reviews!
I've addressed all comments.
The entire kafka connector is now using a space after `if` and `for`.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045550#comment-15045550
]
ASF GitHub Bot commented on FLINK-3108:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1440
[FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor
method
This PR fixes FLINK-3108 and updates all remaining calls to the
TypeExtractor for supporting TypeHints.
You can merge
Stephan Ewen created FLINK-3136:
---
Summary: Scala Closure Cleaner uses wrong ASM import
Key: FLINK-3136
URL: https://issues.apache.org/jira/browse/FLINK-3136
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045519#comment-15045519
]
Timo Walther edited comment on FLINK-2099 at 12/7/15 7:08 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045519#comment-15045519
]
Timo Walther commented on FLINK-2099:
-
Hi Ovidiu,
thanks for your interest. Actually I
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1237#issuecomment-162622155
So basically what you want to say is: throw your entire code away.
I'm disappointed that you think about the whole concept now, after I have
rebased and reworked the
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045471#comment-15045471
]
ASF GitHub Bot commented on FLINK-2828:
---
Github user twalthr commented on the pull r
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46858130
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -440,4 +478,228 @@ private void configur
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045453#comment-15045453
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045430#comment-15045430
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46857083
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -440,4 +478,228 @@ private void configur
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46856784
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -440,4 +478,228 @@ private void configur
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045422#comment-15045422
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46856258
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -440,4 +478,228 @@ private void configur
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045410#comment-15045410
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46855123
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -440,4 +478,228 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045392#comment-15045392
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46850717
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -753,7 +841,11 @@ class JobManager(
* @param
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1255#issuecomment-162608149
Hi @ChengXiangLi, I tried the PR locally on my machine and it was working
quite well.
I found a few minor issues:
- You don't need to set keys and sort order for
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045351#comment-15045351
]
ASF GitHub Bot commented on FLINK-7:
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045313#comment-15045313
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045311#comment-15045311
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46850538
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -495,6 +513,76 @@ class JobManager(
case che
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045308#comment-15045308
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045306#comment-15045306
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46850418
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -495,6 +513,76 @@ class JobManager(
case che
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46850340
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -495,6 +513,76 @@ class JobManager(
case che
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045301#comment-15045301
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46850082
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -336,7 +354,7 @@ class JobManager(
val cli
[
https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1278.
---
> Remove the Record special code paths
>
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1278.
-
Resolution: Fixed
Assignee: Stephan Ewen
Done in 0cae3eae27b4bdb48eee061be141c20240327798
>
[
https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045284#comment-15045284
]
ASF GitHub Bot commented on FLINK-2897:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2897.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via 22ac65ba788b8c5a0c1298d78bfb51ad65d8d00c
[
https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2897.
---
> Use distinct initial indices for OutputEmitter round-robin
> ---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1292
---
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 tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46847734
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Savepoint.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045260#comment-15045260
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045254#comment-15045254
]
Stephan Ewen commented on FLINK-3133:
-
IIRC, "fuzzy duplicate" is a fix term that says
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045242#comment-15045242
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46846360
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/HeapStateStore.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-3132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045240#comment-15045240
]
Aljoscha Krettek commented on FLINK-3132:
-
We can add sub issues for individual pa
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045237#comment-15045237
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46845825
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SavepointCoordinator.java
---
@@ -0,0 +1,359 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045233#comment-15045233
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user tillrohrmann commented on a dif
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 Apach
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46841758
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-162578546
I created a patch of changes in the Stream API that I would propose:
[stream-api-annotations.patch.txt](https://github.com/apache/flink/files/54231/stream-api-a
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46840459
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045220#comment-15045220
]
Maximilian Michels commented on FLINK-3133:
---
Linking makes sense but not as a du
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46840339
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46840304
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -630,6 +638,136 @@ protected int cancel(String[] args) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1434#discussion_r46839601
--- Diff: docs/apis/savepoints.md ---
@@ -0,0 +1,108 @@
+---
+title: "Savepoints"
+is_beta: false
+---
+
+
+Programs written i
[
https://issues.apache.org/jira/browse/FLINK-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045214#comment-15045214
]
ASF GitHub Bot commented on FLINK-2928:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1421#issuecomment-162585460
I like that solution, @iampeter
---
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
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045207#comment-15045207
]
Stephan Ewen commented on FLINK-3133:
-
They suggest very similar things (get an object
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-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045200#comment-15045200
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1437#issuecomment-162580468
All in all quite good. Few things:
- The code style is super heterogeneous, sometimes it puts spaces after a
keyword, sometimes it does not. Would be good
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045198#comment-15045198
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045197#comment-15045197
]
ASF GitHub Bot commented on FLINK-3102:
---
Github user StephanEwen commented on a diff
1 - 100 of 276 matches
Mail list logo
