[
https://issues.apache.org/jira/browse/FLINK-2560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2560:
---
Issue Type: Improvement (was: Bug)
> Flink-Avro Plugin cannot be handled by Eclipse
> ---
[
https://issues.apache.org/jira/browse/FLINK-2560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707661#comment-14707661
]
ASF GitHub Bot commented on FLINK-2560:
---
GitHub user mjsax opened a pull request:
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/1041
[FLINK-2560] Flink-Avro Plugin cannot be handled by Eclipse
- disabled avro-maven-plugin within Eclipse via ...
You can merge this pull request into a Git repository by running:
$ git pull h
Matthias J. Sax created FLINK-2560:
--
Summary: Flink-Avro Plugin cannot be handled by Eclipse
Key: FLINK-2560
URL: https://issues.apache.org/jira/browse/FLINK-2560
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707652#comment-14707652
]
ASF GitHub Bot commented on FLINK-2553:
---
Github user mjsax commented on a diff in th
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/1037#discussion_r37687901
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountRemot
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707651#comment-14707651
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-133591848
Okay. You don't need to hurry.
---
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-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707506#comment-14707506
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/1039#discussion_r37681294
--- Diff: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ---
@@ -48,8 +48,9 @@ public static String getHostnameFromFQDN(String fqdn) {
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/1039#discussion_r37681201
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkLocalCluster.java
--
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707505#comment-14707505
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-1383.
Resolution: Won't Fix
Per discussion in dev list, we will be focusing on fixes that add value to the
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1037#discussion_r37661571
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountRe
[
https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707178#comment-14707178
]
ASF GitHub Bot commented on FLINK-2553:
---
Github user mbalassi commented on a diff in
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1040#issuecomment-133515409
I'm happy to report that I managed to set up a distributed Elasticsearch
cluster and the sink did work with it :smile:
---
If your project is set up for it, you can r
[
https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707171#comment-14707171
]
ASF GitHub Bot commented on FLINK-2558:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2306.
---
> Add support for named streams in Storm compatibility layer
> ---
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2306.
-
Resolution: Fixed
Fix Version/s: 0.10
Implemented in 3a8302998d2fc7f38504c238916bc7d0dada23
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707103#comment-14707103
]
ASF GitHub Bot commented on FLINK-2306:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1011
---
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-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707094#comment-14707094
]
ASF GitHub Bot commented on FLINK-2555:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1038#issuecomment-133505584
The Bases exist because there is a java-specific and a scals-specific
version of each HadoopInputFormat.
---
If your project is set up for it, you can reply to this e
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1039#issuecomment-133502218
Okay, I've relocated the source into the `flink-connector-kafka` module.
I added a convenience class `PersistentKafkaSource` in the exact same
package as in the old
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707069#comment-14707069
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14707035#comment-14707035
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1039#issuecomment-133494751
Okay, will do.
---
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 featur
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1039#issuecomment-133483983
Concerning the `FlinkKafkaConsumer081` and `FlinkKafkaConsumer082` - lets
keep them exactly to fix bugs underneath the hood.
I would actually move all this f
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706975#comment-14706975
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706972#comment-14706972
]
ASF GitHub Bot commented on FLINK-2555:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1038#issuecomment-133483445
There might actually be a way of testing against a secured cluster:
https://issues.apache.org/jira/browse/HADOOP-9848 /
https://github.com/apache/hadoop/blob/master/had
[
https://issues.apache.org/jira/browse/FLINK-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706946#comment-14706946
]
ASF GitHub Bot commented on FLINK-2555:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1038#issuecomment-133479533
I actually think that there is no need for the `HadoopInputFormatBase`s to
exist.
There are two implementations and two bases for mapred and mapreduce, but
they ha
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706936#comment-14706936
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1039#issuecomment-133478852
Damn. You are right. I'll add the full type parameters again for the 0.9.1
backport (once this one is merged).
> Should we even differentiate between them, or o
[
https://issues.apache.org/jira/browse/FLINK-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706934#comment-14706934
]
ASF GitHub Bot commented on FLINK-2555:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1038#issuecomment-133478724
Looks good. The HadoopFormatBase and similar classes could use a line or
two more in comments, but otherwise, this seems well.
Any way to test this? There do
[
https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706930#comment-14706930
]
ASF GitHub Bot commented on FLINK-2553:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1037#issuecomment-133477238
I got it now. Can be merged from my point of view.
---
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 StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1039#issuecomment-133470243
This needs to go into 0.9.1, so the diamond operators are going to be a
problem
There is no difference, currently, between the 0.8.2 and the 0.8.1 Kafka
con
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1028#issuecomment-133470378
Yes, I think we can close this issue.
---
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 do
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706924#comment-14706924
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen closed the pull req
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1028#issuecomment-133475027
Subsumed by #1039
---
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
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/1028
---
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-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706923#comment-14706923
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1011#issuecomment-133470436
Will merge this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706908#comment-14706908
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2540.
---
> LocalBufferPool.requestBuffer gets into infinite loop
>
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2540.
-
Resolution: Fixed
Fixed
- 0.9.1 in a31f29480ace690ac59e3e29a8dd4832d078d2ab
- 0.10 in 58421b84
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706907#comment-14706907
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706909#comment-14706909
]
ASF GitHub Bot commented on FLINK-2306:
---
Github user StephanEwen commented on the pu
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1040
[FLINK-2558] Add Streaming Connector for Elasticsearch
This adds an ITCase, an example and documentation.
You can merge this pull request into a Git repository by running:
$ git pull https://g
[
https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706889#comment-14706889
]
ASF GitHub Bot commented on FLINK-2558:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706886#comment-14706886
]
ASF GitHub Bot commented on FLINK-2558:
---
GitHub user aljoscha opened a pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1040#issuecomment-133465114
I'm currently in the process of setting up a cluster to test it with an
actual Elasticsearch cluster. Once I have the results of that I'll post them
here.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706871#comment-14706871
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1028#issuecomment-133463879
Since it is rebased to #1039 already, could this one be closed and do
review on that one instead?
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706867#comment-14706867
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1028#issuecomment-133463429
So is the #1039 depends on this one?
---
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 doe
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706861#comment-14706861
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-133461987
Hey @ChengXiangLi , I just observed a failure on a test case:
https://travis-ci.org/sachingoel0101/flink/jobs/76649177
Here is the relevant statement:
Rando
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706844#comment-14706844
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/1030#discussion_r37643848
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/sink/SocketClientSinkTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706812#comment-14706812
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-133449024
Okay, I figured out a way to share the environments. :)
Let me know if this is a valid approach.
Waiting for travis to pass.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706805#comment-14706805
]
ASF GitHub Bot commented on FLINK-2553:
---
Github user mjsax commented on a diff in th
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/1037#discussion_r37640464
--- Diff: docs/apis/storm_compatibility.md ---
@@ -224,4 +224,12 @@ DataStream rawInput = env.addSource(
You can find more examples in Maven module
`
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706769#comment-14706769
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-133436324
I need some more time to review it. I'll probably finish it on Monday.
---
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-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706761#comment-14706761
]
ASF GitHub Bot commented on FLINK-2386:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1039
[FLINK-2386] Add new KafkaConsumer, based on Kafka's Simple Consumer API
This pull request is based on https://github.com/apache/flink/pull/1028.
I'm creating another pull request because I reba
[
https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2315:
--
Fix Version/s: (was: 0.9.1)
> Hadoop Writables cannot exploit implementing NormalizableKey
>
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-1901.
--
Resolution: Fixed
Added via c9cfb17cb095def8b8ea0ed1b598fc78b890b874
A fixed size sample operat
[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706744#comment-14706744
]
Till Rohrmann commented on FLINK-2549:
--
Is required to implement sample operator whic
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/949
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706741#comment-14706741
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706689#comment-14706689
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-133410381
Hi @tillrohrmann , I have addressed most of the comments.
1. Improved the documentation
2. Ported the continuous histogram implementation to `TreeMap`
3.
Aljoscha Krettek created FLINK-2559:
---
Summary: Fix Javadoc Code Examples
Key: FLINK-2559
URL: https://issues.apache.org/jira/browse/FLINK-2559
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-2558:
---
Summary: Add Streaming Connector for Elasticsearch
Key: FLINK-2558
URL: https://issues.apache.org/jira/browse/FLINK-2558
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706579#comment-14706579
]
Gabor Gevay commented on FLINK-2548:
I changed the title of the issue to refer to the
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2548:
---
Summary: In a VertexCentricIteration, the run time of one iteration should
be proportional to the size
[
https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2557:
---
Description:
I changed the WordCount example as below and get an exception:
Tokenizer is chan
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706571#comment-14706571
]
ASF GitHub Bot commented on FLINK-2540:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1036
---
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-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2557:
---
Summary: Manual type information via "returns" fails in DataSet API (was:
Manal type informat
Matthias J. Sax created FLINK-2557:
--
Summary: Manal type information via "returns" fails in DataSet API
Key: FLINK-2557
URL: https://issues.apache.org/jira/browse/FLINK-2557
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706538#comment-14706538
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-133371873
Looks great. Thanks a lot for your contribution @ChengXiangLi. Will merge
it now.
---
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-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706536#comment-14706536
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-133371332
Yes, if you read the message of the checks you removes, it is precisely to
figure that out: Whether a program actually triggered execution.
We've build a kic
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706531#comment-14706531
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-133370663
To access the last execution result, the environment needs to be shared.
And since we're creating a new execution environment in the program, it
wouldn't work.
[
https://issues.apache.org/jira/browse/FLINK-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706528#comment-14706528
]
ASF GitHub Bot commented on FLINK-2555:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1038
[FLINK-2555] Properly pass security credentials in the Hadoop Input/Output
format wrappers
This is needed because the Hadoop IF/OF's are using Hadoop's FileSystem
stack, which is using the securit
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-133365847
So, this is now removing some safeguard checks in the test to make this
work. That does not seem quite right. Why not keep the environment and keep
access to the lat
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706523#comment-14706523
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user StephanEwen commented on the pu
Github user rmetzger closed the pull request at:
https://github.com/apache/flink/pull/996
---
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 ena
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706520#comment-14706520
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger closed the pull reques
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/996#issuecomment-133364526
I think we can close this pull request, it has been subsumed by #1028
---
If your project is set up for it, you can reply to this email and have your
reply appear on
1 - 100 of 128 matches
Mail list logo
