f employee.
Request you to please let me know if I am doing something wrong.
regards,
Shamit Jain
Thanks!!
On 2021/07/14 02:26:47, JING ZHANG wrote:
> Hi, Shamit Jain,
> In fact, it is an optimization to simplify expression.
> If a Udf has no parameters, optimizer would be look it as an expression
> which always generate constants results.
> So it would be calculated once
a:127)
at
org.apache.flink.streaming.api.functions.sink.filesystem.Bucket.restore(Bucket.java:466)
at org.apache.flink.streaming.api.functions.sink.filesystem.Def
regards,
Shamit Jain
ousTypes, newRowSerializer.types)) {
return TypeSerializerSchemaCompatibility.incompatible();
}
Can you please help me to understand if we can add a new column in an
existing table and deploy from the snapshot?
Regards,
Shamit Jain
cs-release-1.13/docs/dev/datastream/fault-tolerance/schema_evolution/#evolving-state-schema
Regards,
Shamit Jain
On Wed, Dec 29, 2021 at 5:09 AM Martijn Visser
wrote:
> Hi Shamit,
>
> Adding columns means that you're trying to perform schema evolution, which
> isn'
Thanks Martijn! I will check Datastream APIs, if it fits in our use case.
Regards,
Shamit Jain
On Thu, Dec 30, 2021 at 3:44 AM Martijn Visser
wrote:
> Hi Shamit,
>
> Yes, there are more possibilities when using the DataStream API like with
> the link you've included. You c