You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Shivam Sharma <28...@gmail.com> on 2017/12/13 18:25:39 UTC

Issues in migrating code from 1.3.2 to 1.4.0

Hi

I am getting following issues in working code in new version 1.4.0.

org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
instantiate user function.
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:235)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:355)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:282)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:346)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:282)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:346)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:282)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:126)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:231)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassCastException: cannot assign instance of
com.goibibo.NewClass$$anonfun$main$1 to field
org.apache.flink.streaming.api.scala.DataStream$$anon$6.cleanFun$5 of type
scala.Function1 in instance of
org.apache.flink.streaming.api.scala.DataStream$$anon$6
at
java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2133)
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1305)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2251)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2245)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:290)
at
org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:248)
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:220)
... 10 more

-- 
Shivam Sharma
Data Engineer @ Goibibo
Indian Institute Of Information Technology, Design and Manufacturing
Jabalpur
Mobile No- (+91) 8882114744
Email:- 28shivamsharma@gmail.com
LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
<https://www.linkedin.com/in/28shivamsharma>*

Re: Issues in migrating code from 1.3.2 to 1.4.0

Posted by Fabian Hueske <fh...@gmail.com>.
Can you give a bit more context?

When does the error occur?
Does it happen in the client (i.e., when the query is optimized and the
plan is generated) or in the JobManager or TaskManager when the plan is
submitted to the cluster?
Do you try to start from a savepoint?

Thank you,
Fabian


2017-12-14 8:52 GMT+01:00 Shivam Sharma <28...@gmail.com>:

> yeah I am using Table API of flink.
>
> Basically I am creating my UserDefined Function like below:
>
> class DateTimeUDF extends ScalarFunction {
>
>     def eval(timeStamp: String, destFormat: String): String = {
>         val format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
>         val date: Date = format.parse(timeStamp)
>         new SimpleDateFormat(destFormat).format(date)
>     }
> }
>
> And I am registering this function on Table env like below:
>
> tableEnv.registerFunction("changeDTFormat", new DateTimeUDF())
>
> Note:- My code is working fine in Flink 1.3.2.
>
> On Thu, Dec 14, 2017 at 11:42 AM, Aljoscha Krettek <al...@apache.org>
> wrote:
>
> > Hi,
> >
> > Could you please provide a bit of context. From your second email I
> gather
> > that you're using the Table API, is that right?
> >
> > Best,
> > Aljoscha
> >
> > > On 14. Dec 2017, at 07:08, Shivam Sharma <28...@gmail.com>
> > wrote:
> > >
> > > Basically I am registering one scalarfunction in my code. Is there any
> > > change in writing or registering a User Defined function in flink
> 1.4.0?
> > >
> > > On Wed, Dec 13, 2017 at 11:55 PM, Shivam Sharma <
> > 28shivamsharma@gmail.com>
> > > wrote:
> > >
> > >> Hi
> > >>
> > >> I am getting following issues in working code in new version 1.4.0.
> > >>
> > >> org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
> > >> instantiate user function.
> > >> at org.apache.flink.streaming.api.graph.StreamConfig.
> getStreamOperator(
> > >> StreamConfig.java:235)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> > >> createChainedOperator(OperatorChain.java:355)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> > >> createOutputCollector(OperatorChain.java:282)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> > >> createChainedOperator(OperatorChain.java:346)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> > >> createOutputCollector(OperatorChain.java:282)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> > >> createChainedOperator(OperatorChain.java:346)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> > >> createOutputCollector(OperatorChain.java:282)
> > >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.<
> > >> init>(OperatorChain.java:126)
> > >> at org.apache.flink.streaming.runtime.tasks.StreamTask.
> > >> invoke(StreamTask.java:231)
> > >> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
> > >> at java.lang.Thread.run(Thread.java:748)
> > >> Caused by: java.lang.ClassCastException: cannot assign instance of
> > >> com.goibibo.NewClass$$anonfun$main$1 to field
> > org.apache.flink.streaming.
> > >> api.scala.DataStream$$anon$6.cleanFun$5 of type scala.Function1 in
> > >> instance of org.apache.flink.streaming.api.scala.DataStream$$anon$6
> > >> at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(
> > >> ObjectStreamClass.java:2133)
> > >> at java.io.ObjectStreamClass.setObjFieldValues(
> > >> ObjectStreamClass.java:1305)
> > >> at java.io.ObjectInputStream.defaultReadFields(
> > >> ObjectInputStream.java:2251)
> > >> at java.io.ObjectInputStream.readSerialData(
> > ObjectInputStream.java:2169)
> > >> at java.io.ObjectInputStream.readOrdinaryObject(
> > >> ObjectInputStream.java:2027)
> > >> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> > >> at java.io.ObjectInputStream.defaultReadFields(
> > >> ObjectInputStream.java:2245)
> > >> at java.io.ObjectInputStream.readSerialData(
> > ObjectInputStream.java:2169)
> > >> at java.io.ObjectInputStream.readOrdinaryObject(
> > >> ObjectInputStream.java:2027)
> > >> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> > >> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
> > >> at org.apache.flink.util.InstantiationUtil.deserializeObject(
> > >> InstantiationUtil.java:290)
> > >> at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(
> > >> InstantiationUtil.java:248)
> > >> at org.apache.flink.streaming.api.graph.StreamConfig.
> getStreamOperator(
> > >> StreamConfig.java:220)
> > >> ... 10 more
> > >>
> > >> --
> > >> Shivam Sharma
> > >> Data Engineer @ Goibibo
> > >> Indian Institute Of Information Technology, Design and Manufacturing
> > >> Jabalpur
> > >> Mobile No- (+91) 8882114744
> > >> Email:- 28shivamsharma@gmail.com
> > >> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> > >> <https://www.linkedin.com/in/28shivamsharma>*
> > >>
> > >
> > >
> > >
> > > --
> > > Shivam Sharma
> > > Data Engineer @ Goibibo
> > > Indian Institute Of Information Technology, Design and Manufacturing
> > > Jabalpur
> > > Mobile No- (+91) 8882114744
> > > Email:- 28shivamsharma@gmail.com
> > > LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> > > <https://www.linkedin.com/in/28shivamsharma>*
> >
> >
>
>
> --
> Shivam Sharma
> Data Engineer @ Goibibo
> Indian Institute Of Information Technology, Design and Manufacturing
> Jabalpur
> Mobile No- (+91) 8882114744
> Email:- 28shivamsharma@gmail.com
> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> <https://www.linkedin.com/in/28shivamsharma>*
>

