Tag: apache-flink
Apache Flink ist ein open-source-Plattform für skalierbare batch-und stream-Verarbeitung von Daten. Flink unterstützt batch-und streaming-analytics, in einem system. Analytische Programme geschrieben werden können, werden in übersichtlichen und eleganten APIs in Java und Scala.
konnte nicht finden, impliziten Wert für Beweise parameter vom Typ org.apache.flink.api.common.typeinfo.TypeInformation[...]
3 Antworten
Ich bin versucht, zu schreiben einige Anwendungsfälle für Apache Flink. Ein Fehler, ich Laufe ziemlich oft ist could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[SomeType] Mein problem ist, dass ich kann nicht wirklich festzunageln,
java.lang.NoSuchMethodError: scala.Vordef$.ArrowAssoc(Ljava/lang/Objekt;)Ljava/lang/Object
1 Antworten
Arbeite ich mit flink und kafka, bekam ich diese Fehlermeldung. java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object; at kafka.consumer.FetchRequestAndResponseMetrics.<init>(FetchRequestAndResponseStats.scala:32) at kafka.consumer.FetchRequestAndResponseStats.<init>(FetchRequestAndResponseStats.scala:46) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59) at kafka.utils.Pool.getAndMaybePut(Pool.scala:61) at kafka.consumer.FetchRequestAndResponseStatsRegistry$.getFetchRequestAndResponseStats(FetchRequestAndResponseStats.scala:63) at kafka.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:39) at kafka.javaapi.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:34) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer.getPartitionsForTopic(FlinkKafkaConsumer.java:695) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer.<init>(FlinkKafkaConsumer.java:281) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082.<init>(FlinkKafkaConsumer082.java:49) at com.inndata.flinkkafka.ReadFromKafka.main(ReadFromKafka.java:19) at
Wie verwenden Sie multi-thread-Verbraucher in kafka 0.9.0?
3 Antworten
Den doc von kafka geben einen Ansatz über mit folgenden beschreibt: Einen Consumer-Pro-Thread:Eine einfache option zu geben, ist jeder thread seine eigenen consumer > Instanz. Mein code: public class KafkaConsumerRunner implements Runnable { private final AtomicBoolean closed
Was ist / sind die Hauptunterschiede zwischen Flink und Storm?
2 Antworten
Flink wurde im Vergleich zu Sparkdie, so wie ich es sehe, ist der falsche Vergleich, da er vergleicht einen Fenster-event-processing-system gegen Mikro-Dosierung; Ähnlich, es macht nicht viel Sinn für mich zu vergleichen Flink zu Samza. In beiden
Was ist der Unterschied zwischen Apache Spark und Apache Flink?
6 Antworten
Was sind die Unterschiede zwischen Apache Spark und Apache Flink? Wird Apache Flink ersetzen Hadoop? InformationsquelleAutor der Frage virender | 2015-01-22