[GitHub] [flink] maqingxiang commented on a change in pull request #8008: [FLINK-11963][History Server]Add time-based cleanup mechanism in history server

2019-03-26 Thread GitBox
maqingxiang commented on a change in pull request #8008: [FLINK-11963][History Server]Add time-based cleanup mechanism in history server URL: https://github.com/apache/flink/pull/8008#discussion_r268164156 ## File path:

[GitHub] [flink] yanghua commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread GitBox
yanghua commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#issuecomment-476986958 cc @aljoscha and @pnowojski This is an

[GitHub] [flink] yanghua commented on issue #8048: [FLINK-12009] Fix wrong check message about heartbeat interval for HeartbeatServices

2019-03-26 Thread GitBox
yanghua commented on issue #8048: [FLINK-12009] Fix wrong check message about heartbeat interval for HeartbeatServices URL: https://github.com/apache/flink/pull/8048#issuecomment-476986088 @sunjincheng121 Can you review this PR?

[jira] [Updated] (FLINK-12028) Add Column Operators(add/rename/drop)

2019-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12028: --- Labels: pull-request-available (was: ) > Add Column Operators(add/rename/drop) >

[GitHub] [flink] flinkbot commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` …

2019-03-26 Thread GitBox
flinkbot commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` … URL: https://github.com/apache/flink/pull/8057#issuecomment-476975009 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] sunjincheng121 opened a new pull request #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` …

2019-03-26 Thread GitBox
sunjincheng121 opened a new pull request #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` … URL: https://github.com/apache/flink/pull/8057 ## What is the purpose of the change In this PR will add column operators as follows: - Add columns - Replace

[GitHub] [flink] sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-476966857 @flinkbot attention @aljoscha @twalthr

[jira] [Assigned] (FLINK-12029) Add Column selections

2019-03-26 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-12029: --- Assignee: Hequn Cheng > Add Column selections > - > >

[jira] [Updated] (FLINK-12029) Add Column selections

2019-03-26 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12029: Description: In this Jira will add column operators/operations as follows: Fine-grained column

[jira] [Assigned] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-11967: --- Assignee: sunjincheng > Add Column Operators/Operations > ---

[GitHub] [flink] flinkbot commented on issue #8056: [FLINK-12013][table-planner-blink] Support calc and correlate in blink batch

2019-03-26 Thread GitBox
flinkbot commented on issue #8056: [FLINK-12013][table-planner-blink] Support calc and correlate in blink batch URL: https://github.com/apache/flink/pull/8056#issuecomment-476952996 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-12013) Support calc and correlate in blink

2019-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12013: --- Labels: pull-request-available (was: ) > Support calc and correlate in blink >

[GitHub] [flink] JingsongLi opened a new pull request #8056: [FLINK-12013][table-planner-blink] Support calc and correlate in blink batch

2019-03-26 Thread GitBox
JingsongLi opened a new pull request #8056: [FLINK-12013][table-planner-blink] Support calc and correlate in blink batch URL: https://github.com/apache/flink/pull/8056 ## What is the purpose of the change Introduce blink batch sql calc and correlate. ## Brief change log

[jira] [Created] (FLINK-12029) Add Column selections

2019-03-26 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12029: --- Summary: Add Column selections Key: FLINK-12029 URL: https://issues.apache.org/jira/browse/FLINK-12029 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12028) Add Column Operators(add/rename/drop)

2019-03-26 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12028: --- Summary: Add Column Operators(add/rename/drop) Key: FLINK-12028 URL: https://issues.apache.org/jira/browse/FLINK-12028 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802388#comment-16802388 ] sunjincheng commented on FLINK-11967: -  Thanks a lot for your quick reply, [~dian.fu]! I'll open the

[jira] [Updated] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-26 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12027: --- Description: When I use flink in local mode (LocalEnvironment), I can not access flink web ui.

[jira] [Updated] (FLINK-12026) Remove the `xxxInternal` method from TableImpl

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12026: Description: At present, each operator of TableImpl has an internal method of `xxxInternal`, and

[jira] [Created] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-26 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12027: -- Summary: Flink Web UI is not accessible in local mode Key: FLINK-12027 URL: https://issues.apache.org/jira/browse/FLINK-12027 Project: Flink Issue Type:

[jira] [Created] (FLINK-12026) Remove the `xxxInternal` method from TableImpl

2019-03-26 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12026: --- Summary: Remove the `xxxInternal` method from TableImpl Key: FLINK-12026 URL: https://issues.apache.org/jira/browse/FLINK-12026 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12024) Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12024: --- Labels: pull-request-available (was: ) > Bump universal Kafka connector to Kafka