Re: Issues in migrating code from 1.3.2 to 1.4.0

Posted by Shivam Sharma <28...@gmail.com>.
yeah I am using Table API of flink.

Basically I am creating my UserDefined Function like below:

class DateTimeUDF extends ScalarFunction {

    def eval(timeStamp: String, destFormat: String): String = {
        val format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
        val date: Date = format.parse(timeStamp)
        new SimpleDateFormat(destFormat).format(date)
    }
}

And I am registering this function on Table env like below:

tableEnv.registerFunction("changeDTFormat", new DateTimeUDF())

Note:- My code is working fine in Flink 1.3.2.

On Thu, Dec 14, 2017 at 11:42 AM, Aljoscha Krettek <al...@apache.org>
wrote:

> Hi,
>
> Could you please provide a bit of context. From your second email I gather
> that you're using the Table API, is that right?
>
> Best,
> Aljoscha
>
> > On 14. Dec 2017, at 07:08, Shivam Sharma <28...@gmail.com>
> wrote:
> >
> > Basically I am registering one scalarfunction in my code. Is there any
> > change in writing or registering a User Defined function in flink 1.4.0?
> >
> > On Wed, Dec 13, 2017 at 11:55 PM, Shivam Sharma <
> 28shivamsharma@gmail.com>
> > wrote:
> >
> >> Hi
> >>
> >> I am getting following issues in working code in new version 1.4.0.
> >>
> >> org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
> >> instantiate user function.
> >> at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(
> >> StreamConfig.java:235)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> >> createChainedOperator(OperatorChain.java:355)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> >> createOutputCollector(OperatorChain.java:282)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> >> createChainedOperator(OperatorChain.java:346)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> >> createOutputCollector(OperatorChain.java:282)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> >> createChainedOperator(OperatorChain.java:346)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> >> createOutputCollector(OperatorChain.java:282)
> >> at org.apache.flink.streaming.runtime.tasks.OperatorChain.<
> >> init>(OperatorChain.java:126)
> >> at org.apache.flink.streaming.runtime.tasks.StreamTask.
> >> invoke(StreamTask.java:231)
> >> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
> >> at java.lang.Thread.run(Thread.java:748)
> >> Caused by: java.lang.ClassCastException: cannot assign instance of
> >> com.goibibo.NewClass$$anonfun$main$1 to field
> org.apache.flink.streaming.
> >> api.scala.DataStream$$anon$6.cleanFun$5 of type scala.Function1 in
> >> instance of org.apache.flink.streaming.api.scala.DataStream$$anon$6
> >> at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(
> >> ObjectStreamClass.java:2133)
> >> at java.io.ObjectStreamClass.setObjFieldValues(
> >> ObjectStreamClass.java:1305)
> >> at java.io.ObjectInputStream.defaultReadFields(
> >> ObjectInputStream.java:2251)
> >> at java.io.ObjectInputStream.readSerialData(
> ObjectInputStream.java:2169)
> >> at java.io.ObjectInputStream.readOrdinaryObject(
> >> ObjectInputStream.java:2027)
> >> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> >> at java.io.ObjectInputStream.defaultReadFields(
> >> ObjectInputStream.java:2245)
> >> at java.io.ObjectInputStream.readSerialData(
> ObjectInputStream.java:2169)
> >> at java.io.ObjectInputStream.readOrdinaryObject(
> >> ObjectInputStream.java:2027)
> >> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> >> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
> >> at org.apache.flink.util.InstantiationUtil.deserializeObject(
> >> InstantiationUtil.java:290)
> >> at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(
> >> InstantiationUtil.java:248)
> >> at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(
> >> StreamConfig.java:220)
> >> ... 10 more
> >>
> >> --
> >> Shivam Sharma
> >> Data Engineer @ Goibibo
> >> Indian Institute Of Information Technology, Design and Manufacturing
> >> Jabalpur
> >> Mobile No- (+91) 8882114744
> >> Email:- 28shivamsharma@gmail.com
> >> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> >> <https://www.linkedin.com/in/28shivamsharma>*
> >>
> >
> >
> >
> > --
> > Shivam Sharma
> > Data Engineer @ Goibibo
> > Indian Institute Of Information Technology, Design and Manufacturing
> > Jabalpur
> > Mobile No- (+91) 8882114744
> > Email:- 28shivamsharma@gmail.com
> > LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> > <https://www.linkedin.com/in/28shivamsharma>*
>
>


