Compilation error in the project

[amitsinha1606]

Hi,

I clone the repo https://github.com/dataArtisans/flink-streaming-demo.git.
After that I imported the project to an IDE. However i am getting compilation error, see screenshot below :

Also as suggested i run the project with the following configuration (screenshot below), however i end up getting an error "Error: Could not find or load main class com.dataartisans.flink_demo.examples.TotalArrivalCount.scala"

[fhueske]

Hi,
I just cloned the repository and was able to run the examples.
The GeoPoint class is defined in the TaxiRide.scala files. Scala does not require that the class name is the same as the file name and support multiple class definitions in one file. However, the code violates the Scala convention, that multi-unit classes should start with a lowercase letter.

Regarding the second issue, have you tried to remove the .scala suffix from the class parameter?

[amitsinha1606]

Hi,

thanks for the reply. The compilation error is still not resolved. Am i missing anything ?
I tried by removing .scala too but still getting the same error :-(

Thanks
Amit

[fhueske]

Not sure what is going on there. You could try to extract the GeoPoint case class into a separate file.

The run command probably fails because the sources cannot be compiled.

[vikramkommaraju]

I saw the same issue. This was because the source was compiled with an older version of Scala and my IDE was using a newer version. Specifically 2.10.x vs 2.11.

You set the Scala Library Container version to 2.10.x. If it's 2.11.x, you'll see compile errors.