Github user mrakshay commented on the issue:
https://github.com/apache/flink/pull/2058
I have filed an issue on Flink ASF JIRA
[](https://issues.apache.org/jira/issues/?filter=-1)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Akshay Shingote created FLINK-4008:
--
Summary: Hello,I am not able to create jar of
flink-streaming-connectors ...I am able to create jar of others like
twitter,kafka,flume but I am not able to create jar of flink-streaming
connectors ?? How can
Akshay Shingote created FLINK-4007:
--
Summary: Flink Kafka Consumer throws Null Pointer Exception when
using DataStream keyBy
Key: FLINK-4007
URL: https://issues.apache.org/jira/browse/FLINK-4007
Proj
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4006:
--
Attachment: FLINK-4006.patch
> ExecutionGraph.restartStrategy field can't be serialized
> --
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4006:
--
Description:
Exception is following
```
java.io.NotSerializableException:
org.apache.flink.runtime.exec
ZhengBowen created FLINK-4006:
-
Summary: ExecutionGraph.restartStrategy field can't be serialized
Key: FLINK-4006
URL: https://issues.apache.org/jira/browse/FLINK-4006
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311626#comment-15311626
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user skavulya commented on the issue
Github user skavulya commented on the issue:
https://github.com/apache/flink/pull/1985
While working on L-BFGS, I realized that I need to remove the gradient
descent step from RegularizationPenalty. I'll update the PR soon.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rekha Joshi updated FLINK-4000:
---
Assignee: (was: Rekha Joshi)
> Exception: Could not restore checkpointed state to operators and fu
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311404#comment-15311404
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311403#comment-15311403
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm commented on the iss
Github user rekhajoshm closed the pull request at:
https://github.com/apache/flink/pull/2061
---
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 rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2061
aha, in one of my intermediate runs had done just initializing
idsProcessedButNotAcknowledged and retain pendingCheckpoints , but in last run
changed it calling open() :-( . makes sense @asavarts
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311395#comment-15311395
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asavartsov commented on the iss
Github user asavartsov commented on the issue:
https://github.com/apache/flink/pull/2061
Take a look at my pull request at https://github.com/apache/flink/pull/2062
---
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
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311375#comment-15311375
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm commented on the iss
Github user rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2061
@asavartsov Ok. Please let me know how you propose to solve this? 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 pro
Github user asavartsov commented on the issue:
https://github.com/apache/flink/pull/2061
No, it does not make any sense and even makes things worse, sorry.
---
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 pro
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311362#comment-15311362
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asavartsov commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311356#comment-15311356
]
ASF GitHub Bot commented on FLINK-4000:
---
GitHub user asavartsov opened a pull reques
GitHub user asavartsov opened a pull request:
https://github.com/apache/flink/pull/2062
[FLINK-4000] Fix for checkpoint state restore at
MessageAcknowledgingSourceBase
As says documentation for MessageAcknowledgingSourceBase.restoreState()
This method is invoked when a fun
Github user skavulya commented on the issue:
https://github.com/apache/flink/pull/1985
Thanks @chiwanpark. I made the changes you recommended. Please let me know
if it looks ok.
---
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-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311314#comment-15311314
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user skavulya commented on the issue
Ufuk Celebi created FLINK-4005:
--
Summary: LocalExecutorITCase.testLocalExecutorWithWordCount fails
Key: FLINK-4005
URL: https://issues.apache.org/jira/browse/FLINK-4005
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311206#comment-15311206
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm commented on the iss
Github user rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2061
I agree @asavartsov , that was a quick look and was working to
reproduce.Does the updated make sense? thank you.
---
If your project is set up for it, you can reply to this email and have your
re
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311152#comment-15311152
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asavartsov commented on the iss
Github user asavartsov commented on the issue:
https://github.com/apache/flink/pull/2061
This kind of check is might be useless and probably wouldn't fix the issue.
My debugging shows that the list `idsProcessedButNotAcknowledged` is null on
recovery, not checkpoints itself. This list
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311087#comment-15311087
]
ASF GitHub Bot commented on FLINK-4000:
---
GitHub user rekhajoshm opened a pull reques
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/2061
[FLINK-4000] Checkpoint dictionaries null after taskmgr failures
Fix for exception during job restart after task mgr failure, at which point
restoreState fails as checkpoint dictionaries can be n
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rekha Joshi reassigned FLINK-4000:
--
Assignee: Rekha Joshi
> Exception: Could not restore checkpointed state to operators and functi
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311043#comment-15311043
]
ASF GitHub Bot commented on FLINK-3921:
---
GitHub user rekhajoshm opened a pull reques
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/2060
[FLINK-3921] StringParser encoding
Corrected StringParser encoding
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rekhajoshm/flink FLINK-3921
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rekha Joshi reassigned FLINK-3921:
--
Assignee: Rekha Joshi
> StringParser not specifying encoding to use
> -
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2058
Can you please close this pull request and pose this as a question in the
mailing list?
---
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-4003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310841#comment-15310841
]
ASF GitHub Bot commented on FLINK-4003:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2059
[FLINK-4003] Use intrinsics for MathUtils logarithms
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
4003_use_intrinsics_for_
Robert Metzger created FLINK-4004:
-
Summary: Do not pass custom flink kafka connector properties to
Kafka to avoid warnings
Key: FLINK-4004
URL: https://issues.apache.org/jira/browse/FLINK-4004
Projec
[
https://issues.apache.org/jira/browse/FLINK-3971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310722#comment-15310722
]
ASF GitHub Bot commented on FLINK-3971:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2049
Thanks for the PR @gallenvara. I'm currently on vacation with limited
access to internet. Will review your PR when I am back in roughly a week.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-1984:
Description:
There are some users asking for an integration of Flink into Mesos.
-There also is a p
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-1984:
Description:
There are some users asking for an integration of Flink into Mesos.
-There also is a p
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2007
then make parseField protected so users MUST call resetErrorStateAndParse.
there, problem solved.
---
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-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310646#comment-15310646
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user zentol commented on the issue:
Greg Hogan created FLINK-4003:
-
Summary: Use intrinsics for MathUtils logarithms
Key: FLINK-4003
URL: https://issues.apache.org/jira/browse/FLINK-4003
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310523#comment-15310523
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on the issue:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/1517
Hi @fhueske,
Thanks for the comments, I think I have addressed all of them.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310486#comment-15310486
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user fpompermaier commented on the i
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65383363
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/RandomAccessInputView.java
---
@@ -45,7 +45,12 @@ public RandomAccessInputView(ArrayLis
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310475#comment-15310475
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/2007
I think that leaving the responsibility of calling
resetErrorStateAndParse() to "consumers" of FieldParser is really a bad idea.
Isn't safer to force its call using the strategy adopted in this
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65376284
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310421#comment-15310421
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310392#comment-15310392
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310389#comment-15310389
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65371629
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/CompactingHashTableTest.java
---
@@ -252,4 +262,81 @@ private static String getL
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310391#comment-15310391
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65371616
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/MemoryHashTableTestCommon.java
---
@@ -0,0 +1,666 @@
+/*
+ * Licensed to
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65371572
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedReduceCombineDriver.java
---
@@ -0,0 +1,305 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310383#comment-15310383
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/2007
i believe what Stephan meant was the following:
* keep the abstract parseField method in FieldParser
* add a new method to FieldParser called resetErrorStateAndParse, which
calls resetPa
[
https://issues.apache.org/jira/browse/FLINK-3993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310362#comment-15310362
]
ASF GitHub Bot commented on FLINK-3993:
---
Github user asfgit closed the pull request
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/2057
Please move the change to the parameter tool exception into a separate
commit.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
[
https://issues.apache.org/jira/browse/FLINK-3993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-3993.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Implemented in b201f8664c9814b6e0a0f5149338e
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2055
---
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-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310350#comment-15310350
]
ASF GitHub Bot commented on FLINK-3806:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/2036
Travis CI is now green.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310328#comment-15310328
]
Alexey Savartsov commented on FLINK-4000:
-
I can confirm this issue with RMQSource
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310323#comment-15310323
]
Aride Chettali commented on FLINK-4000:
---
Thank you for the quick response.
Yes I am
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aride Chettali updated FLINK-4000:
--
Comment: was deleted
(was: I was using the default state check-points (in-memory).
And I have f
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310276#comment-15310276
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65356958
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310275#comment-15310275
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310273#comment-15310273
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65356908
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the Apac
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65356863
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310265#comment-15310265
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chobeat commented on a diff in
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65356053
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310257#comment-15310257
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65355487
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310251#comment-15310251
]
Aride Chettali commented on FLINK-4000:
---
I was using the default state check-points
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310250#comment-15310250
]
Aride Chettali commented on FLINK-4000:
---
I was using the default state check-points
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aride Chettali updated FLINK-4000:
--
Comment: was deleted
(was: I was using the default state check-points (in-memory).
And I have
[
https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310246#comment-15310246
]
ASF GitHub Bot commented on FLINK-3945:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/2021
I'll merge this if there are no further comments.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310227#comment-15310227
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user fpompermaier commented on the p
Github user fpompermaier commented on the pull request:
https://github.com/apache/flink/pull/2007
How should I proceed here?
---
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
enabl
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1978#discussion_r65348898
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/Client.java ---
@@ -100,6 +102,9 @@
*/
private JobID lastJobID;
+
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310218#comment-15310218
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1978
@rmetzger I've updated the pull request and would like to get your opinion
on it again. I've addressed all your comments. Specifically, I've removed all
Yarn code from the CliFrontend. I've clarif
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310217#comment-15310217
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1978#discussion_r65349622
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java ---
@@ -211,14 +191,41 @@ public void run() {
Runtime.getRuntime()
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1978#discussion_r65348868
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -20,8 +20,6 @@
--- End diff --
Done.
---
If your projec
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310210#comment-15310210
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310211#comment-15310211
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310194#comment-15310194
]
ASF GitHub Bot commented on FLINK-2314:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/2020
The input formats still have a leftover field that stores the split.
After that, the only thing that remains is the API methods. Also what was
the reason for the new code in `StreamFa
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310188#comment-15310188
]
ASF GitHub Bot commented on FLINK-2314:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2020#discussion_r65347119
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java
---
@@ -104,8 +106,21 @@ public void runCheckpoint
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310186#comment-15310186
]
Christophe S commented on FLINK-2765:
-
Great! Almost all distro are in 1.1 or 1.2.
>
1 - 100 of 143 matches
Mail list logo
