[jira] [Assigned] (FLINK-10929) Add support for Apache Arrow

2018-12-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10929: Assignee: (was: vinoyang) > Add support for Apache Arrow > > >

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

2018-12-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711081#comment-16711081 ] vinoyang commented on FLINK-9461: - [~twalthr] Some interfaces, such as StreamTableSinkFactory, are used

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711073#comment-16711073 ] ASF GitHub Bot commented on FLINK-11010: lzqdename edited a comment on issue #7180:

[GitHub] lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444762927 let me show how to generate the wrong result --- **background**: processing time

[GitHub] lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444762927 let me show how to generate the wrong result --- **background**: processing time

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711071#comment-16711071 ] ASF GitHub Bot commented on FLINK-11010: lzqdename edited a comment on issue #7180:

[jira] [Commented] (FLINK-8033) Build Flink with JDK 9

2018-12-05 Thread Takanobu Asanuma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711064#comment-16711064 ] Takanobu Asanuma commented on FLINK-8033: - FYI, Hadoop stopped fixing the incompatibilities of

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711063#comment-16711063 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken commented on issue #7180: [FLINK-11010]

[GitHub] lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444773602 @lzqdename, thanks for your detail description.

[jira] [Updated] (FLINK-11084) Incorrect ouput after two consecutive split and select

