Hi all, what is wrong ? Env. Hdp 2.4 > phoenix CREATE TABLE TB.TABLE1 ( COL1 VARCHAR(3) NOT NULL ,COL2 VARCHAR(20) ,CONSTRAINT pk PRIMARY KEY (COL1) ) SELECT T.* FROM ( SELECT * FROM TB.TABLE1 ) T SQL Error [1001] [42I01]: ERROR 1001 (42I01): Undefined column family. familyName=T.null org.apache.phoenix.schema.ColumnFamilyNotFoundException: ERROR 1001 (42I01): Undefined column family. familyName=T.null Thanks, ... View more

We have to read a text file and transfer rows to kafka. TailFile SCHEDULING like following ; Scheduling Strategy => Timer driven Run Schedule => 10 sec ( also we have tried 1 min ) When we stop and start TailFile processor works fine. Nifi does not schedule TailFile job ( maybe all processors ) itself. Where schould be controlled ? ... View more

Our use case ; In some text files coming data from some mission critical applications,these are not click stream data or something like that. We have to catch every row without data losing. At the beginning, daily approximately 15,000,000 rows expected. 30,000 rows/minute. Somehow we have to use kafka to store data. Some consumers take data from kafka topics and than write to hbase or phoenix.Here is clear for us. The most important thing is all rows in these text files must be readed anyway. Question 1. Which solution is best practice for that ? 1. Flume & Kafka ? 2. Spark streaming & Kafka ? 3. Only Spark streaming ? 4. Storm & Kafka ? 5. Flume --> to hbase or phoenix ? 6. any other solutions ? Question 2. Can we use best practice solution with Nifi ? Thanks in advance, ... View more

How can be found Phoenix jdbc drivers on maven repository with group and artifact id or direct phoenix_jdbc_bla_bla.jar like ojdbc6.jar oracle jdbc driver ? Thanks in advance ... View more