[jira] [Commented] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434948#comment-16434948 ] ASF GitHub Bot commented on FLINK-9124: --- Github user tweise commented on a diff in the pull request:

[GitHub] flink pull request #5803: [FLINK-9124] [kinesis] Allow customization of Kine...

2018-04-11 Thread tweise
Github user tweise commented on a diff in the pull request: https://github.com/apache/flink/pull/5803#discussion_r180967646 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@ -176,6 +179,16

[jira] [Assigned] (FLINK-9159) Sanity check default timeout values

2018-04-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9159: --- Assignee: vinoyang > Sanity check default timeout values > --- > >

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434886#comment-16434886 ] ASF GitHub Bot commented on FLINK-9158: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5839: [FLINK-9158][Distributed Coordination] Set default FixedR...

2018-04-11 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5839 CC: @tillrohrmann ---

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434884#comment-16434884 ] ASF GitHub Bot commented on FLINK-9158: --- GitHub user sihuazhou opened a pull request:

[jira] [Assigned] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-11 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9158: - Assignee: Sihua Zhou > Set default FixedRestartDelayStrategy delay to 0s >

[GitHub] flink pull request #5839: [FLINK-9158][Distributed Coordination] Set default...

2018-04-11 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5839 [FLINK-9158][Distributed Coordination] Set default FixedRestartDelayStrategy delay to 0s. ## What is the purpose of the change Set default FixedRestartDelayStrategy delay to 0s.

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-11 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434861#comment-16434861 ] Sihua Zhou commented on FLINK-9158: --- Hi [~till.rohrmann] have you already work on this? Or I'd like to

[jira] [Created] (FLINK-9160) Make subclasses of RuntimeContext internal that should be internal

2018-04-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9160: --- Summary: Make subclasses of RuntimeContext internal that should be internal Key: FLINK-9160 URL: https://issues.apache.org/jira/browse/FLINK-9160 Project:

[jira] [Created] (FLINK-9159) Sanity check default timeout values

2018-04-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9159: Summary: Sanity check default timeout values Key: FLINK-9159 URL: https://issues.apache.org/jira/browse/FLINK-9159 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9158: Summary: Set default FixedRestartDelayStrategy delay to 0s Key: FLINK-9158 URL: https://issues.apache.org/jira/browse/FLINK-9158 Project: Flink Issue Type:

[jira] [Closed] (FLINK-8624) flink-mesos: The flink rest-api sometimes becomes unresponsive

2018-04-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8624. Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Could not reproduce the

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

2018-04-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8715: - Fix Version/s: (was: 1.5.1) (was: 1.6.0) 1.5.0 >

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

2018-04-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8715: - Fix Version/s: (was: 1.5.0) 1.5.1 1.6.0 > RocksDB does

[jira] [Updated] (FLINK-8981) End-to-end test: Kerberos security

2018-04-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8981: - Fix Version/s: 1.5.1 > End-to-end test: Kerberos security > -- >

[jira] [Updated] (FLINK-8978) End-to-end test: Job upgrade

2018-04-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8978: - Fix Version/s: (was: 1.5.0) 1.5.1 1.6.0 > End-to-end

[jira] [Updated] (FLINK-8981) End-to-end test: Kerberos security

2018-04-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8981: - Fix Version/s: (was: 1.5.0) 1.6.0 > End-to-end test: Kerberos security >

[jira] [Updated] (FLINK-8554) Upgrade AWS SDK

2018-04-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8554: -- Description: AWS SDK 1.11.271 fixes a lot of bugs. One of which would exhibit the following: {code} Caused

[jira] [Commented] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2018-04-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434788#comment-16434788 ] Ted Yu commented on FLINK-7775: --- lgtm > Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434772#comment-16434772 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-11 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r180938483 --- Diff: flink-end-to-end-tests/test-scripts/test_quickstarts.sh --- @@ -0,0 +1,117 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434619#comment-16434619 ] ASF GitHub Bot commented on FLINK-8556: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature to the...

2018-04-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5411 Hi @pduveau, sorry for the delay here. I've previously been busy with recent releases, and am currently traveling for Flink Forward. This PR is still on my backlog, will try to get back

[jira] [Commented] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434617#comment-16434617 ] ASF GitHub Bot commented on FLINK-9124: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5803: [FLINK-9124] [kinesis] Allow customization of Kine...

2018-04-11 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5803#discussion_r180909552 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@ -176,6

[jira] [Updated] (FLINK-9157) Support for commonly used external catalog

