[
https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495665#comment-15495665
]
Aljoscha Krettek commented on FLINK-4620:
-
I think FLINK-4511 is the specific issu
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495761#comment-15495761
]
Aljoscha Krettek commented on FLINK-3869:
-
I have another proposal for solving thi
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2504
[FLINK-4590] [table] Some Table API tests are failing when debug lvl is set
to DEBUG
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495808#comment-15495808
]
ASF GitHub Bot commented on FLINK-4590:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-4581:
---
Assignee: Timo Walther
> Table API throws "No suitable driver found for jdbc:calcite"
> -
[
https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495883#comment-15495883
]
ASF GitHub Bot commented on FLINK-4589:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2476
---
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 mxm commented on the issue:
https://github.com/apache/flink/pull/2499
Thanks! Just a few words to @nielsbasjes who reported the issue. I've
tested the fix using the test instructions you provided. Even before this fix,
I could get rid of the temp files by forcing a manual
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495900#comment-15495900
]
ASF GitHub Bot commented on FLINK-4485:
---
Github user mxm commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2499
What would the fix for the TaskManager look like? Simply explicitly closing
the UserCodeClassloader, or does it need more?
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495910#comment-15495910
]
ASF GitHub Bot commented on FLINK-4485:
---
Github user StephanEwen commented on the is
Maximilian Michels created FLINK-4628:
-
Summary: User class loader unavailable during input split
assignment
Key: FLINK-4628
URL: https://issues.apache.org/jira/browse/FLINK-4628
Project: Flink
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2499
@StephanEwen Yes, it is simple. I just pushed a commit. This now releases
all temp files after job completion.
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495940#comment-15495940
]
ASF GitHub Bot commented on FLINK-4485:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495945#comment-15495945
]
Flavio Pompermaier commented on FLINK-4628:
---
Could this be also the cause of
ht
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2489
merging
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495953#comment-15495953
]
ASF GitHub Bot commented on FLINK-4607:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2488
merging
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495952#comment-15495952
]
ASF GitHub Bot commented on FLINK-4608:
---
Github user zentol commented on the issue:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2505
[FLINK-4628] provide user class loader during input split assignment
In analogy to the configure() method, this also sets a context class loader
during input split assignment.
You can merge this pull r
[
https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4626:
---
Assignee: Chesnay Schepler
> Missing break in MetricStore#add()
> ---
[
https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4626:
Component/s: Metrics
> Missing break in MetricStore#add()
>
[
https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4626:
Affects Version/s: 1.2.0
> Missing break in MetricStore#add()
>
[
https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495956#comment-15495956
]
ASF GitHub Bot commented on FLINK-4628:
---
GitHub user mxm opened a pull request:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2492
merging
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495962#comment-15495962
]
ASF GitHub Bot commented on FLINK-4612:
---
Github user zentol commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2492
---
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/2489
---
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-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4626.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 1586fc8cfc6f41244e46b27ad25dcb6b08b7ce4
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2488
---
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-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4608.
---
Resolution: Fixed
Fixed in ceb3aa05bae3d05b9f6c5a7a55e6e43fc91a9450
> Use short-circuit AND i
[
https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495978#comment-15495978
]
ASF GitHub Bot commented on FLINK-4612:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495980#comment-15495980
]
ASF GitHub Bot commented on FLINK-4607:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4612.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in f06930bcf0d3c2a840cdc5a2e6e5f4b1d03f45d
[
https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495979#comment-15495979
]
ASF GitHub Bot commented on FLINK-4608:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495983#comment-15495983
]
Chesnay Schepler edited comment on FLINK-4608 at 9/16/16 10:38 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4607.
---
Resolution: Fixed
Fixed in db90580ffdb93a55a6318b18b5d50ec3666b001b
> Close FileInputStream i
[
https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-4608:
-
> Use short-circuit AND in Max/Min AggregationFunction
> -
[
https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4608.
---
Resolution: Fixed
> Use short-circuit AND in Max/Min AggregationFunction
> ---
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2506
[FLINK-4581] [table] Table API throws "No suitable driver found for
jdbc:calcite"
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list in
[
https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496007#comment-15496007
]
ASF GitHub Bot commented on FLINK-4581:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-4252:
---
Assignee: Timo Walther
> Table program cannot be compiled
>
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2275
@vijikarthi Thanks for the update. Great to see the tests are passing now.
I'm curious, why did this issue only appear on Travis and not locally?
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496069#comment-15496069
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79151542
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -161,6 +161,8 @@ public CliFrontend(String configDir) throws Exception {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79151877
--- Diff: flink-dist/src/main/flink-bin/conf/flink-jaas.conf ---
@@ -0,0 +1,26 @@
+###
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79154987
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1585,6 +1585,8 @@ object TaskManager {
}
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79152195
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -155,6 +157,58 @@ public static void install(SecurityConfigur
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79154968
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -155,6 +157,58 @@ public static void install(SecurityConfigur
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79156099
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -1233,6 +1239,9 @@
/** ZooKeeper default leader port. */
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79153795
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@ -14
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79152436
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -79,9 +82,8 @@ public static void install(SecurityConfigurati
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79153661
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@ -26
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79155885
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -158,22 +157,37 @@ public static void install(SecurityConfigu
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79153742
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@ -36
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496152#comment-15496152
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496148#comment-15496148
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496149#comment-15496149
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496151#comment-15496151
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496156#comment-15496156
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496154#comment-15496154
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496150#comment-15496150
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496155#comment-15496155
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496158#comment-15496158
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496153#comment-15496153
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496157#comment-15496157
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496164#comment-15496164
]
ASF GitHub Bot commented on FLINK-4622:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2501
merging
---
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 feat
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2501
---
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-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4622.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in d7b59d761601baba6765bb4fc407bcd9f
[
https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496172#comment-15496172
]
ASF GitHub Bot commented on FLINK-4622:
---
Github user asfgit closed the pull request
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r79156877
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
---
@@ -241,8 +255,11 @@ private static Options
getSavepointOptionsWith
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r79157293
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs a program.
java.net.URLClassLoader
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496179#comment-15496179
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496180#comment-15496180
]
ASF GitHub Bot commented on FLINK-4084:
---
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/2149#discussion_r79157764
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs a program.
java.net.URLClassLoader
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496185#comment-15496185
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2507
[FLINK-4252] [table] Validate input and output classes of Table API
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideratio
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496227#comment-15496227
]
ASF GitHub Bot commented on FLINK-4252:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-4393.
---
Resolution: Won't Fix
This issue does not describe a bug.
> Failed to serialize accumulators for task
[
https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-4288:
---
Assignee: Timo Walther
> Make it possible to unregister tables
>
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2297
If there are no objections, I would like to merge this PR next week. Other
my other PRs depend on this.
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496347#comment-15496347
]
ASF GitHub Bot commented on FLINK-4081:
---
Github user twalthr commented on the issue:
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
>
@vijikarthi Thanks for the update. Great to see the tests are passing now.
I'm curious, why did this issue only appear on Travis and not locally?
Kafka/ZK connection is unusually lon
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496542#comment-15496542
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79190433
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -1233,6 +1239,9 @@
/** ZooKeeper default leader port.
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496555#comment-15496555
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496768#comment-15496768
]
Fabian Hueske commented on FLINK-2662:
--
I found the root cause of this problem. The p
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79221107
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -161,6 +161,8 @@ public CliFrontend(String configDir) throws Exceptio
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496955#comment-15496955
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r79221254
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -155,6 +157,58 @@ public static void install(SecurityC
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496957#comment-15496957
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
@mxm I have addressed some of the review feedback and rebased to upstream
master.
---
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-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496973#comment-15496973
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
Mariano Gonzalez created FLINK-4629:
---
Summary: Kafka v 0.10 Support
Key: FLINK-4629
URL: https://issues.apache.org/jira/browse/FLINK-4629
Project: Flink
Issue Type: Wish
Reporte
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/2508
[FLINK-2662] [dataSet] Translate union with multiple output into separate
unions with single output.
Fixes FLINK-2662 by translating Union operators with two (or more)
successors into two or more U
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497564#comment-15497564
]
ASF GitHub Bot commented on FLINK-2662:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-2662:
Assignee: Fabian Hueske
> CompilerException: "Bug: Plan generation for Unions picked a ship
98 matches
Mail list logo
