Forum Discussion

coolie's avatar
coolie
Helper I
2 years ago

Create additional column for partition id

I am reading Rest data to create a lakehouse table, but I'd now like the table to be partitioned by date of the daily run. I eventually managed to add the additional source column (derived from pipeline run time) as a string, and add it to the mapping, but get an error when I run the pipeline: 

 

"ErrorCode=PartitioneddestinationMissingTypeConversion

Message=destination partition required input TypeConversion is missing"

 

Additional columns have to be strings, and strings are permitted for partitioning, so not sure what I can do to fix it?

8 Replies

  • v-cboorla-msft's avatar
    v-cboorla-msft
    Microsoft Employee

    Hi coolie 

     

    Thanks for using Fabric Community.

    Could you please give us more details about the additional source column which you have enabled partition for? Please provide some screen shots of the copy data mapping. This would help me to understand the issue and help you better.

     

    Thanks

    • coolie's avatar
      coolie
      Helper I

      These are the additional columns. I have 2 variables. The first is pipeline trigger time in format yyyyDDmm. The second is productId created from a variable.

      Source:

      Destination:

      And here is the mapping. I've also tried long as the target type:

      I am currently using overwrite because if I use append you get duplicate data if the pipeline is run more than once, as there does not seem to be an upsert option. Im hoping that once I get partitioning working, it will only overwrite the relevant partition and not the whole lakehouse (see https://community.fabric.microsoft.com/t5/Data-Pipelines/Appending-data-to-a-partitioned-table-in-the-Lakehouse/m-p/3396450 )

      • v-cboorla-msft's avatar
        v-cboorla-msft
        Microsoft Employee

        Hi coolie 

         

        Thanks for your reponse.

         

        I have tried to repro the same scenario but couldn't find any error. So could you please confirm if you are missing something or if I am missing any steps in the process.

         

        Please find the screenshots and the steps I followed for my repro.

        To do the repro I took source as Lakehouse and selected the sampledata table, destination as Lakeshouse named the output as DemoTable.

        Source:

        Destination:

        Mapping:

        Result:

         

        I hope this helps. If you have any further questions please do let us know.

         

  • Hi there,

     

    what was the resolution to this? I am having a similar issue where I am getting the below error. My source is also a REST api.

    ErrorCode=PartitionedSinkMissingTypeConversion,'Type=Microsoft.DataTransfer.Common.Shared.HybridDeliveryException,Message=Sink partition required input TypeConversion is missing ,Source=Microsoft.DataTransfer.ClientLibrary,'





     

    Partition Column

     

    Source Tab