[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-2977:
Attachment: FLINK-2977-20151009.patch
This patch "works on my machine".
I am currently testing what
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14996842#comment-14996842
]
Niels Basjes commented on FLINK-2977:
-
I just started a simple test Flink application with a keytab
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14998346#comment-14998346
]
Niels Basjes commented on FLINK-2977:
-
I ran this version over night but the VPN from my system
Niels Basjes created FLINK-2977:
---
Summary: Cannot access HBase in a Kerberos secured Yarn cluster
Key: FLINK-2977
URL: https://issues.apache.org/jira/browse/FLINK-2977
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14991608#comment-14991608
]
Niels Basjes commented on FLINK-2977:
-
In the mailing list [~rmetzger] responded:
{quote} I agree with
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes reassigned FLINK-2977:
---
Assignee: Niels Basjes
> Cannot access HBase in a Kerberos secured Yarn cluster
>
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-2977:
Attachment: FLINK-2977-20151005-untested.patch
First attempt, untested.
Essentially copied from
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15042353#comment-15042353
]
Niels Basjes commented on FLINK-3089:
-
I think that having a map type function that supports timers
Niels Basjes created FLINK-3082:
---
Summary: Confusing error about ManualTimestampSourceFunction
Key: FLINK-3082
URL: https://issues.apache.org/jira/browse/FLINK-3082
Project: Flink
Issue Type:
Niels Basjes created FLINK-3089:
---
Summary: OperatorState timeout
Key: FLINK-3089
URL: https://issues.apache.org/jira/browse/FLINK-3089
Project: Flink
Issue Type: New Feature
Niels Basjes created FLINK-3239:
---
Summary: Support for Kerberos enabled Kafka 0.9.0.0
Key: FLINK-3239
URL: https://issues.apache.org/jira/browse/FLINK-3239
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes closed FLINK-3584.
---
Resolution: Fixed
I double checked: This no longer occurs in 1.0.0.
I opened a new ticket for the
Niels Basjes created FLINK-3719:
---
Summary: WebInterface: Moving the barrier between graph and stats
Key: FLINK-3719
URL: https://issues.apache.org/jira/browse/FLINK-3719
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232072#comment-15232072
]
Niels Basjes commented on FLINK-3719:
-
Originally asked here FLINK-3584
> WebInterface: Moving the
[
https://issues.apache.org/jira/browse/FLINK-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232054#comment-15232054
]
Niels Basjes commented on FLINK-3670:
-
A while ago I found that part of the problem is in the upstream
Niels Basjes created FLINK-3584:
---
Summary: WebInterface: Broken graphical display in Chrome
Key: FLINK-3584
URL: https://issues.apache.org/jira/browse/FLINK-3584
Project: Flink
Issue Type: Bug
Niels Basjes created FLINK-3886:
---
Summary: Give a better error when the application Main class is
not public.
Key: FLINK-3886
URL: https://issues.apache.org/jira/browse/FLINK-3886
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-3886:
Attachment: FLINK-3886-20160509.patch
The proposed change.
Please verify if this works/is valid in
[
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15276463#comment-15276463
]
Niels Basjes commented on FLINK-2597:
-
FYI: I see a close relationship between this issue and the one
[
https://issues.apache.org/jira/browse/FLINK-3886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15276489#comment-15276489
]
Niels Basjes commented on FLINK-3886:
-
I just verified that my situation this yields a very usable
Niels Basjes created FLINK-4287:
---
Summary: Unable to access secured HBase from a yarn-session.
Key: FLINK-4287
URL: https://issues.apache.org/jira/browse/FLINK-4287
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401866#comment-15401866
]
Niels Basjes commented on FLINK-4287:
-
Because of the extensive work being done in FLINK-3929 I'm
Niels Basjes created FLINK-4311:
---
Summary: TableInputFormat fails when reused on next split
Key: FLINK-4311
URL: https://issues.apache.org/jira/browse/FLINK-4311
Project: Flink
Issue Type: Bug
Niels Basjes created FLINK-4486:
---
Summary: JobManager not fully running when yarn-session.sh finishes
Key: FLINK-4486
URL: https://issues.apache.org/jira/browse/FLINK-4486
Project: Flink
Issue
Niels Basjes created FLINK-4485:
---
Summary: Finished jobs in yarn session fill /tmp filesystem
Key: FLINK-4485
URL: https://issues.apache.org/jira/browse/FLINK-4485
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-4485:
Description:
On a Yarn cluster I start a yarn-session with a few containers and task slots.
Then I
Niels Basjes created FLINK-4487:
---
Summary: Need tools for managing the yarn-session better
Key: FLINK-4487
URL: https://issues.apache.org/jira/browse/FLINK-4487
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436917#comment-15436917
]
Niels Basjes commented on FLINK-4485:
-
I just reproduced the effect on a non-secure Yarn cluster.
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15455755#comment-15455755
]
Niels Basjes commented on FLINK-4485:
-
I have tried to create a minimal application that reproduces
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452155#comment-15452155
]
Niels Basjes commented on FLINK-4485:
-
Today I tried to reproduce this problem with the wordcount
Niels Basjes created FLINK-4620:
---
Summary: Automatically creating savepoints
Key: FLINK-4620
URL: https://issues.apache.org/jira/browse/FLINK-4620
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490009#comment-15490009
]
Niels Basjes commented on FLINK-4485:
-
Have you been able to reproduce the problem with the test
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15549036#comment-15549036
]
Niels Basjes commented on FLINK-4485:
-
I did a run with the latest 'master' and I ran over 80 jobs on
[
https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15516660#comment-15516660
]
Niels Basjes commented on FLINK-4620:
-
Done.
> Automatically creating savepoints
>
[
https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15516657#comment-15516657
]
Niels Basjes commented on FLINK-4511:
-
As requested by [~aljoscha] my comments copied from FLINK-4620
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445374#comment-15445374
]
Niels Basjes commented on FLINK-4485:
-
No, I had a quick look at the code and I could not find where
[
https://issues.apache.org/jira/browse/FLINK-4287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes resolved FLINK-4287.
-
Resolution: Fixed
The change has been committed
> Unable to access secured HBase from a
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446104#comment-15446104
]
Niels Basjes commented on FLINK-4485:
-
I didn't change that setting.
In the web UI I see only the last
Niels Basjes created FLINK-4495:
---
Summary: Running multiple jobs on yarn (without yarn-session)
Key: FLINK-4495
URL: https://issues.apache.org/jira/browse/FLINK-4495
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643814#comment-15643814
]
Niels Basjes commented on FLINK-5025:
-
Thanks. Jira is so slow right now I couldn't find it.
> Job
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643820#comment-15643820
]
Niels Basjes commented on FLINK-2662:
-
I have the full reproduction application available here:
Niels Basjes created FLINK-5025:
---
Summary: Job fails because of Optimizer bug
Key: FLINK-5025
URL: https://issues.apache.org/jira/browse/FLINK-5025
Project: Flink
Issue Type: Bug
Affects
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643752#comment-15643752
]
Niels Basjes commented on FLINK-5025:
-
See here for a minimal project that does this:
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984813#comment-15984813
]
Niels Basjes commented on FLINK-2055:
-
Last week I implemented a custom sink to feed my special
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-9610:
Description:
The kafka connector package only contains the FlinkFixedPartitioner
implementation
Niels Basjes created FLINK-9610:
---
Summary: Add Kafka partitioner that uses the key to partition by
Key: FLINK-9610
URL: https://issues.apache.org/jira/browse/FLINK-9610
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547551#comment-16547551
]
Niels Basjes commented on FLINK-9311:
-
FYI: Richard Deurwaarder (Xeli) is a colleague of mine at
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes reassigned FLINK-9311:
---
Assignee: Niels Basjes
> PubSub connector
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-10479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16649885#comment-16649885
]
Niels Basjes commented on FLINK-10479:
--
Have a look at the pull request we put up for FLINK-9311
Niels Basjes created FLINK-16288:
Summary: Setting the TTL for discarding task pods on Kubernetes.
Key: FLINK-16288
URL: https://issues.apache.org/jira/browse/FLINK-16288
Project: Flink
Niels Basjes created FLINK-16289:
Summary: Missing serialVersionUID blocks running in Kubernetes.
Key: FLINK-16289
URL: https://issues.apache.org/jira/browse/FLINK-16289
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-16289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-16289:
-
Description:
I have written a Flink 1.10 job that reads a file (using the S3 Presto client),
[
https://issues.apache.org/jira/browse/FLINK-16288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045578#comment-17045578
]
Niels Basjes commented on FLINK-16288:
--
Yes, thank you.
That does what I was looking for.
I
[
https://issues.apache.org/jira/browse/FLINK-16289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-16289:
-
Summary: Missing serialVersionUID blocks running SQL group by in
Kubernetes. (was: Missing
Niels Basjes created FLINK-16432:
Summary: Building Hive connector gives problems
Key: FLINK-16432
URL: https://issues.apache.org/jira/browse/FLINK-16432
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051039#comment-17051039
]
Niels Basjes commented on FLINK-16293:
--
Hi [~azagrebin] [~fly_in_gis] [~trohrmann],
I've
[
https://issues.apache.org/jira/browse/FLINK-15794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046715#comment-17046715
]
Niels Basjes commented on FLINK-15794:
--
FYI: I've put up an initial pull request for you to review.
[
https://issues.apache.org/jira/browse/FLINK-15794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046638#comment-17046638
]
Niels Basjes commented on FLINK-15794:
--
Looking at the code I think it should not be that hard to
[
https://issues.apache.org/jira/browse/FLINK-16289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046680#comment-17046680
]
Niels Basjes commented on FLINK-16289:
--
You guys are right, it was a version problem.
Simply put:
[
https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049679#comment-17049679
]
Niels Basjes commented on FLINK-16142:
--
Let me add my context because I also see this problem OOM
[
https://issues.apache.org/jira/browse/FLINK-16293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049630#comment-17049630
]
Niels Basjes commented on FLINK-16293:
--
Understood. I'll move it towards the Docker area and
Niels Basjes created FLINK-16293:
Summary: Document using plugins in Kubernetes
Key: FLINK-16293
URL: https://issues.apache.org/jira/browse/FLINK-16293
Project: Flink
Issue Type: Improvement
Niels Basjes created FLINK-16871:
Summary: Make more build information available during runtime.
Key: FLINK-16871
URL: https://issues.apache.org/jira/browse/FLINK-16871
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes resolved FLINK-9610.
-
Resolution: Duplicate
This can now be done by using the changes that were part of FLINK-11693.
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104286#comment-17104286
]
Niels Basjes commented on FLINK-5479:
-
[~jaya.ananthram] At this point in time I would recommend
Niels Basjes created FLINK-18458:
Summary: Setting the property java.version makes the build brittle
and harder to debug.
Key: FLINK-18458
URL: https://issues.apache.org/jira/browse/FLINK-18458
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149345#comment-17149345
]
Niels Basjes commented on FLINK-18455:
--
Debugging the profile activation turns out to be needlessly
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-18455:
-
Description:
I was working on some changes in Flink and on my workstation I have also JDK 14
Niels Basjes created FLINK-18455:
Summary: Building with JDK 9+ leads to problems on JDK 8
Key: FLINK-18455
URL: https://issues.apache.org/jira/browse/FLINK-18455
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-18455:
-
Description:
I was working on some changes in Flink and on my workstation I have also JDK 14
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-18455:
-
Description:
I was working on some changes in Flink and on my workstation I have also JDK 14
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148533#comment-17148533
]
Niels Basjes commented on FLINK-18455:
--
Looking at the actual Flink code I found that
In a JDK 8
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148493#comment-17148493
]
Niels Basjes commented on FLINK-18455:
--
This seems like the better solution:
[
https://issues.apache.org/jira/browse/FLINK-18455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149345#comment-17149345
]
Niels Basjes edited comment on FLINK-18455 at 7/1/20, 3:28 PM:
---
Debugging
[
https://issues.apache.org/jira/browse/FLINK-18514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-18514:
-
Description:
On a system with JDK 14 installed the build fails with
{code}
[INFO] ---
[
https://issues.apache.org/jira/browse/FLINK-18514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-18514:
-
Description:
On a system with JDK 14 installed the build fails with
{code}
[INFO] ---
Niels Basjes created FLINK-18514:
Summary: Building fails with JDK 14 installed
Key: FLINK-18514
URL: https://issues.apache.org/jira/browse/FLINK-18514
Project: Flink
Issue Type: Improvement
Niels Basjes created FLINK-18607:
Summary: Give the maven modules human readable names.
Key: FLINK-18607
URL: https://issues.apache.org/jira/browse/FLINK-18607
Project: Flink
Issue Type:
Niels Basjes created FLINK-18606:
Summary: Remove generic parameter from SinkFunction.Context
Key: FLINK-18606
URL: https://issues.apache.org/jira/browse/FLINK-18606
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-18606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158074#comment-17158074
]
Niels Basjes commented on FLINK-18606:
--
The impact seems very limited.
I expect normal user
Niels Basjes created FLINK-18448:
Summary: Update Google Cloud PubSub dependencies
Key: FLINK-18448
URL: https://issues.apache.org/jira/browse/FLINK-18448
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-18448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147844#comment-17147844
]
Niels Basjes commented on FLINK-18448:
--
This problem is triggered by the removal of the deprecated
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17583037#comment-17583037
]
Niels Basjes commented on FLINK-15736:
--
FYI: I found that the twitter `chill-java` dependency also
Niels Basjes created FLINK-28911:
Summary: Elasticsearch connector fails build
Key: FLINK-28911
URL: https://issues.apache.org/jira/browse/FLINK-28911
Project: Flink
Issue Type: Bug
Niels Basjes created FLINK-31714:
Summary: Conjars.org has died
Key: FLINK-31714
URL: https://issues.apache.org/jira/browse/FLINK-31714
Project: Flink
Issue Type: Bug
Reporter:
[
https://issues.apache.org/jira/browse/FLINK-31714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes closed FLINK-31714.
Resolution: Duplicate
> Conjars.org has died
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-31714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708273#comment-17708273
]
Niels Basjes commented on FLINK-31714:
--
You are right. I ran into this while trying to build a
[
https://issues.apache.org/jira/browse/FLINK-28911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes closed FLINK-28911.
Resolution: Won't Fix
> Elasticsearch connector fails build
> ---
88 matches
Mail list logo
