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

zjffdu 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_r237735988 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@

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

zjffdu 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_r237736038 ## 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=16704210#comment-16704210 ] ASF GitHub Bot commented on FLINK-9555: --- zjffdu commented on a change in pull request #7121:

[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=16704209#comment-16704209 ] ASF GitHub Bot commented on FLINK-9555: --- zjffdu commented on a change in pull request #7121:

[GitHub] dianfu commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237722370 ## File path:

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237727039 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237739790 ## File path:

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237472868 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237731718 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237738914 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237724165 ## File path:

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237466962 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237737176 ## File path:

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237726170 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237472659 ## File path:

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237737335 ## File path:

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Created] (FLINK-11034) Provide "rewriting config” to file system factory

Wei-Che Wei created FLINK-11034: --- Summary: Provide "rewriting config” to file system factory Key: FLINK-11034 URL: https://issues.apache.org/jira/browse/FLINK-11034 Project: Flink Issue Type:

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

zhijiangW 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_r237743628 ## File path:

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

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

[GitHub] maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197#issuecomment-443067252 @zhijiangW thanks for your review. Sorry, I will create a jira ticket next time .

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

zjffdu 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_r237735688 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@

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

zjffdu 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_r237735688 ## 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=16704205#comment-16704205 ] ASF GitHub Bot commented on FLINK-9555: --- zjffdu commented on a change in pull request #7121:

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-443079619 Thanks a lot for your reviews, I learnt a lot from them. @azagrebin I fixed the java doc,

[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=16704207#comment-16704207 ] ASF GitHub Bot commented on FLINK-9555: --- zjffdu commented on a change in pull request #7121:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704215#comment-16704215 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237398634 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237399713 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237400562 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237398248 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237399688 ## File path:

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702890#comment-16702890 ] Fabian Hueske commented on FLINK-10999: --- Hi, Processing-time and event-time are supported in the

[GitHub] dianfu opened a new pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

dianfu opened a new pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196 ## What is the purpose of the change *This pull request adds the flatMap operation to the table API.* ## Brief change log

[jira] [Assigned] (FLINK-11022) Update LICENSE and NOTICE files for older releases

[ https://issues.apache.org/jira/browse/FLINK-11022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11022: Assignee: Chesnay Schepler (was: vinoyang) > Update LICENSE and NOTICE files

[jira] [Assigned] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11023: Assignee: Chesnay Schepler (was: vinoyang) > Update LICENSE and NOTICE files

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702877#comment-16702877 ] xuqianjin commented on FLINK-10999: --- [~harbby] You see in the execution plan that you can't add

[GitHub] maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197#issuecomment-442760936 @zhijiangW Please review it, thanks.

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237402642 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237399504 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237402448 ## File path:

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237401057 ## File path:

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

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

[GitHub] twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237396997 ## File path:

[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=16702891#comment-16702891 ] ASF GitHub Bot commented on FLINK-10974: dianfu opened a new pull request #7196: [FLINK-10974]

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[GitHub] maqingxiang opened a new pull request #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

maqingxiang opened a new pull request #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197 ## What is the purpose of the change Catch exceptions thrown due to disk loss, try to find a unique

[jira] [Commented] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704290#comment-16704290 ] ASF GitHub Bot commented on FLINK-10712: Myasuka commented on issue #7009: [FLINK-10712] Support

[GitHub] Myasuka commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy

Myasuka commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/7009#issuecomment-443096765 @StefanRRichter Thanks for your comments, I would refactor this PR. BTW, I found region failover

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704286#comment-16704286 ] Yun Tang commented on FLINK-10930: -- [~StephanEwen] I think your opinion to refactor the mechanism of

[GitHub] yanghua commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

yanghua commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion URL: https://github.com/apache/flink/pull/7026#issuecomment-443107105 Since Flink 1.7 has released, shall we merge this PR?

[GitHub] yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#issuecomment-443107227 @twalthr Let's merge this PR? thanks.

[jira] [Commented] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

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

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704326#comment-16704326 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on issue #6850: [FLINK-10252] Handle

[GitHub] yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges

yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-443107471 @zentol This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704325#comment-16704325 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on issue #7182: [FLINK-11015] Remove

[jira] [Commented] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution

[ https://issues.apache.org/jira/browse/FLINK-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704307#comment-16704307 ] xuqianjin commented on FLINK-11017: --- [~dawidwys] I want to try to solve it. > Time interval for

[jira] [Created] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder

zhijiang created FLINK-11035: Summary: Notify data available to network stack immediately after finishing BufferBuilder Key: FLINK-11035 URL: https://issues.apache.org/jira/browse/FLINK-11035 Project:

[GitHub] zhijiangW commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

zhijiangW commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197#issuecomment-443095850 lgtm! This is an automated

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704330#comment-16704330 ] ASF GitHub Bot commented on FLINK-10431: Clark commented on issue #6898: [FLINK-10431]

[GitHub] Clarkkkkk commented on issue #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

Clark commented on issue #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#issuecomment-443109202 Hi @StefanRRichter , I am just wondering why make SlotPool no longer to be an RpcEndpoint?

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704340#comment-16704340 ] vinoyang commented on FLINK-10993: -- [~fhueske] yes, I looked the design document attached by

[jira] [Commented] (FLINK-11034) Provide "rewriting config” to file system factory

[ https://issues.apache.org/jira/browse/FLINK-11034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704369#comment-16704369 ] Tony Xintong Song commented on FLINK-11034: --- I agree with you that we should allow users to

[jira] [Commented] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704356#comment-16704356 ] Dian Fu commented on FLINK-8739: Hi [~walterddr], are you still working on this ticket? I'd like to help

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702930#comment-16702930 ] Fabian Hueske commented on FLINK-10993: --- I like the proposal of FLINK-8601. It seems like a very

[jira] [Commented] (FLINK-11025) Connector shading is inconsistent

[ https://issues.apache.org/jira/browse/FLINK-11025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702929#comment-16702929 ] Chesnay Schepler commented on FLINK-11025: -- Additionally there are some modules where we

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237422016 ## File path:

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

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

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

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

[GitHub] kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink

kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink URL: https://github.com/apache/flink/pull/6774#discussion_r237427090 ## File path:

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

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

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

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

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

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

[GitHub] kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink

kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink URL: https://github.com/apache/flink/pull/6774#discussion_r237426973 ## File path: flink-formats/flink-sequencefile/pom.xml ## @@ -0,0 +1,107 @@ + +

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[GitHub] kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink

kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink URL: https://github.com/apache/flink/pull/6774#discussion_r237426910 ## File path: flink-formats/flink-sequencefile/pom.xml ## @@ -0,0 +1,107 @@ + +

[jira] [Comment Edited] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702983#comment-16702983 ] xuqianjin edited comment on FLINK-10999 at 11/29/18 10:25 AM: -- hi 

[GitHub] kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink

kl0u commented on a change in pull request #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink URL: https://github.com/apache/flink/pull/6774#discussion_r237428128 ## File path:

  1   2   3   >