2018-04-11 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9157: - Summary: Support for commonly used external catalog (was: Create support for commonly used external

[jira] [Created] (FLINK-9157) Create support for commonly used external catalog

2018-04-11 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9157: Summary: Create support for commonly used external catalog Key: FLINK-9157 URL: https://issues.apache.org/jira/browse/FLINK-9157 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434117#comment-16434117 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-11 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r180810121 --- Diff: flink-end-to-end-tests/test-scripts/test_quickstarts.sh --- @@ -0,0 +1,117 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434074#comment-16434074 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test

2018-04-11 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5823 Fixing the CI build error... ---

[jira] [Commented] (FLINK-9087) Change the method signature of RecordWriter#broadcastEvent() from BufferConsumer to void

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433814#comment-16433814 ] ASF GitHub Bot commented on FLINK-9087: --- Github user zentol commented on the issue:

[GitHub] flink issue #5802: [FLINK-9087] [runtime] change the method signature of Rec...

2018-04-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5802 merging. ---

[jira] [Commented] (FLINK-9087) Change the method signature of RecordWriter#broadcastEvent() from BufferConsumer to void

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433787#comment-16433787 ] ASF GitHub Bot commented on FLINK-9087: --- Github user trionesadam commented on the issue:

[GitHub] flink issue #5802: [FLINK-9087] [runtime] change the method signature of Rec...

2018-04-11 Thread trionesadam
Github user trionesadam commented on the issue: https://github.com/apache/flink/pull/5802 @NicoK thanks a lot ---

[jira] [Commented] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433736#comment-16433736 ] ASF GitHub Bot commented on FLINK-9156: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5838: [FLINK-9156][REST][CLI] Update --jobmanager option...

2018-04-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5838 [FLINK-9156][REST][CLI] Update --jobmanager option logic for REST client ## What is the purpose of the change With this PR the `--jobmanager` option is properly respected by the

[jira] [Assigned] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9156: --- Assignee: Chesnay Schepler (was: Gary Yao) > CLI does not respect -m,--jobmanager option >

[jira] [Assigned] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9156: --- Assignee: Gary Yao (was: Chesnay Schepler) > CLI does not respect -m,--jobmanager option >

[jira] [Assigned] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9156: --- Assignee: Chesnay Schepler > CLI does not respect -m,--jobmanager option >

[jira] [Updated] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9156: Description: *Description* The CLI does not respect the {{-m, --jobmanager}} option. For example

[jira] [Commented] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433690#comment-16433690 ] mingleizhang commented on FLINK-9156: - Yes. We should make the CLI as the first choose, can not use

[jira] [Commented] (FLINK-9140) simplify scalastyle configurations

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433674#comment-16433674 ] ASF GitHub Bot commented on FLINK-9140: --- Github user zentol commented on the issue:

[GitHub] flink issue #5819: [FLINK-9140] [Build System] [scalastyle] simplify scalast...

2018-04-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5819 merging. ---

[GitHub] flink issue #5827: [hotfix][docs][minor] fix typo in documentation

2018-04-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5827 merging. ---

[jira] [Created] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9156: --- Summary: CLI does not respect -m,--jobmanager option Key: FLINK-9156 URL: https://issues.apache.org/jira/browse/FLINK-9156 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9156: Description: *Description* The CLI does not respect the {{-m, --jobmanager}} option. For example

[jira] [Commented] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433668#comment-16433668 ] ASF GitHub Bot commented on FLINK-9147: --- Github user zentol commented on the issue:

[GitHub] flink issue #5828: [FLINK-9147] [metrics] Include shaded Prometheus dependen...

2018-04-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5828 merging. ---

[jira] [Commented] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433667#comment-16433667 ] ASF GitHub Bot commented on FLINK-8426: --- Github user zentol commented on the issue:

[GitHub] flink issue #5837: [FLINK-8426][docs] Error in Generating Timestamp/Watermak...

2018-04-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5837 merging ---

[jira] [Commented] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433650#comment-16433650 ] ASF GitHub Bot commented on FLINK-8426: --- GitHub user mylog00 opened a pull request:

[GitHub] flink pull request #5837: [FLINK-8426][docs] Error in Generating Timestamp/W...

2018-04-11 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/5837 [FLINK-8426][docs] Error in Generating Timestamp/Watermakr doc [FLINK-8426][docs] fix java examples for "Generating Timestamp/Watermakr" documentation. You can merge this pull request into a

[jira] [Assigned] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

2018-04-11 Thread Dmitrii Kniazev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitrii Kniazev reassigned FLINK-8426: -- Assignee: Dmitrii Kniazev > Error in Generating Timestamp/Watermakr doc >

[jira] [Commented] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433602#comment-16433602 ] ASF GitHub Bot commented on FLINK-9141: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5836: [FLINK-9141][datastream] Fail early when using bot...

2018-04-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5836 [FLINK-9141][datastream] Fail early when using both split and side-outputs ## What is the purpose of the change With this PR we fail early if a user attempts to use split() and side-outputs

[jira] [Assigned] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

2018-04-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9141: --- Assignee: Chesnay Schepler > Calling getSideOutput() and split() on one DataStream

[jira] [Assigned] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

2018-04-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9141: --- Assignee: (was: vinoyang) > Calling getSideOutput() and split() on one DataStream causes NPE >

[jira] [Updated] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

2018-04-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9141: Description: Calling both {{getSideOutput()}} and {{split()}} on one DataStream causes a

[GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test

2018-04-11 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5823 This commit seems has an issue. not suitable to review now. I will fix it soon. ---

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433570#comment-16433570 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zhangminglei commented on the issue:

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

2018-04-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433525#comment-16433525 ] ASF GitHub Bot commented on FLINK-2435: --- GitHub user DmitryKober opened a pull request:

[GitHub] flink pull request #5835: [FLINK-2435] Extending CsvReader capabilities: it ...

2018-04-11 Thread DmitryKober
GitHub user DmitryKober opened a pull request: https://github.com/apache/flink/pull/5835 [FLINK-2435] Extending CsvReader capabilities: it is now possible to let user-defined classes be presented in csv fields. *Thank you very much for contributing to Apache Flink - we are happy