[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15386896#comment-15386896
]
ASF GitHub Bot commented on FLINK-3929:
---
GitHub user vijikarthi opened a pull request:
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)
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=15386578#comment-15386578
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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=15386170#comment-15386170
]
Till Rohrmann commented on FLINK-4072:
--
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15386150#comment-15386150
]
ASF GitHub Bot commented on FLINK-4152:
---
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/2257#discussion_r71559450
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -113,7 +111,8 @@
/** The
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15386152#comment-15386152
]
ASF GitHub Bot commented on FLINK-4152:
---
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/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
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15386134#comment-15386134
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on a diff in the pull
[
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
[
https://issues.apache.org/jira/browse/FLINK-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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=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=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
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://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://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15386094#comment-15386094
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user aljoscha closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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.
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-4235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15386011#comment-15386011
]
Ufuk Celebi commented on FLINK-4235:
I saw the later issue (FLINK-4237) before this one and already
[
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.
>
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15385994#comment-15385994
]
Stavros Kontopoulos commented on FLINK-1984:
+1 make it major pls.
> Integrate Flink with
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=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=15385970#comment-15385970
]
Joan Goyeau commented on FLINK-1984:
Hi,
What is the status on this?
Why is this minor?
Cheers
>
[
https://issues.apache.org/jira/browse/FLINK-4050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385958#comment-15385958
]
Stephan Ewen commented on FLINK-4050:
-
Could you drop a code snippet of the API as you would want it
[
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=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
[
https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385946#comment-15385946
]
ASF GitHub Bot commented on FLINK-3729:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385918#comment-15385918
]
Stephan Ewen commented on FLINK-3695:
-
Makes sense.
You can probably still get started with these
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
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385905#comment-15385905
]
Greg Hogan commented on FLINK-3695:
---
[~StephanEwen] I was looking to use primitive arrays rather than
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385877#comment-15385877
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385874#comment-15385874
]
Greg Hogan commented on FLINK-3042:
---
That would be splendid!
> Define a way to let types create their
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
[
https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15385856#comment-15385856
]
Timo Walther commented on FLINK-3042:
-
If no one else wants to work on it, I could fix this issue and
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385854#comment-15385854
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the pull request:
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(
[
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
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385845#comment-15385845
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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
[
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=15385829#comment-15385829
]
ASF GitHub Bot commented on FLINK-4070:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385823#comment-15385823
]
ASF GitHub Bot commented on FLINK-4152:
---
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/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
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15385804#comment-15385804
]
ASF GitHub Bot commented on FLINK-4229:
---
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/2266#discussion_r71518447
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerMetricTest.java
---
@@ -50,9 +50,10 @@
public void
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385799#comment-15385799
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the pull request:
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(
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385797#comment-15385797
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user zentol commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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:
[
https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
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:
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
[
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=15385754#comment-15385754
]
Maximilian Michels commented on FLINK-3753:
---
Thanks for reporting! It actually states in the
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
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385737#comment-15385737
]
Stephan Ewen commented on FLINK-3695:
-
I would vote to try and have a generic type system extension
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385729#comment-15385729
]
Stephan Ewen commented on FLINK-3042:
-
You could do for a LongValue[] something like:
{code}
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
[
https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15385726#comment-15385726
]
ASF GitHub Bot commented on FLINK-4150:
---
Github user tillrohrmann commented on the issue:
1 - 100 of 117 matches
Mail list logo
