Sorry, wrong thread -----Original Message----- From: Anton Solovev [mailto:anton_solo...@epam.com] Sent: Friday, November 25, 2016 7:20 PM To: dev@flink.apache.org Subject: RE: Flink using Yarn on MapR
I agree that we should improve RowTypeInfo. But why not to keep it in Scala? In case flink-2186 that the "Row" is a "Product" is a reason of supporting wide columns indeed. Just for example I tried to move the "Row" to flink-scala module (https://github.com/apache/flink/compare/master...tonycox:FLINK-2186-x) (https://travis-ci.org/tonycox/flink/builds/178846355) -----Original Message----- From: Maximilian Michels [mailto:m...@apache.org] Sent: Friday, November 25, 2016 6:06 PM To: dev@flink.apache.org Cc: Naveen Tirupattur <ntirupat...@maprtech.com> Subject: Re: Flink using Yarn on MapR Fix is now in the master and everything should run smooth with MapR Hadoop. I'd be happy if you gave it another try. -Max On Thu, Nov 24, 2016 at 6:22 PM, Maximilian Michels <m...@apache.org> wrote: > Hi Naveen, > > The new Kerberos authentication code in Flink assumes that we're > running against vanilla Hadoop. The unmodified Hadoop's behavior is to > skip a secure login if security is not configured. This is different > for the MapR Hadoop version. > > Thus, we need to make sure we don't perform any login action if > security is not configured. I'm in the process of restructuring the > security code. I've submitted a first PR which fixes the problem > reported by you: https://github.com/apache/flink/pull/2864 > > Thanks, > Max > > On Fri, Nov 11, 2016 at 3:22 PM, vijikarthi <vijikar...@yahoo.com> wrote: >> Flink security context gets initialized during the application start phase. >> As part of the initialization, the UserGroupInformation (UGI) >> instance is bootstrapped using the Hadoop configuration files (read: >> HADOOP_CONF_DIR or YARN_CONF_DIR environment variable is set). If the >> hadoop configuration >> (core-site) enables security, then the UGI context uses JAAS module >> to load/login through Kerberos. Looks like in this case, the Hadoop >> configurations that got loaded somehow has the security enabled and >> UGI is trying to obtain the identity using keytab cache. >> >> >> >> -- >> View this message in context: >> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Flink- >> using-Yarn-on-MapR-tp14484p14496.html >> Sent from the Apache Flink Mailing List archive. mailing list archive at >> Nabble.com.
