Fabian Hueske created FLINK-2936:
Summary: ClassCastException when using EventTimeSourceFunction in
non-EventTime program
Key: FLINK-2936
URL: https://issues.apache.org/jira/browse/FLINK-2936
Project:
[
https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14979224#comment-14979224
]
ASF GitHub Bot commented on FLINK-2932:
---
GitHub user fkautz opened a pull request:
GitHub user fkautz opened a pull request:
https://github.com/apache/flink/pull/1309
[FLINK-2932] Examples in docs now download shell script using https instead
of http
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fkautz/flink
[
https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14979183#comment-14979183
]
ASF GitHub Bot commented on FLINK-2800:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1308#issuecomment-151983062
Very important fix!
+1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14979160#comment-14979160
]
Fabian Hueske commented on FLINK-2932:
--
Committers definitely need a CLA.
However, ht
[
https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14979048#comment-14979048
]
Aljoscha Krettek commented on FLINK-2932:
-
No, as far as I know a CLA is only requ
[
https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978975#comment-14978975
]
Frederick F. Kautz IV commented on FLINK-2932:
--
Sure, but first formalities.
Github user danielblazevski commented on the pull request:
https://github.com/apache/flink/pull/1220#issuecomment-151942911
@tillrohrmann I now have more time to go back and try to finalize this PR
in the next couple of weeks. After debugging a bit, I noticed that in your
modificatio
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978968#comment-14978968
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user danielblazevski commented on th
[
https://issues.apache.org/jira/browse/FLINK-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978887#comment-14978887
]
Fabian Hueske commented on FLINK-2933:
--
I'll reply on the thread to get you in the lo
[
https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1497#comment-1497
]
ASF GitHub Bot commented on FLINK-2800:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1308
[FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data
The Kryo serializer uses Kryo's Output class to buffer individual write
operations before
it is written to the underlying o
[
https://issues.apache.org/jira/browse/FLINK-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978870#comment-14978870
]
Frederick F. Kautz IV commented on FLINK-2933:
--
I just signed up to the maili
[
https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978749#comment-14978749
]
Ted Yu commented on FLINK-2826:
---
Can you clarify on point #1 please. We already have:
{code}
[
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 hadoop-
[
https://issues.apache.org/jira/browse/FLINK-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-2868.
---
Resolution: Not A Problem
> Missing null check for operatorChain in StreamTask#invoke()
>
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978675#comment-14978675
]
Gabor Gevay commented on FLINK-2662:
Yes, because I checked out the branch that is ref
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978670#comment-14978670
]
Chesnay Schepler commented on FLINK-2662:
-
are you sure that you ran it both times
[
https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-2351:
---
Assignee: Chesnay Schepler
> Deprecate config builders in InputFormats and Output for
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1214#discussion_r43273230
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/Client.java ---
@@ -271,18 +272,21 @@ public JobSubmissionResult
runDetached(PackagedProgra
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978611#comment-14978611
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on a diff in the
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1305#issuecomment-151884357
Wow, a lot of stuff. I will look into it once the release is out. :smiley:
---
If your project is set up for it, you can reply to this email and have your
reply appear
Johannes created FLINK-2935:
---
Summary: Allow scala shell to read yarn properties
Key: FLINK-2935
URL: https://issues.apache.org/jira/browse/FLINK-2935
Project: Flink
Issue Type: Improvement
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-151849439
@mxm , if there are any more comments, let me know. I'll try to resolve
them quickly so we can include this in the next rc (which will likely be the
last one(?)).
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978450#comment-14978450
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978402#comment-14978402
]
Aljoscha Krettek commented on FLINK-2934:
-
Maybe, I'm not sure what is supposed to
[
https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978391#comment-14978391
]
Sachin Goel commented on FLINK-2934:
[~aljoscha] there's already a jira for taskmanage
[
https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978388#comment-14978388
]
ASF GitHub Bot commented on FLINK-2934:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1307#issuecomment-151841903
Thanks! Looks good.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978385#comment-14978385
]
Aljoscha Krettek commented on FLINK-2934:
-
Did you add a Jira for adding them agai
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1296#issuecomment-151836166
Ping.
---
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
e
[
https://issues.apache.org/jira/browse/FLINK-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978370#comment-14978370
]
ASF GitHub Bot commented on FLINK-2902:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978365#comment-14978365
]
ASF GitHub Bot commented on FLINK-2934:
---
GitHub user sachingoel0101 opened a pull re
GitHub user sachingoel0101 opened a pull request:
https://github.com/apache/flink/pull/1307
[FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log
and taskmanager.stdout
You can merge this pull request into a Git repository by running:
$ git pull https://gi
Sachin Goel created FLINK-2934:
--
Summary: Remove placehoder pages in Web dashboard
Key: FLINK-2934
URL: https://issues.apache.org/jira/browse/FLINK-2934
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978297#comment-14978297
]
ASF GitHub Bot commented on FLINK-2559:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1298#issuecomment-151823317
OK, I can do it as well.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978294#comment-14978294
]
ASF GitHub Bot commented on FLINK-2559:
---
Github user hczerpak commented on the pull
Github user hczerpak commented on the pull request:
https://github.com/apache/flink/pull/1298#issuecomment-151820648
I'm sorry @fhueske but honestly I don't know how to squash the history.
After few tires I've given up yesterday, it didn't happen correctly.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978248#comment-14978248
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user mliesenberg commented on the pu
Github user mliesenberg commented on the pull request:
https://github.com/apache/flink/pull/1097#issuecomment-151804263
Yes, that's right.
I'll address the comments tonight. If the `add(Option)` issue is blocking
the merge, we can just drop the function it, if you want.
--
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978234#comment-14978234
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user mliesenberg commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978233#comment-14978233
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user mliesenberg commented on a diff
Github user mliesenberg commented on a diff in the pull request:
https://github.com/apache/flink/pull/1097#discussion_r43241539
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
---
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache S
Github user mliesenberg commented on a diff in the pull request:
https://github.com/apache/flink/pull/1097#discussion_r43241508
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
---
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978225#comment-14978225
]
ASF GitHub Bot commented on FLINK-2901:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1306#issuecomment-151800406
Nice @zentol! Thanks for this effort!
---
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-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978202#comment-14978202
]
ASF GitHub Bot commented on FLINK-2901:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/1306
[FLINK-2901] Remove Record API dependencies from flink-tests
This PR removes all dependencies to the Record API in the flink-tests
project.
For this, tests were either ported or removed.
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978135#comment-14978135
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1097#issuecomment-151791276
Thanks for the update!
Except for my comments, the only remaining question is whether to offer the
`add(Option)` method or not, right?
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978133#comment-14978133
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1097#discussion_r43236812
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
---
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Softw
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1097#discussion_r43236711
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
---
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978131#comment-14978131
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978124#comment-14978124
]
Gabor Gevay commented on FLINK-2662:
It is working on my work laptop...
> CompilerExc
[
https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978107#comment-14978107
]
ASF GitHub Bot commented on FLINK-2559:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1298#issuecomment-151786552
Thanks for the update.
Looks good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your p
[
https://issues.apache.org/jira/browse/FLINK-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978005#comment-14978005
]
ASF GitHub Bot commented on FLINK-2869:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1270#issuecomment-151773654
Thanks for the update.
Looks good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your p
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14977968#comment-14977968
]
ASF GitHub Bot commented on FLINK-7:
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1255#discussion_r43228263
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -1223,6 +1230,51 @@ public long count() throws Exception {
fi
[
https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14977872#comment-14977872
]
Aljoscha Krettek commented on FLINK-2932:
-
[~fkautz] Would you be interested in co
[
https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14977870#comment-14977870
]
Aljoscha Krettek commented on FLINK-2932:
-
I think we should change it, yes.
> Fl
65 matches
Mail list logo
