flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3933) Add an auto-type-extracting DeserializationSchema
Date Thu, 19 May 2016 11:03:12 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15290903#comment-15290903

ASF GitHub Bot commented on FLINK-3933:

Github user aljoscha commented on a diff in the pull request:

    --- Diff: docs/apis/streaming/connectors/kafka.md ---
    @@ -142,18 +142,24 @@ for querying the list of topics and partitions.
     For this to work, the consumer needs to be able to access the consumers from the machine
submitting the job to the Flink cluster.
     If you experience any issues with the Kafka consumer on the client side, the client log
might contain information about failed requests, etc.
    -##### The `DeserializationSchema`
    +##### **The `DeserializationSchema`**
    --- End diff --
    Why did you add the `**`? The other section headings don't have it.

> Add an auto-type-extracting DeserializationSchema
> -------------------------------------------------
>                 Key: FLINK-3933
>                 URL: https://issues.apache.org/jira/browse/FLINK-3933
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>    Affects Versions: 1.0.0
>            Reporter: Stephan Ewen
>            Assignee: Stephan Ewen
>             Fix For: 1.1.0
> When creating a {{DeserializationSchema}}, people need to manually worry about how to
provide the produced type's {{TypeInformation}}.
> We should add a base utility {{AbstractDeserializationSchema}} that provides that automatically
via the type extractor.

This message was sent by Atlassian JIRA

View raw message