[GitHub] [flink] flinkbot commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread GitBox
flinkbot commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#issuecomment-476945512 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] yanghua opened a new pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread GitBox
yanghua opened a new pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055 ## What is the purpose of the change *This pull request bumps universal Kafka connector to Kafka dependency to 2.2.0*

[jira] [Commented] (FLINK-11982) BatchTableSourceFactory support Json Format File

2019-03-26 Thread frank wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802361#comment-16802361 ] frank wang commented on FLINK-11982: can you provide your test.json file, let me try that, thx >

[jira] [Commented] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802357#comment-16802357 ] vinoyang commented on FLINK-12025: -- [~x1q1j1] yes, you are right. So I pinged [~twalthr] in the

[jira] [Commented] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

2019-03-26 Thread Forward Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802355#comment-16802355 ] Forward Xu commented on FLINK-12025: Cool, this is the syntax for the dimension table. Firstly,

[jira] [Comment Edited] (FLINK-12003) Revert the config option about mapreduce.output.basename in HadoopOutputFormatBase

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802334#comment-16802334 ] vinoyang edited comment on FLINK-12003 at 3/27/19 1:59 AM: --- [~twalthr] It does

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802349#comment-16802349 ] vinoyang commented on FLINK-11921: -- Hi [~twalthr] Calcite official announced 1.19 has been released: 

[jira] [Created] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

2019-03-26 Thread vinoyang (JIRA)
vinoyang created FLINK-12025: Summary: Support FOR SYSTEM_TIME AS OF in temporal table Key: FLINK-12025 URL: https://issues.apache.org/jira/browse/FLINK-12025 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802348#comment-16802348 ] Dian Fu commented on FLINK-11967: - Hi [~sunjincheng121], I have not started the work yet. Feel free to

[jira] [Assigned] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-11967: --- Assignee: (was: Dian Fu) > Add Column Operators/Operations > --- >

[jira] [Commented] (FLINK-12023) Override TaskManager memory when submitting a Flink job

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802342#comment-16802342 ] vinoyang commented on FLINK-12023: -- Hi [~RustedBones] What's the deploying mode you want this feature?

[jira] [Assigned] (FLINK-12023) Override TaskManager memory when submitting a Flink job

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-12023: Assignee: vinoyang > Override TaskManager memory when submitting a Flink job >

[jira] [Assigned] (FLINK-12024) Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-12024: Assignee: vinoyang > Bump universal Kafka connector to Kafka dependency to 2.2.0 >

[jira] [Commented] (FLINK-12003) Revert the config option about mapreduce.output.basename in HadoopOutputFormatBase

2019-03-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802334#comment-16802334 ] vinoyang commented on FLINK-12003: -- [~twalthr] It does not matter. What is your opinion? [~fhueske] If

[jira] [Commented] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802329#comment-16802329 ] sunjincheng commented on FLINK-11967: - Hi [~dian.fu] Thanks for taking this ticket, have you start

[GitHub] [flink] xuefuz edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-476812342 > Thanks for the PR, I think catalog is very important for Table/SQL. Great job @xuefuz! > >

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269288171 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269286117 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269285533 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269284622 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269282987 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269282239 ## File path:

[GitHub] [flink] xuefuz commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
xuefuz commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-476812342 > Thanks for the PR, I think catalog is very important for Table/SQL. Great job @xuefuz! > > I

[GitHub] [flink] flinkbot commented on issue #8054: [hotfix][docs] fix description error of checkpoint directory

2019-03-26 Thread GitBox
flinkbot commented on issue #8054: [hotfix][docs] fix description error of checkpoint directory URL: https://github.com/apache/flink/pull/8054#issuecomment-476798688 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] aloyszhang opened a new pull request #8054: [hotfix][docs] fix description error of checkpoint directory

2019-03-26 Thread GitBox
aloyszhang opened a new pull request #8054: [hotfix][docs] fix description error of checkpoint directory URL: https://github.com/apache/flink/pull/8054 This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

2019-03-26 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802008#comment-16802008 ] Shuyi Chen commented on FLINK-9477: --- That sounds like a good idea. I will split the tasks according to

[jira] [Created] (FLINK-12024) Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread Elias Levy (JIRA)
Elias Levy created FLINK-12024: -- Summary: Bump universal Kafka connector to Kafka dependency to 2.2.0 Key: FLINK-12024 URL: https://issues.apache.org/jira/browse/FLINK-12024 Project: Flink

[jira] [Updated] (FLINK-12017) Support translation from Rank/FirstLastRow to StreamTransformation

