IDEA only show "cannot resolve constructor" error message, without other error message.
Dawid Wysakowicz <dwysakow...@apache.org> 于2018年10月10日周三 下午5:55写道: > Hi, > > what is the exact error message you are getting? > > Best, > > Dawid > > On 10/10/18 11:51, 远远 wrote: > > invoke FlinkKafkaProducer011 constructor in scala: > > val producer = new > FlinkKafkaProducer011[PVEvent.Entity](appConf.getPvEventTopic, new > PvEventSerializeSchema, producerProps, > Optional.of(FlinkRebalancePartitioner[PVEvent.Entity])) > > and the constructor is : > > /** * Creates a FlinkKafkaProducer for a given topic. The sink produces its > input to * the topic. It accepts a keyed {@link KeyedSerializationSchema} and > possibly a custom {@link FlinkKafkaPartitioner}. * * <p>If a partitioner is > not provided, written records will be partitioned by the attached key of each > * record (as determined by {@link > KeyedSerializationSchema#serializeKey(Object)}). If written records do not * > have a key (i.e., {@link KeyedSerializationSchema#serializeKey(Object)} > returns {@code null}), they * will be distributed to Kafka partitions in a > round-robin fashion. * * @param defaultTopicId The default topic to write > data to * @param serializationSchema A serializable serialization schema for > turning user objects into a kafka-consumable byte[] supporting key/value > messages * @param producerConfig Configuration properties for the > KafkaProducer. 'bootstrap.servers.' is the only required argument. * @param > customPartitioner A serializable partitioner for assigning messages to Kafka > partitions. * If a partitioner is not provided, > records will be partitioned by the key of each record * > (determined by {@link KeyedSerializationSchema#serializeKey(Object)}). If > the keys * are {@code null}, then records will be > distributed to Kafka partitions in a * round-robin > fashion. */public FlinkKafkaProducer011( > String defaultTopicId, KeyedSerializationSchema<IN> > serializationSchema, Properties producerConfig, > Optional<FlinkKafkaPartitioner<IN>> customPartitioner) { > this( > defaultTopicId, serializationSchema, producerConfig, > customPartitioner, Semantic.AT_LEAST_ONCE, > DEFAULT_KAFKA_PRODUCERS_POOL_SIZE);} > > but cannot complie pass, and IDEA show ''cannot resolve constructor" > error. > and i invoke other constructor that without java8 Optional params, it > will no > error。 because of java8 Optional param?what should i do? > > >