[jira] [Commented] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515386#comment-16515386 ] Shuyi Chen commented on FLINK-9606: --- I think this is duplicate of [FLINK-2169|https://

[jira] [Updated] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers

2018-06-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9608: --- Issue Type: Sub-task (was: Test) Parent: FLINK-9376 > Add test base for Type

[jira] [Created] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers

2018-06-17 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9608: -- Summary: Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers Key: FLINK-9608 URL: https://issues.apache.org/jira/br

[GitHub] flink pull request #6177: Backport of Kinesis connector changes from 1.5 to ...

2018-06-17 Thread tweise
GitHub user tweise opened a pull request: https://github.com/apache/flink/pull/6177 Backport of Kinesis connector changes from 1.5 to release-1.4 Backport of Kinesis connector changes from 1.5 release to 1.4. R: @tzulitai @tillrohrmann You can merge this pull request into

[jira] [Commented] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse

2018-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515087#comment-16515087 ] ASF GitHub Bot commented on FLINK-9580: --- Github user yanghua commented on the issue

[GitHub] flink issue #6166: [FLINK-9580] Potentially unclosed ByteBufInputStream in R...

2018-06-17 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6166 cc @pnowojski ---

[jira] [Assigned] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9603: --- Assignee: (was: vinoyang) > Incorrect indexing of part files, when part suffix is specified > (

[jira] [Commented] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515084#comment-16515084 ] Rinat Sharipov commented on FLINK-9603: --- I've created a PR, that fixes this problem

[jira] [Commented] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515083#comment-16515083 ] ASF GitHub Bot commented on FLINK-9603: --- GitHub user kent2171 opened a pull request

[GitHub] flink pull request #6176: [FLINK-9603][connector-filesystem] fix part indexi...

2018-06-17 Thread kent2171
GitHub user kent2171 opened a pull request: https://github.com/apache/flink/pull/6176 [FLINK-9603][connector-filesystem] fix part indexing, when part suffix is specified This pull-request fixes problem of incorrect part file index lookup, when part suffix is specified. Part fil

[jira] [Updated] (FLINK-9604) Support KafkaProtoBufTableSource

2018-06-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-9604: Description: Protocol buffers are a language-neutral, platform-neutral extensible mechanism for se

[jira] [Commented] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515072#comment-16515072 ] Rinat Sharipov commented on FLINK-9603: --- Hi mates, I got the following proposal abo

[jira] [Assigned] (FLINK-9607) Support ParquetTableSink

2018-06-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9607: --- Assignee: (was: mingleizhang) > Support ParquetTableSink > > >

[jira] [Updated] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-9606: Component/s: Table API & SQL > Support ParquetTableSource > -- > >

[jira] [Assigned] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9606: --- Assignee: (was: mingleizhang) > Support ParquetTableSource > --

[jira] [Created] (FLINK-9607) Support ParquetTableSink

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9607: --- Summary: Support ParquetTableSink Key: FLINK-9607 URL: https://issues.apache.org/jira/browse/FLINK-9607 Project: Flink Issue Type: New Feature Repo

[jira] [Created] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9606: --- Summary: Support ParquetTableSource Key: FLINK-9606 URL: https://issues.apache.org/jira/browse/FLINK-9606 Project: Flink Issue Type: New Feature Re

[jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9605: --- Summary: Support KafkaProtoBufTableSink Key: FLINK-9605 URL: https://issues.apache.org/jira/browse/FLINK-9605 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9604: --- Summary: Support KafkaProtoBufTableSource Key: FLINK-9604 URL: https://issues.apache.org/jira/browse/FLINK-9604 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

2018-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515032#comment-16515032 ] ASF GitHub Bot commented on FLINK-9328: --- Github user Myasuka commented on the issue

[GitHub] flink issue #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore probl...

2018-06-17 Thread Myasuka
Github user Myasuka commented on the issue: https://github.com/apache/flink/pull/5984 Sorry for the late reply, @tzulitai I have already rebased on the latest master now. ---

[jira] [Commented] (FLINK-9567) Flink does not release resource in Yarn Cluster mode

2018-06-17 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515018#comment-16515018 ] Shimin Yang commented on FLINK-9567: I think I can fix the issue but I cannot assign