This message was deleted.
# troubleshooting
s
This message was deleted.
r
I'm trying to 'fix' the datasource names bc of bad trino: https://github.com/trinodb/trino/issues/6850
h
Why don't you just re-ingest/re-index to a new datasource?
r
I only have ~ last 5 days or so in kafka, 30 days used/loaded on the historicals, and a few months of data not loaded (unused), although it could be fine to keep the 'old' segment as historical only (but during the migration I would have to rewrite all queries to query both datasources, paginations would be hard)
I think I gonna export to csv, import to s3 and load back to trino. I was doing the same thing, but download to local db, importing to postgres and then running some analytics with lots of joins where druid just can't beat pg with indexes
h
I mean reindex from druid.
Copy code
{
  "type": "index_parallel",
  "spec": {
    "ioConfig": {
      "type": "index_parallel",
      "inputSource": {
        "type": "druid",
        "dataSource": "OldDataSourceName",
        "interval": "1970-01-01T00:00:00/9999-01-01T00:00:00" 
      }
    },
...
    "dataSchema": {
...
      "dataSource": "newdatasourcename",
...
    }
  }
}
This will leave the old datasource as-is and create a new datasource with a new name
while at it, you can fine tune your segment size et cetera
• turn off kafka ingestion to old datasource • run Druid reindex task • check that it worked (at least compare numRows between old and new datasource) • turn on kafka ingestion to new datasource
r
oh! that's make sense, I can use this to reindex for the current data!
h
(Disclaimer, I'm not a Druid developer, just a user, but I did just that, and it worked great (I had lots of small segments before))
r
I forgot that this option exists!
h
just use the wizard under "Load Data" to create the spec
r
yeah, I will start this job I will not change the current ingestion right now, but I can run the analysis on a copy
thanks!
h
np
k
Yes, re-indexing is the only real way of renaming your datasource.
r
easy task but I'm unlucky today! First died with crazy error (Expected [700,958] bytes, only saw [615,989], potential corruption?) Then I reduced merge tasks, try again, then out of space (can I set the path of this task only? I've setup only 11GB on the /var/druid for the MM {just to clean restarts} ,but I have 600gb local disks on the host VM) the third I cancelled to remove some columns, tried again with just 2 days loaded, now I got out of memory ! haha
yay!
šŸ™Œ 1
g
you should have better luck in the next druid release! we've implemented substantially more self tuning for the new SQL-based ingest feature i have been enjoying using it in prerelease testing šŸ™‚
glad you got it done though
šŸ™‚ 1