2019-03-26 Thread aloyszhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aloyszhang updated FLINK-12017: --- Description: Support translation from Rank/FirstLastRow to StreamTransformation, So following sql

[GitHub] [flink] flinkbot commented on issue #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability

2019-03-26 Thread GitBox
flinkbot commented on issue #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability URL: https://github.com/apache/flink/pull/8053#issuecomment-476743730 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-12015) TaskManagerRunnerTest is unstable

2019-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12015: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] aljoscha opened a new pull request #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability

2019-03-26 Thread GitBox
aljoscha opened a new pull request #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability URL: https://github.com/apache/flink/pull/8053 Before, the was a race condition between the termination future in TaskManagerRunner completing and the asynchronous shutdown part here:

[jira] [Created] (FLINK-12023) Override TaskManager memory when submitting a Flink job

2019-03-26 Thread Michel Davit (JIRA)
Michel Davit created FLINK-12023: Summary: Override TaskManager memory when submitting a Flink job Key: FLINK-12023 URL: https://issues.apache.org/jira/browse/FLINK-12023 Project: Flink

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

2019-03-26 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801808#comment-16801808 ] Hequn Cheng commented on FLINK-9477: +1 to have a little design document and split methods into

[jira] [Commented] (FLINK-12019) ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable

2019-03-26 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801807#comment-16801807 ] TisonKun commented on FLINK-12019: -- It looks like the same root issue as FLINK-12006 >

[jira] [Assigned] (FLINK-12019) ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable

2019-03-26 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-12019: Assignee: TisonKun > ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable >

[GitHub] [flink] flinkbot edited a comment on issue #8041: [FLINK-11153][dataset] Remove UdfAnalyzer

2019-03-26 Thread GitBox
flinkbot edited a comment on issue #8041: [FLINK-11153][dataset] Remove UdfAnalyzer URL: https://github.com/apache/flink/pull/8041#issuecomment-475944853 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] twalthr commented on issue #8041: [FLINK-11153][dataset] Remove UdfAnalyzer

2019-03-26 Thread GitBox
twalthr commented on issue #8041: [FLINK-11153][dataset] Remove UdfAnalyzer URL: https://github.com/apache/flink/pull/8041#issuecomment-476650537 @flinkbot approve-until consensus This is an automated message from the Apache

[jira] [Commented] (FLINK-12003) Revert the config option about mapreduce.output.basename in HadoopOutputFormatBase

2019-03-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801737#comment-16801737 ] Timo Walther commented on FLINK-12003: -- Sorry, I did this a long time ago. Cannot remember the

[GitHub] [flink] flinkbot edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

2019-03-26 Thread GitBox
flinkbot edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-476498188 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] twalthr commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

2019-03-26 Thread GitBox
twalthr commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-476648401 @flinkbot approve-until consensus This is an automated

[jira] [Updated] (FLINK-11669) Add Synchronous Checkpoint Triggering RPCs.

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11669: --- Labels: pull-request-available (was: ) > Add Synchronous Checkpoint Triggering RPCs. >

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

2019-03-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801718#comment-16801718 ] Timo Walther commented on FLINK-9477: - Thanks for the suggestion [~yanghua]. That makes sense. It

[jira] [Updated] (FLINK-11671) Expose SUSPEND/TERMINATE to CLI

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11671: --- Labels: pull-request-available (was: ) > Expose SUSPEND/TERMINATE to CLI >

[jira] [Updated] (FLINK-11670) Add SUSPEND/TERMINATE calls to REST API

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11670: --- Labels: pull-request-available (was: ) > Add SUSPEND/TERMINATE calls to REST API >

[jira] [Updated] (FLINK-11458) Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11458: --- Affects Version/s: 1.8.0 > Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34) >

[jira] [Updated] (FLINK-11667) Add Synchronous Checkpoint handling in StreamTask

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11667: --- Labels: pull-request-available (was: ) > Add Synchronous Checkpoint handling in StreamTask

[jira] [Updated] (FLINK-11668) Allow sources to advance time to max watermark on checkpoint.

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11668: --- Labels: pull-request-available (was: ) > Allow sources to advance time to max watermark on

[jira] [Commented] (FLINK-11670) Add SUSPEND/TERMINATE calls to REST API

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801714#comment-16801714 ] Kostas Kloudas commented on FLINK-11670: Open PR https://github.com/apache/flink/pull/8052 >

[jira] [Updated] (FLINK-11670) Add SUSPEND/TERMINATE calls to REST API

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11670: --- Affects Version/s: 1.8.0 > Add SUSPEND/TERMINATE calls to REST API >

