[jira] [Resolved] (FLINK-11047) CoGroupGroupSortTranslationTest does not compile with scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-11047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11047. --- Resolution: Fixed Fix Version/s: 1.7.1 Fixed via 1.8.0: https://github.com/apache/fl

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11050: Fix Version/s: (was: 1.7.1) > When IntervalJoin, get left or right buffer's entries more quickly by > assigni

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708337#comment-16708337 ] Tzu-Li (Gordon) Tai commented on FLINK-11046: - Hi [~luoguohao], So, to clar

[GitHub] tillrohrmann closed pull request #7218: [BP-1.7][FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types

tillrohrmann closed pull request #7218: [BP-1.7][FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types URL: https://github.com/apache/flink/pull/7218 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Commented] (FLINK-11047) CoGroupGroupSortTranslationTest does not compile with scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-11047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708322#comment-16708322 ] ASF GitHub Bot commented on FLINK-11047: tillrohrmann closed pull request #7217:

[GitHub] tillrohrmann closed pull request #7217: [FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types

tillrohrmann closed pull request #7217: [FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types URL: https://github.com/apache/flink/pull/7217 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of prove

[jira] [Commented] (FLINK-11041) ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708320#comment-16708320 ] Till Rohrmann commented on FLINK-11041: --- Another instance: https://api.travis-ci.o