-- 
Shivam Sharma
Data Engineer @ Goibibo
Indian Institute Of Information Technology, Design and Manufacturing
Jabalpur
Mobile No- (+91) 8882114744
Email:- 28shivamsharma@gmail.com
LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
<https://www.linkedin.com/in/28shivamsharma>*

Re: Issues in migrating code from 1.3.2 to 1.4.0

Posted by Aljoscha Krettek <al...@apache.org>.
Hi,

Could you please provide a bit of context. From your second email I gather that you're using the Table API, is that right?

Best,
Aljoscha

> On 14. Dec 2017, at 07:08, Shivam Sharma <28...@gmail.com> wrote:
> 
> Basically I am registering one scalarfunction in my code. Is there any
> change in writing or registering a User Defined function in flink 1.4.0?
> 
> On Wed, Dec 13, 2017 at 11:55 PM, Shivam Sharma <28...@gmail.com>
> wrote:
> 
>> Hi
>> 
>> I am getting following issues in working code in new version 1.4.0.
>> 
>> org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
>> instantiate user function.
>> at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(
>> StreamConfig.java:235)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
>> createChainedOperator(OperatorChain.java:355)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
>> createOutputCollector(OperatorChain.java:282)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
>> createChainedOperator(OperatorChain.java:346)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
>> createOutputCollector(OperatorChain.java:282)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
>> createChainedOperator(OperatorChain.java:346)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
>> createOutputCollector(OperatorChain.java:282)
>> at org.apache.flink.streaming.runtime.tasks.OperatorChain.<
>> init>(OperatorChain.java:126)
>> at org.apache.flink.streaming.runtime.tasks.StreamTask.
>> invoke(StreamTask.java:231)
>> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
>> at java.lang.Thread.run(Thread.java:748)
>> Caused by: java.lang.ClassCastException: cannot assign instance of
>> com.goibibo.NewClass$$anonfun$main$1 to field org.apache.flink.streaming.
>> api.scala.DataStream$$anon$6.cleanFun$5 of type scala.Function1 in
>> instance of org.apache.flink.streaming.api.scala.DataStream$$anon$6
>> at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(
>> ObjectStreamClass.java:2133)
>> at java.io.ObjectStreamClass.setObjFieldValues(
>> ObjectStreamClass.java:1305)
>> at java.io.ObjectInputStream.defaultReadFields(
>> ObjectInputStream.java:2251)
>> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
>> at java.io.ObjectInputStream.readOrdinaryObject(
>> ObjectInputStream.java:2027)
>> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
>> at java.io.ObjectInputStream.defaultReadFields(
>> ObjectInputStream.java:2245)
>> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
>> at java.io.ObjectInputStream.readOrdinaryObject(
>> ObjectInputStream.java:2027)
>> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
>> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
>> at org.apache.flink.util.InstantiationUtil.deserializeObject(
>> InstantiationUtil.java:290)
>> at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(
>> InstantiationUtil.java:248)
>> at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(
>> StreamConfig.java:220)
>> ... 10 more
>> 
>> --
>> Shivam Sharma
>> Data Engineer @ Goibibo
>> Indian Institute Of Information Technology, Design and Manufacturing
>> Jabalpur
>> Mobile No- (+91) 8882114744
>> Email:- 28shivamsharma@gmail.com
>> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
>> <https://www.linkedin.com/in/28shivamsharma>*
>> 
> 
> 
> 
> -- 
> Shivam Sharma
> Data Engineer @ Goibibo
> Indian Institute Of Information Technology, Design and Manufacturing
> Jabalpur
> Mobile No- (+91) 8882114744
> Email:- 28shivamsharma@gmail.com
> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> <https://www.linkedin.com/in/28shivamsharma>*

