[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205524700 ## File path:

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205526999 ## File path:

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205525970 ## File path:

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205523208 ## File path: docs/dev/table/sql.md ## @@ -1848,6 +1848,17 @@ FROM_BASE64(text string)

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205524074 ## File path: docs/dev/table/tableApi.md ## @@ -2474,17 +2474,30 @@ STRING.rpad(len INT, pad

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205526614 ## File path:

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205522776 ## File path: docs/dev/table/tableApi.md ## @@ -2474,17 +2474,30 @@ STRING.rpad(len INT, pad

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205522289 ## File path: docs/dev/table/tableApi.md ## @@ -2474,17 +2474,30 @@ STRING.rpad(len INT, pad

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205522908 ## File path: docs/dev/table/sql.md ## @@ -1848,6 +1848,17 @@ FROM_BASE64(text string)

[GitHub] yanghua commented on issue #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

yanghua commented on issue #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#issuecomment-408169883 @xccui thanks for your suggestion, fixed them~ This is an

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558698#comment-16558698 ] ASF GitHub Bot commented on FLINK-9897: --- tweise commented on a change in pull request #6408:

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205572919 ## File path:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558791#comment-16558791 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[jira] [Commented] (FLINK-9959) JoinFunction should be able to access its Window

[ https://issues.apache.org/jira/browse/FLINK-9959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558899#comment-16558899 ] Bowen Li commented on FLINK-9959: - [~aljoscha] what do you think of this change? > JoinFunction should

[GitHub] fhueske commented on issue #6423: [FLINK-9935] [table] Fix incorrect group field access in batch window combiner.

fhueske commented on issue #6423: [FLINK-9935] [table] Fix incorrect group field access in batch window combiner. URL: https://github.com/apache/flink/pull/6423#issuecomment-408155116 Merged This is an automated message from

[jira] [Closed] (FLINK-9935) Batch Table API: grouping by window and attribute causes java.lang.ClassCastException:

[ https://issues.apache.org/jira/browse/FLINK-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9935. Resolution: Fixed Fix Version/s: 1.7.0 1.6.0 1.5.3

[jira] [Commented] (FLINK-9935) Batch Table API: grouping by window and attribute causes java.lang.ClassCastException:

[ https://issues.apache.org/jira/browse/FLINK-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558520#comment-16558520 ] ASF GitHub Bot commented on FLINK-9935: --- fhueske closed pull request #6423: [FLINK-9935] [table]

[jira] [Commented] (FLINK-9935) Batch Table API: grouping by window and attribute causes java.lang.ClassCastException:

[ https://issues.apache.org/jira/browse/FLINK-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558519#comment-16558519 ] ASF GitHub Bot commented on FLINK-9935: --- fhueske commented on issue #6423: [FLINK-9935] [table] Fix

[GitHub] fhueske closed pull request #6423: [FLINK-9935] [table] Fix incorrect group field access in batch window combiner.

fhueske closed pull request #6423: [FLINK-9935] [table] Fix incorrect group field access in batch window combiner. URL: https://github.com/apache/flink/pull/6423 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] yanghua commented on issue #6432: [FLINK-9970] Add ASCII function for table/sql API

yanghua commented on issue #6432: [FLINK-9970] Add ASCII function for table/sql API URL: https://github.com/apache/flink/pull/6432#issuecomment-408164654 @twalthr Really sorry about my careless. For this PR, I just want to push as soon as possible, because it is mid-night in China, so did

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205572300 ## File path:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558793#comment-16558793 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558825#comment-16558825 ] Nico Kruber commented on FLINK-8523: Sorry for coming back so late, but we recently discovered that

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558579#comment-16558579 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558587#comment-16558587 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558584#comment-16558584 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558582#comment-16558582 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558581#comment-16558581 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558585#comment-16558585 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558586#comment-16558586 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558580#comment-16558580 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205524441 ## File path:

[GitHub] xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on a change in pull request #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#discussion_r205525765 ## File path:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558588#comment-16558588 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558583#comment-16558583 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558589#comment-16558589 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on a change in pull request #6390:

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558631#comment-16558631 ] ASF GitHub Bot commented on FLINK-9915: --- yanghua commented on issue #6390: [FLINK-9915] Add

[jira] [Created] (FLINK-9976) Odd signatures for streaming file sink format builders

Chesnay Schepler created FLINK-9976: --- Summary: Odd signatures for streaming file sink format builders Key: FLINK-9976 URL: https://issues.apache.org/jira/browse/FLINK-9976 Project: Flink

[jira] [Updated] (FLINK-9946) Quickstart E2E test archetype version is hard-coded

[ https://issues.apache.org/jira/browse/FLINK-9946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9946: -- Labels: pull-request-available (was: ) > Quickstart E2E test archetype version is hard-coded

[jira] [Commented] (FLINK-9946) Quickstart E2E test archetype version is hard-coded

[ https://issues.apache.org/jira/browse/FLINK-9946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558875#comment-16558875 ] ASF GitHub Bot commented on FLINK-9946: --- zentol opened a new pull request #6433:

[GitHub] zentol opened a new pull request #6433: [FLINK-9946][tests] Expose Flink version to E2E tests

zentol opened a new pull request #6433: [FLINK-9946][tests] Expose Flink version to E2E tests URL: https://github.com/apache/flink/pull/6433 ## What is the purpose of the change With this PR the flink version is determined from the `flink-end-to-end-tests` pom and exposed to test

[jira] [Commented] (FLINK-9970) Add ASCII function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558605#comment-16558605 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on issue #6432: [FLINK-9970] Add ASCII

[jira] [Assigned] (FLINK-9976) Odd signatures for streaming file sink format builders

[ https://issues.apache.org/jira/browse/FLINK-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9976: --- Assignee: Chesnay Schepler > Odd signatures for streaming file sink format builders

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558814#comment-16558814 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558810#comment-16558810 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558811#comment-16558811 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558813#comment-16558813 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558812#comment-16558812 ] ASF GitHub Bot commented on FLINK-8523: --- NicoK commented on a change in pull request #5381:

[GitHub] tweise commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

tweise commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#discussion_r205551265 ## File path:

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205576747 ## File path:

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205575969 ## File path:

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205579424 ## File path:

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205577375 ## File path:

[GitHub] NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode

NicoK commented on a change in pull request #5381: [FLINK-8523][network] Stop assigning floating buffers for blocked input channels in exactly-once mode URL: https://github.com/apache/flink/pull/5381#discussion_r205575797 ## File path:

[jira] [Closed] (FLINK-8873) move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest

[ https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-8873. --- Resolution: Won't Fix > move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest >

[jira] [Commented] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

[ https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559128#comment-16559128 ] zhangminglei commented on FLINK-9651: - Hi, [~twalthr] Thanks and I am on my way to do this. > Add a

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559142#comment-16559142 ] ASF GitHub Bot commented on FLINK-9915: --- xccui commented on issue #6390: [FLINK-9915] Add TO_BASE64

[GitHub] yanghua commented on issue #6336: [FLINK-9630] [connector] Kafka09PartitionDiscoverer cause connection …

yanghua commented on issue #6336: [FLINK-9630] [connector] Kafka09PartitionDiscoverer cause connection … URL: https://github.com/apache/flink/pull/6336#issuecomment-408288375 hi @ubyyj Till and Chesnay are busy releasing Flink 1.6 and 1.5.2, just wait~

[jira] [Updated] (FLINK-8994) Add a test operator with keyed state that uses Avro serializer (from schema/by reflection)

[ https://issues.apache.org/jira/browse/FLINK-8994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8994: -- Labels: pull-request-available (was: ) > Add a test operator with keyed state that uses Avro

[GitHub] tzulitai opened a new pull request #6435: [FLINK-8994] [tests] Let general purpose DataStream jobs use Avro as state

tzulitai opened a new pull request #6435: [FLINK-8994] [tests] Let general purpose DataStream jobs use Avro as state URL: https://github.com/apache/flink/pull/6435 ## What is the purpose of the change This improves the coverage of our general purpose DataStream job by having Avro

[jira] [Commented] (FLINK-8994) Add a test operator with keyed state that uses Avro serializer (from schema/by reflection)

[ https://issues.apache.org/jira/browse/FLINK-8994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559299#comment-16559299 ] ASF GitHub Bot commented on FLINK-8994: --- tzulitai opened a new pull request #6435: [FLINK-8994]

[jira] [Commented] (FLINK-9970) Add ASCII function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559100#comment-16559100 ] ASF GitHub Bot commented on FLINK-9970: --- TisonKun commented on a change in pull request #6432:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559159#comment-16559159 ] ASF GitHub Bot commented on FLINK-6968: --- liurenjie1024 commented on issue #5688: [FLINK-6968][Table

[jira] [Commented] (FLINK-9825) Upgrade checkstyle version to 8.6

[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559160#comment-16559160 ] zhangminglei commented on FLINK-9825: - Hi, [~Zentol] Could you please give [~lsy] a permission that

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r205674745 ## File path:

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559302#comment-16559302 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull request #6391:

[jira] [Updated] (FLINK-8535) Implement a basic set of table factories

[ https://issues.apache.org/jira/browse/FLINK-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8535: Summary: Implement a basic set of table factories (was: Implement a basic set of table source

[jira] [Created] (FLINK-9964) Add a CSV table format factory

Timo Walther created FLINK-9964: --- Summary: Add a CSV table format factory Key: FLINK-9964 URL: https://issues.apache.org/jira/browse/FLINK-9964 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9965) Support schema derivation in Avro table format factory

Timo Walther created FLINK-9965: --- Summary: Support schema derivation in Avro table format factory Key: FLINK-9965 URL: https://issues.apache.org/jira/browse/FLINK-9965 Project: Flink Issue

[GitHub] yanghua commented on issue #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

yanghua commented on issue #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#issuecomment-407987453 @xccui can you review `TO_BASE64` function? This is an automated

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556949#comment-16556949 ] ASF GitHub Bot commented on FLINK-9915: --- yanghua commented on issue #6390: [FLINK-9915] Add

[jira] [Commented] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16557994#comment-16557994 ] Stefan Richter commented on FLINK-9945: --- The exception does not show the root cause why the

[jira] [Commented] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

[ https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558000#comment-16558000 ] Timo Walther commented on FLINK-9651: - Hi [~mingleizhang], FLINK-8558 has been merged. Now would be

[jira] [Created] (FLINK-9961) Add CHR function for table/sql API

vinoyang created FLINK-9961: --- Summary: Add CHR function for table/sql API Key: FLINK-9961 URL: https://issues.apache.org/jira/browse/FLINK-9961 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-8535) Implement a basic set of table factories

[ https://issues.apache.org/jira/browse/FLINK-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8535: Description: A lot of work went into creating unified interfaces for source, sinks, formats.

[jira] [Created] (FLINK-9963) Create a string table format factory

Timo Walther created FLINK-9963: --- Summary: Create a string table format factory Key: FLINK-9963 URL: https://issues.apache.org/jira/browse/FLINK-9963 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-9963) Add a string table format factory

[ https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9963: Summary: Add a string table format factory (was: Create a string table format factory) > Add a

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558024#comment-16558024 ] ASF GitHub Bot commented on FLINK-9413: --- zhijiangW commented on issue #6103: [FLINK-9413]

[GitHub] zhijiangW commented on issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail with Partition…

zhijiangW commented on issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail with Partition… URL: https://github.com/apache/flink/pull/6103#issuecomment-408008057 This exception is also ever caused in our large-scale applications, and we increase the

[jira] [Created] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

Bowen Li created FLINK-9962: --- Summary: allow users to specify TimeZone in DateTimeBucketer Key: FLINK-9962 URL: https://issues.apache.org/jira/browse/FLINK-9962 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558900#comment-16558900 ] Bowen Li commented on FLINK-9962: - [~fhue...@gmail.com] what do you think of this change? > allow users

[jira] [Updated] (FLINK-9825) Upgrade checkstyle version to 8.6

[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9825: -- Component/s: Build System > Upgrade checkstyle version to 8.6 > - > >

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559076#comment-16559076 ] ASF GitHub Bot commented on FLINK-9630: --- ubyyj commented on issue #6336: [FLINK-9630] [connector]

[jira] [Comment Edited] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints

[ https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556325#comment-16556325 ] Steven Zhen Wu edited comment on FLINK-9693 at 7/27/18 12:57 AM: - We can

[GitHub] TisonKun commented on a change in pull request #6432: [FLINK-9970] Add ASCII function for table/sql API

TisonKun commented on a change in pull request #6432: [FLINK-9970] Add ASCII function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r205643221 ## File path:

[GitHub] TisonKun commented on a change in pull request #6432: [FLINK-9970] Add ASCII function for table/sql API

TisonKun commented on a change in pull request #6432: [FLINK-9970] Add ASCII function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r205643221 ## File path:

[jira] [Commented] (FLINK-9970) Add ASCII function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559098#comment-16559098 ] ASF GitHub Bot commented on FLINK-9970: --- TisonKun commented on a change in pull request #6432:

[GitHub] xccui commented on issue #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API

xccui commented on issue #6390: [FLINK-9915] Add TO_BASE64 function for table/sql API URL: https://github.com/apache/flink/pull/6390#issuecomment-408287972 @twalthr, please take a look. Thanks. This is an automated message

[jira] [Created] (FLINK-9977) Refine the docs for Table/SQL built-in functions

Xingcan Cui created FLINK-9977: -- Summary: Refine the docs for Table/SQL built-in functions Key: FLINK-9977 URL: https://issues.apache.org/jira/browse/FLINK-9977 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9967) Snapshot release branches aren't deployed

[ https://issues.apache.org/jira/browse/FLINK-9967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559033#comment-16559033 ] Thomas Weise commented on FLINK-9967: - Good this is fixed. We saw strange build errors with

[jira] [Closed] (FLINK-7470) Acquire RM leadership before registering with Mesos

[ https://issues.apache.org/jira/browse/FLINK-7470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-7470. - Resolution: Duplicate > Acquire RM leadership before registering with Mesos >

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559146#comment-16559146 ] ASF GitHub Bot commented on FLINK-9630: --- yanghua commented on issue #6336: [FLINK-9630] [connector]

[jira] [Assigned] (FLINK-9825) Upgrade checkstyle version to 8.6

[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-9825: --- Assignee: (was: zhangminglei) > Upgrade checkstyle version to 8.6 >

[GitHub] liurenjie1024 commented on issue #5688: [FLINK-6968][Table API & SQL] Add Queryable table sink.

liurenjie1024 commented on issue #5688: [FLINK-6968][Table API & SQL] Add Queryable table sink. URL: https://github.com/apache/flink/pull/5688#issuecomment-408291783 I'm sorry for messing this up with a wrong rebase. I've opened a cleaner PR https://github.com/apache/flink/pull/6434 for

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559155#comment-16559155 ] ASF GitHub Bot commented on FLINK-6968: --- liurenjie1024 opened a new pull request #6434:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559156#comment-16559156 ] ASF GitHub Bot commented on FLINK-6968: --- liurenjie1024 commented on issue #6434: [FLINK-6968][Table

[GitHub] liurenjie1024 opened a new pull request #6434: [FLINK-6968][Table API & SQL] Add Queryable table sink.

liurenjie1024 opened a new pull request #6434: [FLINK-6968][Table API & SQL] Add Queryable table sink. URL: https://github.com/apache/flink/pull/6434 ## What is the purpose of the change Streaming tables with unique key are continuously updated. For example queries with a

[jira] [Updated] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6968: -- Labels: pull-request-available (was: ) > Store streaming, updating tables with unique key in

[jira] [Commented] (FLINK-8354) Flink Kafka connector ignores Kafka message headers

[ https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559157#comment-16559157 ] Alexey Trenikhin commented on FLINK-8354: - In our case we are using Headers to propagate avro 

[GitHub] liurenjie1024 commented on issue #6434: [FLINK-6968][Table API & SQL] Add Queryable table sink.

liurenjie1024 commented on issue #6434: [FLINK-6968][Table API & SQL] Add Queryable table sink. URL: https://github.com/apache/flink/pull/6434#issuecomment-408291551 I'm sorry for messing up https://github.com/apache/flink/pull/5688 with a wrong rebase and opened this new PR.

  1   2   3   >