you’re using compile target lower then 1.8, what needs to be done depends
on your build tool

On Fri 7. 1. 2022 at 20:05, Flink Lover <flinkbyhe...@gmail.com> wrote:

> Hi David,
>
> Thanks for your explanation!
>
> I am familiar with how JVM works but why am I facing this issue? What
> exactly needs to be done?
>
> Thanks,
> Martin O.
>
> On Sat, Jan 8, 2022 at 12:19 AM David Morávek <d...@apache.org> wrote:
>
>> Hi Siddhesh,
>>
>> any JVM based language (Java, Scala, Kotlin) compiles into a byte-code
>> that can be executed by the JVM. As the JVM was evolving over the years,
>> new versions of byte code have been introduced. Target version simply
>> refers the the version of bytecode the compiler should generate. How to
>> specify it depends on the used build tool, but in general it all boils down
>> to running java compiler with specified "-target" [1].
>>
>> [1]
>> https://docs.oracle.com/javase/8/docs/technotes/tools/windows/javac.html
>>
>> D.
>>
>> On Fri, Jan 7, 2022 at 6:22 PM Flink Lover <flinkbyhe...@gmail.com>
>> wrote:
>>
>>> Could you please help me with this?
>>>
>>> On Fri, Jan 7, 2022 at 11:48 AM Flink Lover <flinkbyhe...@gmail.com>
>>> wrote:
>>>
>>>> I tried Flink version 1.14.2 / 1.13.5
>>>>
>>>> On Fri, Jan 7, 2022 at 11:46 AM Flink Lover <flinkbyhe...@gmail.com>
>>>> wrote:
>>>>
>>>>> Also, I am using flink-connector-kafka_2.11
>>>>>
>>>>> val consumer = new FlinkKafkaConsumer[String]("topic_name", new
>>>>> SimpleStringSchema(), properties)
>>>>>
>>>>>
>>>>> val myProducer = new FlinkKafkaProducer[String](
>>>>>       "topic_name", // target topic
>>>>>       new KeyedSerializationSchemaWrapper[String](new
>>>>> SimpleStringSchema()), // serialization schema
>>>>>       getProperties(), // producer config
>>>>>       FlinkKafkaProducer.Semantic.AT_LEAST_ONCE)
>>>>>
>>>>>
>>>>>
>>>>> On Fri, Jan 7, 2022 at 11:43 AM Flink Lover <flinkbyhe...@gmail.com>
>>>>> wrote:
>>>>>
>>>>>> Hi All,
>>>>>>
>>>>>> I checked the Java version using the java -version on the terminal
>>>>>> and it gave me 1.8.0.281. Also, the project has been compiled using JDK 8
>>>>>> only which is by default.
>>>>>>
>>>>>> [image: image.png]
>>>>>>
>>>>>> What do you mean by target jvm? Also, what I am trying to achieve is
>>>>>> correct? about the windows?
>>>>>>
>>>>>> Thanks,
>>>>>> Martin
>>>>>>
>>>>>> On Fri, Jan 7, 2022 at 8:07 AM Qingsheng Ren <renqs...@gmail.com>
>>>>>> wrote:
>>>>>>
>>>>>>> Hi Martin,
>>>>>>>
>>>>>>> Can you provide the configuration of your Kafka producer and
>>>>>>> consumer? Also it’ll be helpful to have the complete code of your
>>>>>>> DataStream.
>>>>>>>
>>>>>>> About the error you mentioned, I doubt that the JDK version you
>>>>>>> actually use is probably below 1.8. Can you have a double check on the
>>>>>>> environment that your job is running in?
>>>>>>>
>>>>>>> Cheers,
>>>>>>>
>>>>>>> Qingsheng Ren
>>>>>>>
>>>>>>>
>>>>>>> > On Jan 7, 2022, at 1:13 AM, Flink Lover <flinkbyhe...@gmail.com>
>>>>>>> wrote:
>>>>>>> >
>>>>>>> > Hello Folks!
>>>>>>> >
>>>>>>> > I have a DataStream which sends data to the consumer but I got the
>>>>>>> data once the code completed its execution. I didn't receive the 
>>>>>>> records as
>>>>>>> the code was writing it to the topic. I was able to achieve this 
>>>>>>> behavior
>>>>>>> using AT_LEAST_ONCE property but I decided to implement Watermarks. I
>>>>>>> haven't enabled checkpointing as of now. I know checkpointing will also 
>>>>>>> do
>>>>>>> the trick.  My expectation is Producer should batch the records of 2
>>>>>>> seconds and send it to the consumer and consumer should receive a batch 
>>>>>>> of
>>>>>>> 2 seconds. My code goes as below:
>>>>>>> >
>>>>>>> > Producer Side:
>>>>>>> >  dataToKafka.assignTimestampsAndWatermarks(
>>>>>>> >       WatermarkStrategy
>>>>>>> >         .forBoundedOutOfOrderness[String](Duration.ofSeconds(2)))
>>>>>>> >     dataToKafka.addSink(myProducer).uid("source")
>>>>>>> >
>>>>>>> > Consumer Side:
>>>>>>> > consumer.assignTimestampsAndWatermarks(
>>>>>>> >       WatermarkStrategy
>>>>>>> >         .forBoundedOutOfOrderness[String](Duration.ofSeconds(2)))
>>>>>>> >
>>>>>>> > Now this gives me an error as below:
>>>>>>> >
>>>>>>> > Static methods in interface require -target:jvm-1.8
>>>>>>> >         .forBoundedOutOfOrderness[String](Duration.ofSeconds(2)))
>>>>>>> >
>>>>>>> > My scala version is 2.11.12 and Java JDK 1.8.0.281
>>>>>>> >
>>>>>>> > Thanks,
>>>>>>> > Martin.
>>>>>>> >
>>>>>>> >
>>>>>>> >
>>>>>>>
>>>>>>>

Reply via email to