[jira] [Updated] (FLINK-11669) Add Synchronous Checkpoint Triggering RPCs.

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11669: --- Affects Version/s: 1.8.0 > Add Synchronous Checkpoint Triggering RPCs. >

[jira] [Updated] (FLINK-11671) Expose SUSPEND/TERMINATE to CLI

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11671: --- Affects Version/s: 1.8.0 > Expose SUSPEND/TERMINATE to CLI >

[jira] [Commented] (FLINK-11669) Add Synchronous Checkpoint Triggering RPCs.

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801711#comment-16801711 ] Kostas Kloudas commented on FLINK-11669: Open PR https://github.com/apache/flink/pull/8052 >

[jira] [Updated] (FLINK-11668) Allow sources to advance time to max watermark on checkpoint.

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11668: --- Affects Version/s: 1.8.0 > Allow sources to advance time to max watermark on checkpoint. >

[jira] [Commented] (FLINK-11671) Expose SUSPEND/TERMINATE to CLI

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801712#comment-16801712 ] Kostas Kloudas commented on FLINK-11671: Open PR https://github.com/apache/flink/pull/8052 >

[jira] [Commented] (FLINK-11668) Allow sources to advance time to max watermark on checkpoint.

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801710#comment-16801710 ] Kostas Kloudas commented on FLINK-11668: Open PR https://github.com/apache/flink/pull/8052 >

[jira] [Updated] (FLINK-11667) Add Synchronous Checkpoint handling in StreamTask

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11667: --- Affects Version/s: 1.8.0 > Add Synchronous Checkpoint handling in StreamTask >

[jira] [Commented] (FLINK-11667) Add Synchronous Checkpoint handling in StreamTask

2019-03-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801708#comment-16801708 ] Kostas Kloudas commented on FLINK-11667: Open PR https://github.com/apache/flink/pull/8052 >

[GitHub] [flink] klion26 commented on a change in pull request #8045: [FLINK-12004][TypeInformation] analyze pojo using method chaining

2019-03-26 Thread GitBox
klion26 commented on a change in pull request #8045: [FLINK-12004][TypeInformation] analyze pojo using method chaining URL: https://github.com/apache/flink/pull/8045#discussion_r269097538 ## File path:

[jira] [Updated] (FLINK-11458) Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

2019-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11458: --- Labels: pull-request-available (was: ) > Add TERMINATE/SUSPEND Job with Savepoint

[GitHub] [flink] flinkbot commented on issue #8052: [FLINK-11458][checkpointing, rest] Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

2019-03-26 Thread GitBox
flinkbot commented on issue #8052: [FLINK-11458][checkpointing, rest] Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34) URL: https://github.com/apache/flink/pull/8052#issuecomment-476624630 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] kl0u opened a new pull request #8052: [FLINK-11458][checkpointing, rest] Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

2019-03-26 Thread GitBox
kl0u opened a new pull request #8052: [FLINK-11458][checkpointing, rest] Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34) URL: https://github.com/apache/flink/pull/8052 ## What is the purpose of the change This is a first (almost complete) implementation of the FLIP-34 effort.

[jira] [Created] (FLINK-12022) Enable StreamWriter to update file length on sync flush

2019-03-26 Thread Paul Lin (JIRA)
Paul Lin created FLINK-12022: Summary: Enable StreamWriter to update file length on sync flush Key: FLINK-12022 URL: https://issues.apache.org/jira/browse/FLINK-12022 Project: Flink Issue Type:

[jira] [Closed] (FLINK-11975) Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'

2019-03-26 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11975. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 6333fc734f730e64c5f96390f345e7e0b1352662

[jira] [Assigned] (FLINK-11975) Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'

2019-03-26 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11975: -- Assignee: Jing Zhang > Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a,

[GitHub] [flink] KurtYoung merged pull request #8035: [FLINK-11975][table-planner-blink] Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'

2019-03-26 Thread GitBox
KurtYoung merged pull request #8035: [FLINK-11975][table-planner-blink] Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)' URL: https://github.com/apache/flink/pull/8035 This is an automated message

[GitHub] [flink] sunjincheng121 commented on issue #8047: [FLINK-12001][tests] fix the external jar path config error for AvroE…

2019-03-26 Thread GitBox
sunjincheng121 commented on issue #8047: [FLINK-12001][tests] fix the external jar path config error for AvroE… URL: https://github.com/apache/flink/pull/8047#issuecomment-476599660 @flinkbot attention @zentol @aljoscha

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269040649 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269038738 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269034814 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269044922 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269036820 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269044748 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269035396 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269045279 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269039472 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269035636 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269036107 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269042924 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-03-26 Thread GitBox
sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r269043100 ## File path:

  1   2   >