Re: Issues in migrating code from 1.3.2 to 1.4.0

Posted by Shivam Sharma <28...@gmail.com>.
Basically I am registering one scalarfunction in my code. Is there any
change in writing or registering a User Defined function in flink 1.4.0?

On Wed, Dec 13, 2017 at 11:55 PM, Shivam Sharma <28...@gmail.com>
wrote:

> Hi
>
> I am getting following issues in working code in new version 1.4.0.
>
> org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
> instantiate user function.
> at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(
> StreamConfig.java:235)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> createChainedOperator(OperatorChain.java:355)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> createOutputCollector(OperatorChain.java:282)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> createChainedOperator(OperatorChain.java:346)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> createOutputCollector(OperatorChain.java:282)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> createChainedOperator(OperatorChain.java:346)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.
> createOutputCollector(OperatorChain.java:282)
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.<
> init>(OperatorChain.java:126)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.
> invoke(StreamTask.java:231)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.ClassCastException: cannot assign instance of
> com.goibibo.NewClass$$anonfun$main$1 to field org.apache.flink.streaming.
> api.scala.DataStream$$anon$6.cleanFun$5 of type scala.Function1 in
> instance of org.apache.flink.streaming.api.scala.DataStream$$anon$6
> at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(
> ObjectStreamClass.java:2133)
> at java.io.ObjectStreamClass.setObjFieldValues(
> ObjectStreamClass.java:1305)
> at java.io.ObjectInputStream.defaultReadFields(
> ObjectInputStream.java:2251)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
> at java.io.ObjectInputStream.readOrdinaryObject(
> ObjectInputStream.java:2027)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> at java.io.ObjectInputStream.defaultReadFields(
> ObjectInputStream.java:2245)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
> at java.io.ObjectInputStream.readOrdinaryObject(
> ObjectInputStream.java:2027)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
> at org.apache.flink.util.InstantiationUtil.deserializeObject(
> InstantiationUtil.java:290)
> at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(
> InstantiationUtil.java:248)
> at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(
> StreamConfig.java:220)
> ... 10 more
>
> --
> Shivam Sharma
> Data Engineer @ Goibibo
> Indian Institute Of Information Technology, Design and Manufacturing
> Jabalpur
> Mobile No- (+91) 8882114744
> Email:- 28shivamsharma@gmail.com
> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> <https://www.linkedin.com/in/28shivamsharma>*
>



-- 
Shivam Sharma
Data Engineer @ Goibibo
Indian Institute Of Information Technology, Design and Manufacturing
Jabalpur
Mobile No- (+91) 8882114744
Email:- 28shivamsharma@gmail.com
LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
<https://www.linkedin.com/in/28shivamsharma>*