I’ve a python transformation file in development box and would like to create kafka pipeline using transformation.however, i’m getting the following error.
Error message:
Failed to download transform from URL ‘file://G:\tweet_tiny.py’ because ‘libcurl error:Couldn’t read a file:// file’
CREATE PIPELINE tweet
AS LOAD DATA KAFKA ‘localhost:9092/my_topic’
BATCH_INTERVAL 2500
ENABLE OUT_OF_ORDER OPTIMIZATION
WITH TRANSFORM (‘file://G:\tweet_tiny.py’ , ‘’ , ‘’)
SKIP ALL ERRORS
INTO TABLE tweet_tiny
FIELDS TERMINATED BY ‘\t’ ENCLOSED BY ‘’ ESCAPED BY ‘\’
LINES TERMINATED BY ‘\n’ STARTING BY ‘’
(
tweet_tiny
.tweet_id
,
tweet_tiny
.body
,
tweet_tiny
.actor_id
,
tweet_tiny
.posted_time
)
SingleStore DB Version: 7.8.12
Any help is appreciated