[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-07-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6082 ---

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193168591 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193137905 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193132257 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193102162 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193101536 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193092151 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193084082 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSourceTestBase.java --- @@

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread tragicjun
Github user tragicjun commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r193039834 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192771700 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192770567 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192771502 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192965275 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192768664 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSourceTestBase.java --- @@

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-05 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192955182 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private