[
https://issues.apache.org/jira/browse/FLINK-2913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2913:
--
Description:
{code}
ObjectOutputStream os = new ObjectOutputStream(outStream);
[
https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2914:
--
Description:
{code}
case CONNECTION_SUSPENDED:
LOG.warn("ZooKeeper connection SUSPENDED.
[
https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2826:
--
Description:
Here is related code:
{code}
if (references.isEmpty()) {
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for
[
https://issues.apache.org/jira/browse/FLINK-2984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14995095#comment-14995095
]
Chiwan Park commented on FLINK-2984:
Hi [~jkirsch], thanks for reporting issue. But I'm not sure the
[
https://issues.apache.org/jira/browse/FLINK-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14995090#comment-14995090
]
ASF GitHub Bot commented on FLINK-2947:
---
GitHub user chiwanpark opened a pull request:
GitHub user chiwanpark opened a pull request:
https://github.com/apache/flink/pull/1337
[FLINK-2947] [scala shell] Add color support to Scala Shell
This PR adds color support to Scala Shell with Scala 2.11. Color scheme is
inherited from Scala 2.11 default color scheme.
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993322#comment-14993322
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the pull request:
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-154339878
Failure on an unrelated test: JobManagerSubmittedJobGraphsRecoveryITCase
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993456#comment-14993456
]
Martin Junghanns commented on FLINK-2981:
-
Yes, of course.
> Update README for building docs
>
[
https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-2963:
---
Assignee: Aljoscha Krettek
> Dependence on SerializationUtils#deserialize() should
[
https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2963:
Assignee: (was: Aljoscha Krettek)
> Dependence on SerializationUtils#deserialize()
[
https://issues.apache.org/jira/browse/FLINK-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993477#comment-14993477
]
ASF GitHub Bot commented on FLINK-2981:
---
GitHub user s1ck opened a pull request:
GitHub user s1ck opened a pull request:
https://github.com/apache/flink/pull/1335
[FLINK-2981] [docs] update requirements in docs/README.md
* added libraries and versions
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/s1ck/flink
[
https://issues.apache.org/jira/browse/FLINK-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993424#comment-14993424
]
Maximilian Michels commented on FLINK-2959:
---
The setters on the ExecutionEnvironment just set
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993414#comment-14993414
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993415#comment-14993415
]
ASF GitHub Bot commented on FLINK-2797:
---
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/1214#discussion_r44117608
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java
---
@@ -114,15 +115,33 @@ public Client getClient() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1214#discussion_r44117601
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java
---
@@ -114,15 +115,33 @@ public Client getClient() {
[
https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993417#comment-14993417
]
Maximilian Michels commented on FLINK-2124:
---
Eactly. With 0.9.1 your classes have to implement
[
https://issues.apache.org/jira/browse/FLINK-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993429#comment-14993429
]
Maximilian Michels commented on FLINK-2981:
---
+1 Would you mind listing those dependencies and
[
https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993493#comment-14993493
]
ASF GitHub Bot commented on FLINK-2752:
---
Github user mjsax commented on the pull request:
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1320#issuecomment-154376504
Good idea. Just updated this. Please verify that it renders correctly for
you. And let me know if I can merge it.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993494#comment-14993494
]
ASF GitHub Bot commented on FLINK-7:
Github user ChengXiangLi commented on a diff in the pull request:
Github user ChengXiangLi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1255#discussion_r44124427
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/Channel.java ---
@@ -134,6 +134,10 @@ public Channel(PlanNode sourceNode,
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993501#comment-14993501
]
ASF GitHub Bot commented on FLINK-7:
Github user ChengXiangLi commented on a diff in the pull request:
Github user ChengXiangLi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1255#discussion_r44125013
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/RangePartitionRewriter.java
---
@@ -0,0 +1,188 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993517#comment-14993517
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on a diff in the pull
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1214#discussion_r44126978
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java
---
@@ -114,15 +115,33 @@ public Client getClient() {
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1336
---
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-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-2979.
-
Resolution: Fixed
Fix Version/s: 1.0
Fixed in
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1322#issuecomment-154508639
I think the best solution (also for future features like the SQL API) is a
TableConfig, where TimeZone, Locales, and also the `nullCheck` can be
configured. Once #1237
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-2985:
Assignee: (was: Timo Walther)
Priority: Minor (was: Major)
Issue Type: Improvement
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1336#issuecomment-154499240
Manually merged
---
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-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994197#comment-14994197
]
ASF GitHub Bot commented on FLINK-2979:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994198#comment-14994198
]
ASF GitHub Bot commented on FLINK-2979:
---
Github user aljoscha closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994205#comment-14994205
]
ASF GitHub Bot commented on FLINK-2979:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1336#issuecomment-154499798
Can you also merge this into the 0.10 branch, so the 0.10.1 release will
get the fix?
---
If your project is set up for it, you can reply to this email and have
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1336#issuecomment-154499953
Already done. :smiley:
---
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-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994207#comment-14994207
]
ASF GitHub Bot commented on FLINK-2979:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994269#comment-14994269
]
ASF GitHub Bot commented on FLINK-2961:
---
Github user twalthr commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-154428753
There are still two issues I noticed. Printing to standard out should be
disabled during the dry-run phase. Just like in the OptimizerPlanEnvironment.
The other one is
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993764#comment-14993764
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on the pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1336
[FLINK-2979] Fix RollingSink truncate for Hadoop 2.7
The problem was, that truncate is asynchronous and the RollingSink was
not taking this into account.
Now it has a loop after the
[
https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993808#comment-14993808
]
ASF GitHub Bot commented on FLINK-2979:
---
GitHub user aljoscha opened a pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1335#issuecomment-154384532
Thank you. 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
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1320#discussion_r44128483
--- Diff: docs/internals/coding_guidelines.md ---
@@ -20,4 +20,6 @@ specific language governing permissions and limitations
under the License.
-->
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1320#discussion_r44128486
--- Diff: docs/internals/how_to_contribute.md ---
@@ -20,4 +20,6 @@ specific language governing permissions and limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993634#comment-14993634
]
Gyula Fora commented on FLINK-2983:
---
Alright I see your point we can think about this if it comes up
[
https://issues.apache.org/jira/browse/FLINK-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993623#comment-14993623
]
Stephan Ewen commented on FLINK-2983:
-
Hmmm, I am not fully sure about this. It seems like another
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1320#issuecomment-154405702
Just updated. Set redirect to 5 seconds (this gives enough time to read the
single line). Also added comment that auto redirect is enabled. Please check
the "look an
[
https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993640#comment-14993640
]
ASF GitHub Bot commented on FLINK-2752:
---
Github user mjsax commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/commit/bf29de981c2bcd5cb5d33c68b158c95c8820f43d#commitcomment-14240638
You're welcome.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993540#comment-14993540
]
ASF GitHub Bot commented on FLINK-2752:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993541#comment-14993541
]
ASF GitHub Bot commented on FLINK-2752:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1320#issuecomment-154390451
Thanks for the update. Works for me in Firefox, Chromium, and Safari. Good
to merge with an increased timeout for the redirect.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993544#comment-14993544
]
ASF GitHub Bot commented on FLINK-2752:
---
Github user mxm commented on the pull request:
Gyula Fora created FLINK-2983:
-
Summary: Add StateLoader as an alternative to default KvState
Key: FLINK-2983
URL: https://issues.apache.org/jira/browse/FLINK-2983
Project: Flink
Issue Type:
Timo Walther created FLINK-2985:
---
Summary: Allow different field names for unionAll() in Table API
Key: FLINK-2985
URL: https://issues.apache.org/jira/browse/FLINK-2985
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994075#comment-14994075
]
Nick Dimiduk commented on FLINK-2124:
-
It appears to, yes. Thanks a lot [~mxm]!
>
Github user mxm commented on the pull request:
https://github.com/apache/flink/commit/bf29de981c2bcd5cb5d33c68b158c95c8820f43d#commitcomment-14239173
Are you still having this problem? The newest flink-storm version as of
today is from Nov 06.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-2981.
---
Resolution: Fixed
Thanks for the pull request!
Resolved in {{9178a58}}.
> Update
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1335
---
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-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2981:
--
Fix Version/s: 1.0
> Update README for building docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993524#comment-14993524
]
ASF GitHub Bot commented on FLINK-2981:
---
Github user asfgit closed the pull request at:
Github user alexeyegorov commented on the pull request:
https://github.com/apache/flink/commit/bf29de981c2bcd5cb5d33c68b158c95c8820f43d#commitcomment-14239582
Yesterday I saw that it was updated on Nov 04 and it worked. Thanks! ;)
---
If your project is set up for it, you can reply
Johannes created FLINK-2984:
---
Summary: Support lenient parsing of SVMLight input files
Key: FLINK-2984
URL: https://issues.apache.org/jira/browse/FLINK-2984
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994471#comment-14994471
]
Johannes commented on FLINK-2213:
-
I just ran into this problem on a cluster configured with the
68 matches
Mail list logo
