Till Rohrmann created FLINK-3156:
Summary: FlinkKafkaConsumer fails with NPE on
notifyCheckpointComplete
Key: FLINK-3156
URL: https://issues.apache.org/jira/browse/FLINK-3156
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1416
---
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-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3074.
---
Resolution: Fixed
Fixed for 1.0 in http://git-wip-us.apache.org/repos/asf/flink/commit/74b535d
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048954#comment-15048954
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048857#comment-15048857
]
ASF GitHub Bot commented on FLINK-2796:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1449
[FLINK-2796] [runtime-web] Add configurable job manager address to HTTP
requests
These changes (re-)enable testing of changes to the web frontend:
- Set the `allow-origin` header in order to al
[
https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3145.
-
Resolution: Fixed
Fix Version/s: 0.10.2
master: b2aa1d9e3741c77230d300d6c777d3eabe9
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3143.
-
Resolution: Fixed
Fix Version/s: 0.10.2
> Update Clojure Cleaner's ASM references t
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-3143:
---
> Update Clojure Cleaner's ASM references to ASM5
> --
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3143.
-
Resolution: Fixed
master: e28b62e0e2973b01ad5b08ce319aaf0e7ce4c087
release-0.10: f3f2ced46
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1443
---
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 aljoscha opened a pull request:
https://github.com/apache/flink/pull/1448
[FLINK-2936] Fix ClassCastException for Event-Time source
Before, would throw a ClassCastException when emitting watermarks with
timestamp/watermark multiplexing disabled.
You can merge this pu
[
https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048779#comment-15048779
]
ASF GitHub Bot commented on FLINK-2936:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048761#comment-15048761
]
ASF GitHub Bot commented on FLINK-3145:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048760#comment-15048760
]
ASF GitHub Bot commented on FLINK-3143:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1445
---
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/1441
---
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-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-2769:
This changed removed the address completely, but it should have been an empty
string by default. Otherw
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048739#comment-15048739
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3073.
-
Resolution: Fixed
Implemented in
https://github.com/apache/flink/commit/4f12356eb64af3790
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1433
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048738#comment-15048738
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163264394
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 featu
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048732#comment-15048732
]
Timo Walther commented on FLINK-2099:
-
We can use this issue as an umbrella task for a
[
https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3121:
---
Assignee: Aljoscha Krettek
> Watermark forwarding does not work for sources not produ
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1447
[FLINK-3121] Emit Final Watermark in Kafka Source
Kafka sources that don't read from any partition never emit a watermark,
thereby blocking the progress of event-time in downstream operations.
[
https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048718#comment-15048718
]
ASF GitHub Bot commented on FLINK-3121:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-2936:
---
Assignee: Aljoscha Krettek
> ClassCastException when using EventTimeSourceFunction in
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1441#issuecomment-163186476
I'm not really sure about the implications of Kryo in the root pom so I try
to fix it where it is a problem first.
>Kryo beyond 2.24.0 changed maven group and artifa
[
https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048639#comment-15048639
]
ASF GitHub Bot commented on FLINK-3150:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1446
[FLINK-3150] Make the YARN container start invocation configurable
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink3150
Al
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163221930
`preallocate` can be seen as one word, no?
---
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-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048632#comment-15048632
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048630#comment-15048630
]
Maximilian Michels commented on FLINK-2823:
---
I will open a new pull request to a
[
https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2823:
-
Assignee: Maximilian Michels
> YARN client should report a proper exception if Ha
[
https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048625#comment-15048625
]
ASF GitHub Bot commented on FLINK-2823:
---
Github user mxm closed the pull request at:
Github user mxm closed the pull request at:
https://github.com/apache/flink/pull/1235
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048624#comment-15048624
]
ASF GitHub Bot commented on FLINK-2823:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1235#issuecomment-163220976
Closing this because of the raised objections.
---
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 projec
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1422#issuecomment-163194318
All right, lets merge this then...
---
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
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1445
[FLINK-3143] update Closure Cleaner's ASM references to ASM5
- This solves errors with reflectasm using Scala 2.11 and Java 8
You can merge this pull request into a Git repository by running:
$ git
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048601#comment-15048601
]
Ovidiu Marcu commented on FLINK-2099:
-
Thanks, I will look into FLINK-3152.
Can you pl
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1416#issuecomment-163183261
Only some minor comments left. +1 for merging after they are are addressed
or discarded.
---
If your project is set up for it, you can reply to this email and have
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1441#issuecomment-163181852
Not sure about the Kryo dependency in the root pom. We already pin the Kryo
version via dependency management in the root pom. This eliminates most
conflicts in sub projects
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1443#issuecomment-163196855
Thanks @hsaputra for the reminder. I've filed a JIRA:
https://issues.apache.org/jira/browse/FLINK-3155
Looks good to merge otherwise.
---
If your project is set up
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-163188173
Hi @StephanEwen, I have modified the signature of the `handleRequest`
method to separate path and query parameters.
If there are any more concerns, let me know
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1443#discussion_r47079200
--- Diff: flink-contrib/docker-flink/flink/Dockerfile ---
@@ -25,8 +25,8 @@ RUN cat ~/.ssh/id_rsa.pub >> ~/.ssh/authorized_keys &&
chmod 600 ~/.ssh/*
##Flink
[
https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048558#comment-15048558
]
ASF GitHub Bot commented on FLINK-3023:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1422#issuecomment-163200275
Olrite. Great!
#1418 should also be meregable with this one IMO.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163192234
+1 from my side, after the switch to "preallocate"
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1443#issuecomment-163153842
Do you have JIRA ticket filed for this? As part of ASF contribution please
do file JIRA [1] and associate with the PR [2]. Thanks!
[1] https://issues.apache.org
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048534#comment-15048534
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on the pull reque
Maximilian Michels created FLINK-3155:
-
Summary: Update Flink docker version to latest stable Flink version
Key: FLINK-3155
URL: https://issues.apache.org/jira/browse/FLINK-3155
Project: Flink
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163194389
is `pre-allocate` also ok? btw, we have a wild mixture of option styles,
there is camelCase, under_score, and with-hyphens.
---
If your project is set up for it, you c
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048527#comment-15048527
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048526#comment-15048526
]
ASF GitHub Bot commented on FLINK-3023:
---
Github user StephanEwen commented on the pu
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r47073661
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048508#comment-15048508
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user StephanEwen commented on the pu
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163177539
Any objections against me merging this now?
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048502#comment-15048502
]
Stephan Ewen commented on FLINK-3143:
-
Ah, got it. The opCode versions inside the Clos
Maximilian Michels created FLINK-3154:
-
Summary: Update Kryo version from 2.24.0 to 3.0.3
Key: FLINK-3154
URL: https://issues.apache.org/jira/browse/FLINK-3154
Project: Flink
Issue Type:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r47073443
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163187358
PR looks good. +1 for `taskmanager.memory.preallocate`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1418#issuecomment-163188701
>Also, what is the procedure for creating a release artifact
locally[without GPG keys, Apache id, etc.] so I can check that this works okay
for those too?
The relea
[
https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048482#comment-15048482
]
ASF GitHub Bot commented on FLINK-3077:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048480#comment-15048480
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1422#discussion_r47076123
--- Diff: flink-runtime-web/web-dashboard/app/partials/overview.jade ---
@@ -22,6 +22,12 @@ nav.navbar.navbar-default.navbar-fixed-top.navbar-main
[
https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048476#comment-15048476
]
ASF GitHub Bot commented on FLINK-3023:
---
Github user sachingoel0101 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048475#comment-15048475
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048471#comment-15048471
]
ASF GitHub Bot commented on FLINK-3145:
---
Github user mxm commented on the pull reque
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163184597
Can do, yes.
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1433#issuecomment-163184249
Looks good!
One thing that just came to my mind is whether we should call the config
flag "taskmanager.memory.preallocate" (default false).
I think
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048466#comment-15048466
]
ASF GitHub Bot commented on FLINK-3143:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048465#comment-15048465
]
Stephan Ewen commented on FLINK-3143:
-
I think the regular ASM we use is already ASM 5
[
https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048459#comment-15048459
]
ASF GitHub Bot commented on FLINK-3145:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048458#comment-15048458
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user aljoscha commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1441#issuecomment-163184620
Fair enough, let's leave it specific to storm then.
Kryo beyond 2.24.0 changed maven group and artifact names...
---
If your project is set up for it, you c
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048456#comment-15048456
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048455#comment-15048455
]
Maximilian Michels commented on FLINK-3143:
---
The dependency has been updated but
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1422#discussion_r47073802
--- Diff: flink-runtime-web/web-dashboard/app/partials/overview.jade ---
@@ -22,6 +22,12 @@ nav.navbar.navbar-default.navbar-fixed-top.navbar-main
.
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048453#comment-15048453
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048451#comment-15048451
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r47074199
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {
Timo Walther created FLINK-3153:
---
Summary: Support all comparisons for String type
Key: FLINK-3153
URL: https://issues.apache.org/jira/browse/FLINK-3153
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048445#comment-15048445
]
ASF GitHub Bot commented on FLINK-3145:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048443#comment-15048443
]
ASF GitHub Bot commented on FLINK-3023:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048440#comment-15048440
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048439#comment-15048439
]
Timo Walther commented on FLINK-2099:
-
Cool, that you already checked out and tested m
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048438#comment-15048438
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048437#comment-15048437
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r47073382
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {
[
https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048435#comment-15048435
]
Stephan Ewen commented on FLINK-3143:
-
I think this is the same as [FLINK-3136]
> Upd
[
https://issues.apache.org/jira/browse/FLINK-3138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048430#comment-15048430
]
Stephan Ewen commented on FLINK-3138:
-
Try using a custom type with a getKey method().
Timo Walther created FLINK-3152:
---
Summary: Support all comparisons for Date type
Key: FLINK-3152
URL: https://issues.apache.org/jira/browse/FLINK-3152
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3136.
-
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/718a17b282923c5d10a6ef6
[
https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048426#comment-15048426
]
ASF GitHub Bot commented on FLINK-3073:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3136:
---
Assignee: Aljoscha Krettek (was: Stephan Ewen)
> Scala Closure Cleaner uses wrong AS
[
https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3150:
-
Assignee: Robert Metzger
> Make YARN container invocation configurable
>
[
https://issues.apache.org/jira/browse/FLINK-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048370#comment-15048370
]
Robert Metzger commented on FLINK-3151:
---
With the standard fraction of 0.25
> YARN
[
https://issues.apache.org/jira/browse/FLINK-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-3151:
--
Assignee: Ufuk Celebi
> YARN kills Flink TM containers due to memory overuse (outside heap/offh
101 - 200 of 207 matches
Mail list logo
