Hi,     I've been getting problems with the consumer in CDH5.13.0. For other CDH-5.11.0 and CDH-5.12.0 versions with Kafka version : 0.10.2-kafka-2.2.0 are working fine. Added advertised.listeners also and i'm running in a non-secure environment. Observed client.id is blank for console consumer whereas it is client.id = console-producer for producer. I need to work with CDH-5.13.0,please help me out   When I run the old API consumer, it works by running bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning However, when I run the new API consumer, I don't get anything when I run bin/kafka-console-consumer.sh --new-consumer --topic test --from-beginning  --bootstrap-server localhost:9092     ... View more

Hi,     ISSUE: Requested data length 146629817 is longer than maximum configured RPC length 134217728 Earlier , ipc.maximum.data.length used to be 64MB and got the same error and we changed that to 128MB. Now again it got exceeded and resulting  data corruption/missing issues. Is there any maximum configurable value of  ipc.maximum.data.length? Can we change this value above 128MB?    Thanks in advance ... View more

Hi guys,   How can I make a file undeletable in Hdfs. Any suggestions ?   Thanks in advance     ... View more

Hi All, I added  fs.s3n.awsAccessKeyId and fs.s3n.awsSecretAccessKey properties in core,hdfs,hive-site.xml. I am able to run select * from tbl which is on s3 and got the resullt with beeline.But, when i run select count(*) from tbl, it's getting failed with following errors Error: java.io.IOException: java.lang.reflect. InvocationTargetException         at org.apache.hadoop.hive.io. HiveIOExceptionHandlerChain. handleRecordReaderCreationExce ption( HiveIOExceptionHandlerChain. java:97)        ........ Caused by: java.lang.reflect. InvocationTargetException         at sun.reflect. NativeConstructorAccessorImpl. newInstance0(Native Method)         at org.apache.hadoop.hive.shims. HadoopShimsSecure$ CombineFileRecordReader. initNextRecordReader( HadoopShimsSecure.java:251)         ... 11 more Caused by: java.io.IOException: s3n://rakeshs3 : 400 : Bad Request         at org.apache.hadoop.fs.s3native. Jets3tNativeFileSystemStore. processException( Jets3tNativeFileSystemStore. java:453)         at org.apache.hadoop.fs.s3native. Jets3tNativeFileSystemStore. processException( Jets3tNativeFileSystemStore. java:427)                   ... 16 more Caused by: org.jets3t.service.impl.rest. HttpException: 400 Bad Request         at org.jets3t.service.impl.rest. httpclient.RestStorageService. performRequest( RestStorageService.java:425)         at org.jets3t.service.impl.rest. httpclient.RestStorageService. performRequest( RestStorageService.java:279)               ... 29 more   Impala Errors: Failed to open HDFS file s3n://rakeshs3/tel.txt    Error(255): Unknown error 255   Thanks ... View more

Dear Team,   I am using CDH5.4.7 i enabled kerberos and level1&2 TLS/SSL.. Successfully enabled for other CDH services except Solr... After enabling ssl for solr the following errors occurs.   Solr Server API Liveness Suppress... The Cloudera Manager Agent is not able to communicate with this Solr Server over the HTTP API. Web Server Status Suppress... The Cloudera Manager Agent is not able to communicate with this role's web server.   In the solr server logs:   ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted   could not read the data org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired for /overseer_elect/leader   Error while calling watcher java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@27cd611e rejected from java.util.concurrent.ThreadPoolExecutor@1ca30cfc[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]       ... View more