2018-12-05 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-11084: Summary: Incorrect ouput after two consecutive split and select (was: Incorrect ouput after two

[jira] [Commented] (FLINK-11084) Incorrect ouput after two successive split and select

2018-12-05 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711041#comment-16711041 ] Shimin Yang commented on FLINK-11084: - Currently I am creating a OutputSelectorWrapper to hold the

[jira] [Created] (FLINK-11084) Incorrect ouput after two successive split and select

2018-12-05 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-11084: --- Summary: Incorrect ouput after two successive split and select Key: FLINK-11084 URL: https://issues.apache.org/jira/browse/FLINK-11084 Project: Flink Issue

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711033#comment-16711033 ] ASF GitHub Bot commented on FLINK-11010: lzqdename edited a comment on issue #7180:

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711035#comment-16711035 ] ASF GitHub Bot commented on FLINK-11010: lzqdename edited a comment on issue #7180:

[GitHub] lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444762927 let me show how to generate the wrong result --- **background**: processing time

[GitHub] lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444762927 let me show how to generate the wrong result --- **background**: processing time

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711023#comment-16711023 ] ASF GitHub Bot commented on FLINK-11010: lzqdename commented on issue #7180: [FLINK-11010]

[GitHub] lzqdename commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444762927 let me show how to generate the wrong result --- **background**: processing time in

[jira] [Commented] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

2018-12-05 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711016#comment-16711016 ] boshu Zheng commented on FLINK-11083: - cc [~pnowojski] Could you please have a look? >

[jira] [Created] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

2018-12-05 Thread boshu Zheng (JIRA)
boshu Zheng created FLINK-11083: --- Summary: CRowSerializerConfigSnapshot is not instantiable Key: FLINK-11083 URL: https://issues.apache.org/jira/browse/FLINK-11083 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11048: --- Labels: pull-request-available (was: ) > Ability to programmatically execute streaming

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711005#comment-16711005 ] ASF GitHub Bot commented on FLINK-11048: tweise opened a new pull request #7249: [FLINK-11048]

[GitHub] tweise opened a new pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-05 Thread GitBox
tweise opened a new pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249 ## What is the purpose of the change Adds the ability to programmatically execute a job with savepoint

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710996#comment-16710996 ] ASF GitHub Bot commented on FLINK-11010: lzqdename removed a comment on issue #7180:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710998#comment-16710998 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on issue #6918:

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

2018-12-05 Thread GitBox
sunjincheng121 commented on issue #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#issuecomment-444757050 Thanks for the quickly update! @hequn8128 +1 to merged. Thanks, Jincheng

[GitHub] lzqdename removed a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename removed a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444723623 In flink, I think it is better to avoid timezone in calculation ,because the input is

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

2018-12-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-9555. -- Resolution: Fixed Fix Version/s: 1.7.1 1.8.0 Fixed in master: 

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710993#comment-16710993 ] ASF GitHub Bot commented on FLINK-9555: --- asfgit closed pull request #7121: [FLINK-9555]Support

[GitHub] asfgit closed pull request #7121: [FLINK-9555]Support table api in scala shell

2018-12-05 Thread GitBox
asfgit closed pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121 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 provenance: As this is a foreign

[GitHub] kisimple commented on issue #7192: [hotfix][test][streaming] Fix a test failure in Windows 7 environment.

2018-12-05 Thread GitBox
kisimple commented on issue #7192: [hotfix][test][streaming] Fix a test failure in Windows 7 environment. URL: https://github.com/apache/flink/pull/7192#issuecomment-444750934 cc @kl0u This is an automated message from the

[GitHub] kisimple commented on issue #7215: [hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowOperatorTest

2018-12-05 Thread GitBox
kisimple commented on issue #7215: [hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowOperatorTest URL: https://github.com/apache/flink/pull/7215#issuecomment-444750664 cc @kl0u This is an automated message

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710971#comment-16710971 ] ASF GitHub Bot commented on FLINK-10543: hequn8128 commented on issue #6918:

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

2018-12-05 Thread GitBox
hequn8128 commented on issue #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#issuecomment-444745171 @sunjincheng121 Thanks for your view. I have updated the pr according to your suggestions. Best,

[jira] [Commented] (FLINK-11082) Increase backlog only if it is available for consumption

2018-12-05 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710966#comment-16710966 ] zhijiang commented on FLINK-11082: -- [~pnowojski], what do you think of issue? > Increase backlog only

[GitHub] maqingxiang opened a new pull request #7248: [hotfix][tableApi] Fix the description information of intersect in tableApi docs

2018-12-05 Thread GitBox
maqingxiang opened a new pull request #7248: [hotfix][tableApi] Fix the description information of intersect in tableApi docs URL: https://github.com/apache/flink/pull/7248 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710963#comment-16710963 ] TisonKun commented on FLINK-10333: -- Hi [~StephanEwen] and [~till.rohrmann] With an offline discuss

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710960#comment-16710960 ] ASF GitHub Bot commented on FLINK-7208: --- walterddr commented on a change in pull request #7201:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710961#comment-16710961 ] ASF GitHub Bot commented on FLINK-7208: --- walterddr commented on a change in pull request #7201:

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

2018-12-05 Thread GitBox
walterddr 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_r239320583 ## File path:

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

2018-12-05 Thread GitBox
walterddr 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_r239320467 ## File path:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710946#comment-16710946 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710955#comment-16710955 ] ASF GitHub Bot commented on FLINK-10973: dianfu commented on issue #7167: [FLINK-10973] [table]

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

2018-12-05 Thread GitBox
dianfu commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-444737589 Hi @twalthr, any comments? That would be great if you can give some feedback on this ticket.

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710941#comment-16710941 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710947#comment-16710947 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710950#comment-16710950 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710940#comment-16710940 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710943#comment-16710943 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710949#comment-16710949 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710944#comment-16710944 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710945#comment-16710945 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710948#comment-16710948 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710942#comment-16710942 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

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

2018-12-05 Thread GitBox
dianfu 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_r239308521 ## File path:

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

2018-12-05 Thread GitBox
dianfu 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_r239308496 ## File path:

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

2018-12-05 Thread GitBox
dianfu 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_r239308474 ## File path:

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

2018-12-05 Thread GitBox
dianfu 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_r239302128 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

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

2018-12-05 Thread GitBox
dianfu 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_r239301814 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

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

2018-12-05 Thread GitBox
dianfu 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_r239318443 ## File path:

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

2018-12-05 Thread GitBox
dianfu 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_r239308968 ## File path:

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

2018-12-05 Thread GitBox
dianfu 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_r239302052 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

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

2018-12-05 Thread GitBox
dianfu 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_r239307495 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

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

2018-12-05 Thread GitBox
dianfu 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_r239307765 ## File path:

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

2018-12-05 Thread GitBox
dianfu 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_r239302508 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

[jira] [Created] (FLINK-11082) Increase backlog only if it is available for consumption

2018-12-05 Thread zhijiang (JIRA)
zhijiang created FLINK-11082: Summary: Increase backlog only if it is available for consumption Key: FLINK-11082 URL: https://issues.apache.org/jira/browse/FLINK-11082 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710927#comment-16710927 ] ASF GitHub Bot commented on FLINK-10941: QiLuo-BD commented on a change in pull request #7186:

[GitHub] QiLuo-BD commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

2018-12-05 Thread GitBox
QiLuo-BD commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#discussion_r239314973 ## File path:

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710920#comment-16710920 ] ASF GitHub Bot commented on FLINK-10941: QiLuo-BD commented on a change in pull request #7186:

[GitHub] QiLuo-BD commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

2018-12-05 Thread GitBox
QiLuo-BD commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#discussion_r239314285 ## File path:

[jira] [Commented] (FLINK-10560) JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn

2018-12-05 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710916#comment-16710916 ] Jiayi Liao commented on FLINK-10560: [~till.rohrmann] Thanks for pointing it out. It will be better

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710911#comment-16710911 ] ASF GitHub Bot commented on FLINK-10884: wg1026688210 commented on a change in pull request

[GitHub] wg1026688210 commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

2018-12-05 Thread GitBox
wg1026688210 commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185#discussion_r239310963 ## File path:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710906#comment-16710906 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on issue #7121:

[GitHub] sunjincheng121 commented on issue #7121: [FLINK-9555]Support table api in scala shell

2018-12-05 Thread GitBox
sunjincheng121 commented on issue #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#issuecomment-444726128 Thanks for the update! @shuiqiangchen Merging... This is an

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710899#comment-16710899 ] ASF GitHub Bot commented on FLINK-11010: lzqdename commented on issue #7180: [FLINK-11010]

[GitHub] lzqdename commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-05 Thread GitBox
lzqdename commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444723623 In flink, I think it is better to avoid timezone in calculation ,because the input is always UTC

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

2018-12-05 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710889#comment-16710889 ] Hequn Cheng commented on FLINK-11065: - [~twalthr] Hi, thanks for driving this. I think we would

[jira] [Assigned] (FLINK-10783) Update WindowOperatorMigrationTest for 1.7

2018-12-05 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10783: --- Assignee: boshu Zheng (was: vinoyang) > Update WindowOperatorMigrationTest for 1.7 >

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

2018-12-05 Thread Tony Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710884#comment-16710884 ] Tony Xintong Song commented on FLINK-10640: --- Hi [~Tison], what you proposed is exactly what

[jira] [Assigned] (FLINK-11081) Support binding port range for REST server

2018-12-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11081: Assignee: vinoyang > Support binding port range for REST server >

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710867#comment-16710867 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710866#comment-16710866 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710868#comment-16710868 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread GitBox
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_r239298808 ## File path:

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

2018-12-05 Thread GitBox
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_r239301372 ## File path:

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

2018-12-05 Thread GitBox
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_r239300038 ## File path:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710822#comment-16710822 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710830#comment-16710830 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710824#comment-16710824 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710828#comment-16710828 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710823#comment-16710823 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710831#comment-16710831 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710825#comment-16710825 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710821#comment-16710821 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread GitBox
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_r239271885 ## File path:

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

2018-12-05 Thread GitBox
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_r239285343 ## File path:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710827#comment-16710827 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710829#comment-16710829 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710826#comment-16710826 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on a change in pull request

  1   2   3   >