[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386896#comment-15386896
]
ASF GitHub Bot commented on FLINK-3929:
---
GitHub user vijikarthi opened a pull reques
GitHub user vijikarthi opened a pull request:
https://github.com/apache/flink/pull/2275
FLINK-3929 Support for Kerberos Authentication with Keytab Credential
This PR addresses FLINK-3929 requirements:
1) Added Keytab support to Flink (Standalone and Yarn mode deployment)
2) U
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
Last build failed on an outdated version of this branch. Pushed an updated
and fixed version of this PR to trigger build on a newer version.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386578#comment-15386578
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386503#comment-15386503
]
ASF GitHub Bot commented on FLINK-4238:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2273
Since we now have separate branches for both sink types it may be
worthwhile to move these checks completely into the respective
`CassandraXXXSinkBuilder` classes. Otherwise, +1.
---
If your project
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2274
[FLINK-4180] [FLINK-4181] [table] add Batch SQL and Stream SQL and Stream
Table API examples
[FLINK-4180] [FLINK-4181] [table] add Batch SQL and Stream SQL and Stream
Table API examples
I
[
https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386170#comment-15386170
]
Till Rohrmann commented on FLINK-4072:
--
Another instance:
https://s3.amazonaws.com/a
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386164#comment-15386164
]
ASF GitHub Bot commented on FLINK-4180:
---
GitHub user wuchong opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386150#comment-15386150
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386152#comment-15386152
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71559450
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -113,7 +111,8 @@
/** The servic
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71559335
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +405,23 @@ class JobManager(
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71557572
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -87,6 +93,
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386134#comment-15386134
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-4224:
---
Assignee: Aljoscha Krettek
> Exception after successful execution os job submitted th
[
https://issues.apache.org/jira/browse/FLINK-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386124#comment-15386124
]
ASF GitHub Bot commented on FLINK-4238:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2273
[FLINK-4238] Only allow/require query for Tuple Stream in CassandraSink
R: @zentol for review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/al
Aljoscha Krettek created FLINK-4238:
---
Summary: Only allow/require query for Tuple Stream in CassandraSink
Key: FLINK-4238
URL: https://issues.apache.org/jira/browse/FLINK-4238
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386105#comment-15386105
]
ASF GitHub Bot commented on FLINK-3956:
---
Github user kl0u closed the pull request at
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386108#comment-15386108
]
ASF GitHub Bot commented on FLINK-3956:
---
Github user kl0u commented on the issue:
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/2270
---
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 kl0u commented on the issue:
https://github.com/apache/flink/pull/2270
Done! Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4229.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3956.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386094#comment-15386094
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2266
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is en
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386088#comment-15386088
]
ASF GitHub Bot commented on FLINK-3956:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2270
Merged it. Could you please close this PR and mark the Jira as resolved?
---
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-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386045#comment-15386045
]
ASF GitHub Bot commented on FLINK-4231:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2272
[FLINK-4231] [java] Switch DistinctOperator from GroupReduce to Reduce
Rewrite the DistinctOperator using Reduce to support both the sort-based
combine and the recently added hash-based combine. T
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386059#comment-15386059
]
ASF GitHub Bot commented on FLINK-3956:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2270
Thanks a lot @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 so,
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386055#comment-15386055
]
ASF GitHub Bot commented on FLINK-3956:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2270
Perfect! I'll merge right away.
---
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-4235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386011#comment-15386011
]
Ufuk Celebi commented on FLINK-4235:
I saw the later issue (FLINK-4237) before this on
[
https://issues.apache.org/jira/browse/FLINK-4237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4237.
--
Resolution: Duplicate
I'm closing this, because FLINK-4235 was created before this issue.
> ClassLoader
[
https://issues.apache.org/jira/browse/FLINK-4235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4235:
--
Assignee: Ufuk Celebi
> ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Tr
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2271
[FLINK-4202] Add restarting time JM metric
This PR adds a JM metric which shows the time it took to restart a job. The
time is
measured between entering the JobStatus.RESTARTING and reachin
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2270
[FLINK-3956] Make FileInputFormats independent from Configuration
This PR makes all the parameters from the input formats accessible through
setters.
Before, some could only be set through a config
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15386005#comment-15386005
]
ASF GitHub Bot commented on FLINK-3956:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385994#comment-15385994
]
Stavros Kontopoulos commented on FLINK-1984:
+1 make it major pls.
> Integrat
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2266
Thanks for reviewing! I'll merge in a bit.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385975#comment-15385975
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385970#comment-15385970
]
Joan Goyeau commented on FLINK-1984:
Hi,
What is the status on this?
Why is this minor
[
https://issues.apache.org/jira/browse/FLINK-4050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385958#comment-15385958
]
Stephan Ewen commented on FLINK-4050:
-
Could you drop a code snippet of the API as you
[
https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3729.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 6ab96a7bbe5a65db1e0aa683380fbde55883607f.
[
https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385915#comment-15385915
]
ASF GitHub Bot commented on FLINK-3729:
---
Github user twalthr commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2238
---
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-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385946#comment-15385946
]
ASF GitHub Bot commented on FLINK-3729:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385918#comment-15385918
]
Stephan Ewen commented on FLINK-3695:
-
Makes sense.
You can probably still get starte
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2238
LGTM. I will merge it. Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and w
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385905#comment-15385905
]
Greg Hogan commented on FLINK-3695:
---
[~StephanEwen] I was looking to use primitive array
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385878#comment-15385878
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2266
+1
---
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 i
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2266#discussion_r71527251
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerMetricTest.java
---
@@ -50,9 +50,10 @@
public void testJobManagerM
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385877#comment-15385877
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385874#comment-15385874
]
Greg Hogan commented on FLINK-3042:
---
That would be splendid!
> Define a way to let type
Kostas Kloudas created FLINK-4237:
-
Summary: ClassLoaderITCase.testDisposeSavepointWithCustomKvState
fails due to Timeout Futures
Key: FLINK-4237
URL: https://issues.apache.org/jira/browse/FLINK-4237
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2194
Magic number mismatch will fail with an error message stating that a likely
cause for this is resuming from Flink 1.0 savepoints, which is not supported.
I've removed the legacy classes and undid the ren
[
https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385860#comment-15385860
]
ASF GitHub Bot commented on FLINK-4067:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385856#comment-15385856
]
Timo Walther commented on FLINK-3042:
-
If no one else wants to work on it, I could fix
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385854#comment-15385854
]
ASF GitHub Bot commented on FLINK-4152:
---
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/2257#discussion_r71523881
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +405,23 @@ class JobManager(
currentR
[
https://issues.apache.org/jira/browse/FLINK-4237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4237:
--
Assignee: Ufuk Celebi
> ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Ti
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385845#comment-15385845
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385847#comment-15385847
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2257
Thank you for taking the time to revise some parts of the PR! I like the
changes. The eventual resource registration has been re-introduced but
simplified to only acknowledge the registration of TaskMana
[
https://issues.apache.org/jira/browse/FLINK-4237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4237:
--
Labels: test-stability (was: )
> ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71522922
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -113,7 +111,8 @@
/** The service to find
[
https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4070.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 130511ffc379e3096baf5e8f19bd34c4e508b3f7.
[
https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385829#comment-15385829
]
ASF GitHub Bot commented on FLINK-4070:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2120
---
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-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385823#comment-15385823
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71520071
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +405,23 @@ class JobManager(
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2245
Thanks a lot @tillrohrmann !
I integrated your comment.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385805#comment-15385805
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385804#comment-15385804
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2266
Dammit, I thought about the doc but then forgot... changing.
---
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
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2266#discussion_r71518447
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerMetricTest.java
---
@@ -50,9 +50,10 @@
public void testJobManage
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385799#comment-15385799
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385797#comment-15385797
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user zentol commented on a diff in t
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71517956
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +405,23 @@ class JobManager(
currentR
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2266#discussion_r71517800
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerMetricTest.java
---
@@ -50,9 +50,10 @@
public void testJobManagerM
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385795#comment-15385795
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2266
The documentation for JMX wasn't updated; it still references
`metrics.jmx.port`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
Gary Yao created FLINK-4236:
---
Summary: Flink Dashboard stops showing list of uploaded jars if
main method cannot be looked up
Key: FLINK-4236
URL: https://issues.apache.org/jira/browse/FLINK-4236
Project: F
[
https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385765#comment-15385765
]
ASF GitHub Bot commented on FLINK-4070:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2120
Yes I think renaming makes sense as we both didn't find the method at first
glance. I will finalize your PR so that it will be included in the release.
---
If your project is set up for it, you can
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2259
---
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 the issue:
https://github.com/apache/flink/pull/2259
Changes look good to me. Thanks for your work @kl0u. Will 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 p
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2245
Changes look good @kl0u. Good work :-) There is only a minor issue with one
of the test cases and its exception handling.
---
If your project is set up for it, you can reply to this email and h
Till Rohrmann created FLINK-4235:
Summary: ClassLoaderITCase.testDisposeSavepointWithCustomKvState
timed out on Travis
Key: FLINK-4235
URL: https://issues.apache.org/jira/browse/FLINK-4235
Project: Fl
Till Rohrmann created FLINK-4234:
Summary: CassandraConnectorTest causes travis build to time out
Key: FLINK-4234
URL: https://issues.apache.org/jira/browse/FLINK-4234
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3753.
---
Resolution: Won't Fix
> KillerWatchDog should not use kill on toKill thread
>
[
https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385754#comment-15385754
]
Maximilian Michels commented on FLINK-3753:
---
Thanks for reporting! It actually s
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2245#discussion_r71512375
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisSinkTest.java
---
@@ -41,6 +50
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385737#comment-15385737
]
Stephan Ewen commented on FLINK-3695:
-
I would vote to try and have a generic type sys
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15385729#comment-15385729
]
Stephan Ewen commented on FLINK-3042:
-
You could do for a LongValue[] something like:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2256
Changes look good to me :-). Really good work @uce. I'm just wondering
whether we could remove empty folders upon shutdown of the `BlobStore`. Apart
from that, +1 for merging.
---
If your proj
1 - 100 of 118 matches
Mail list logo