[jira] [Updated] (FLINK-10977) Add FlatAggregate operator to unbounded streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-10977: Summary: Add FlatAggregate operator to unbounded streaming Table API (was: Add UnBounded FlatAggr

[jira] [Updated] (FLINK-10978) Add FlatAggregate operator to batch Table API

[ https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-10978: Summary: Add FlatAggregate operator to batch Table API (was: Add UnBounded FlatAggregate operator

[jira] [Closed] (FLINK-6325) Refinement of slot reuse for task manager failure

[ https://issues.apache.org/jira/browse/FLINK-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-6325. --- Resolution: Duplicate > Refinement of slot reuse for task manager failure > -

[jira] [Closed] (FLINK-5138) Add the method in state backend to estimate memory by hint of state size in ResourceSpec

[ https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-5138. --- Resolution: Workaround > Add the method in state backend to estimate memory by hint of state size in > Resou

[jira] [Commented] (FLINK-6325) Refinement of slot reuse for task manager failure

[ https://issues.apache.org/jira/browse/FLINK-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708266#comment-16708266 ] zhijiang commented on FLINK-6325: - already done in FLINK-9635, close it > Refinement of

[jira] [Created] (FLINK-11060) Unable to set number of task manager and slot per task number in scala shell local mode

Jeff Zhang created FLINK-11060: -- Summary: Unable to set number of task manager and slot per task number in scala shell local mode Key: FLINK-11060 URL: https://issues.apache.org/jira/browse/FLINK-11060 P

[jira] [Assigned] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-11060: -- Assignee: Jeff Zhang > Unable to set number of task manager and slot per task manager in scal

[jira] [Updated] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11060: --- Description: In scala-shell, I can not change the number of task manager and slot per task manager,

[jira] [Updated] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11060: --- Summary: Unable to set number of task manager and slot per task manager in scala shell local mode (

[jira] [Updated] (FLINK-11060) Unable to set number of task manager and slot per task number in scala shell local mode

[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11060: --- Description: In scala-shell, I can not change the number of task manager and slot per task number >

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708229#comment-16708229 ] ASF GitHub Bot commented on FLINK-10543: hequn8128 commented on issue #6918: [FL

[GitHub] hequn8128 commented on issue #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

hequn8128 commented on issue #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#issuecomment-443980126 @sunjincheng121 Thanks a lot for your review and suggestions. I have addressed your comments and rebased

[GitHub] XuQianJin-Stars opened a new pull request #7228: [FLINK-9740][Table API &SQL] Support group windows over intervals of months

XuQianJin-Stars opened a new pull request #7228: [FLINK-9740][Table API &SQL] Support group windows over intervals of months URL: https://github.com/apache/flink/pull/7228 ## What is the purpose of the change *(*This PR is designed to solve the problem of Support group windows over

[jira] [Updated] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9740: -- Labels: pull-request-available (was: ) > Support group windows over intervals of months > ---

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708191#comment-16708191 ] ASF GitHub Bot commented on FLINK-9740: --- XuQianJin-Stars opened a new pull request

[jira] [Commented] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout

[ https://issues.apache.org/jira/browse/FLINK-11059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708190#comment-16708190 ] ASF GitHub Bot commented on FLINK-11059: shuai-xu opened a new pull request #722

[jira] [Updated] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout

[ https://issues.apache.org/jira/browse/FLINK-11059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11059: --- Labels: pull-request-available (was: ) > JobMaster may continue using an invalid slot if re

[GitHub] shuai-xu opened a new pull request #7227: [FLINK-11059] [runtime] do not add releasing failed slot to free slots

shuai-xu opened a new pull request #7227: [FLINK-11059] [runtime] do not add releasing failed slot to free slots URL: https://github.com/apache/flink/pull/7227 ## What is the purpose of the change *This pr fix the bug that job master add back the slot when releasing to task exec

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708168#comment-16708168 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on issue #7201: [FLINK-72

[GitHub] dianfu commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#issuecomment-443967089 @sunjincheng121 @walterddr Got your points and make sense to me. Have updated the PR to address your comments.

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708157#comment-16708157 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on issue #7196: [FLINK

[GitHub] dianfu commented on issue #7196: [FLINK-10974] [table] Add support for flatMap to table API

dianfu commented on issue #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#issuecomment-443962507 @sunjincheng121 Thanks a lot for the review. Have updated the PR accordingly. --

[jira] [Commented] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708154#comment-16708154 ] ASF GitHub Bot commented on FLINK-11050: Myracle opened a new pull request #7226

[jira] [Created] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout

shuai.xu created FLINK-11059: Summary: JobMaster may continue using an invalid slot if releasing idle slot meet a timeout Key: FLINK-11059 URL: https://issues.apache.org/jira/browse/FLINK-11059 Project: F

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11050: --- Labels: performance pull-request-available (was: performance) > When IntervalJoin, get left

[GitHub] Myracle opened a new pull request #7226: FLINK-11050 add lowerBound and upperBound for optimizing RocksDBMapState's entries

Myracle opened a new pull request #7226: FLINK-11050 add lowerBound and upperBound for optimizing RocksDBMapState's entries URL: https://github.com/apache/flink/pull/7226 **(The sections below can be removed for hotfixes of typos)** --> ## What is the purpose of the change

[jira] [Created] (FLINK-11058) FlinkKafkaProducer011 fails when kafka broker crash

cz created FLINK-11058: -- Summary: FlinkKafkaProducer011 fails when kafka broker crash Key: FLINK-11058 URL: https://issues.apache.org/jira/browse/FLINK-11058 Project: Flink Issue Type: Bug Com

[jira] [Updated] (FLINK-6065) Make TransportClient for ES5 pluggable

[ https://issues.apache.org/jira/browse/FLINK-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6065: -- Labels: pull-request-available (was: ) > Make TransportClient for ES5 pluggable >

[jira] [Commented] (FLINK-6065) Make TransportClient for ES5 pluggable

[ https://issues.apache.org/jira/browse/FLINK-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708147#comment-16708147 ] ASF GitHub Bot commented on FLINK-6065: --- hzyuemeng1 commented on issue #3934: [FLIN

[GitHub] hzyuemeng1 commented on issue #3934: [FLINK-6065] Add initClient method to ElasticsearchApiCallBridge

hzyuemeng1 commented on issue #3934: [FLINK-6065] Add initClient method to ElasticsearchApiCallBridge URL: https://github.com/apache/flink/pull/3934#issuecomment-443957496 @tzulitai ,is anyone still work for this issue. If not, can I do this job -

[jira] [Updated] (FLINK-11057) where in grammar will cause stream inner join loigcal

[ https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-11057: Description: {code:java} select action , count ( * ) as cnt from user_action where action in ( 'view' , '

[jira] [Updated] (FLINK-11057) where in grammar will cause stream inner join loigcal

[ https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-11057: Description: {code:java} select action , count ( * ) as cnt from user_action where action in ( 'view' , '

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708131#comment-16708131 ] ASF GitHub Bot commented on FLINK-10543: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

hequn8128 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238516661 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table

[jira] [Commented] (FLINK-10640) Enable Slot Resource Profile for Resource Management

[ https://issues.apache.org/jira/browse/FLINK-10640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708124#comment-16708124 ] Tony Xintong Song commented on FLINK-10640: --- Hi [~Tison], it's a good question

[jira] [Created] (FLINK-11057) where in grammar will cause stream inner join loigcal

yuemeng created FLINK-11057: --- Summary: where in grammar will cause stream inner join loigcal Key: FLINK-11057 URL: https://issues.apache.org/jira/browse/FLINK-11057 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-11056) Remove MesosApplicationMasterRunner

[ https://issues.apache.org/jira/browse/FLINK-11056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11056: --- Labels: pull-request-available (was: ) > Remove MesosApplicationMasterRunner >

[jira] [Commented] (FLINK-11056) Remove MesosApplicationMasterRunner

[ https://issues.apache.org/jira/browse/FLINK-11056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708120#comment-16708120 ] ASF GitHub Bot commented on FLINK-11056: TisonKun opened a new pull request #722

[GitHub] TisonKun opened a new pull request #7225: [FLINK-11056] [mesos] Remove MesosApplicationMasterRunner

TisonKun opened a new pull request #7225: [FLINK-11056] [mesos] Remove MesosApplicationMasterRunner URL: https://github.com/apache/flink/pull/7225 ## What is the purpose of the change `MesosApplicationMasterRunner` is for legacy mode and none depend on it now, so that we can do a di

[jira] [Created] (FLINK-11056) Remove MesosApplicationMasterRunner

TisonKun created FLINK-11056: Summary: Remove MesosApplicationMasterRunner Key: FLINK-11056 URL: https://issues.apache.org/jira/browse/FLINK-11056 Project: Flink Issue Type: Sub-task Co

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708108#comment-16708108 ] ASF GitHub Bot commented on FLINK-10543: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

hequn8128 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238513035 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708106#comment-16708106 ] ASF GitHub Bot commented on FLINK-10543: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

hequn8128 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238512298 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table

[jira] [Commented] (FLINK-11020) Reorder joins only to eliminate cross joins

[ https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708095#comment-16708095 ] Hequn Cheng commented on FLINK-11020: - Hi [~fhueske] [~twalthr] Yes, I agree that we

[GitHub] yanghua commented on issue #5641: [WIP] Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization

yanghua commented on issue #5641: [WIP] Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization URL: https://github.com/apache/flink/pull/5641#issuecomment-443944337 @sihuazhou OK, I think the community is very interested in this feature. I

[jira] [Assigned] (FLINK-8601) Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization

[ https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8601: --- Assignee: Sihua Zhou (was: vinoyang) > Introduce ElasticBloomFilter for Approximate calculation and

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708090#comment-16708090 ] ASF GitHub Bot commented on FLINK-6756: --- Clark commented on issue #7168: [FLINK

[GitHub] sihuazhou commented on issue #5641: [WIP] Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization

sihuazhou commented on issue #5641: [WIP] Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization URL: https://github.com/apache/flink/pull/5641#issuecomment-443943556 Hi @yanghua , thanks for having a look at this PR. I'm too busy recently,

[GitHub] Clarkkkkk commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

Clark commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#issuecomment-443943474 cc @dawidwys, changes in RichAsyncFunction has been reverted. Thank you for your review. ---

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708067#comment-16708067 ] ASF GitHub Bot commented on FLINK-7208: --- sunjincheng121 commented on a change in pu

[GitHub] sunjincheng121 commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

sunjincheng121 commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238504541 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table

[jira] [Commented] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707991#comment-16707991 ] ASF GitHub Bot commented on FLINK-11045: sunjincheng121 commented on issue #7213

[GitHub] sunjincheng121 commented on issue #7213: [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor

sunjincheng121 commented on issue #7213: [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor URL: https://github.com/apache/flink/pull/7213#issuecomment-443914687 Hi @hequn8128 Thanks for the good catch! The change looks good to me! +1 to

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707980#comment-16707980 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707981#comment-16707981 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707978#comment-16707978 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707979#comment-16707979 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r238479911 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scal

[GitHub] sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r238478347 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scal

[GitHub] sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r238476606 ## File path: docs/dev/table/tableApi.md ## @@ -1682,6 +1682,60 @@ The `OverWindow` d

[GitHub] sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r238476414 ## File path: docs/dev/table/tableApi.md ## @@ -1682,6 +1682,60 @@ The `OverWindow` d

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707964#comment-16707964 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on a change in pu

[GitHub] sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r238475160 ## File path: flink-scala-shell/start-script/start-scala-shell.sh ## @@ -52,6 +52,13 @@ bin=`cd "$b

[GitHub] sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r238474488 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ##

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707961#comment-16707961 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on a change in pu

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707941#comment-16707941 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10973) Add Map operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707950#comment-16707950 ] ASF GitHub Bot commented on FLINK-10973: sunjincheng121 commented on issue #7167

[GitHub] sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API

sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-443904942 Hi @twalthr, Are there some comments about this PR? I appreciate if you can give some feedback :) Bests, Jincheng

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707945#comment-16707945 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707944#comment-16707944 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707946#comment-16707946 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707940#comment-16707940 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707947#comment-16707947 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707943#comment-16707943 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707942#comment-16707942 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238471156 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238469295 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238464306 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238471559 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238456197 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238465825 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238471367 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238470724 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707845#comment-16707845 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707846#comment-16707846 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707851#comment-16707851 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707841#comment-16707841 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707849#comment-16707849 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r238438000 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchem

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r238341448 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchem

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r238440527 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchem

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707840#comment-16707840 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

  1   2   3   4   >