[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

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

[GitHub] yanghua commented on a change in pull request #6963: [FLINK-10704] Fix sql client end to end test failure

2018-11-05 Thread GitBox
yanghua commented on a change in pull request #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#discussion_r231025059 ## File path: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ## @@ -87,6 +87,8 @@

[jira] [Comment Edited] (FLINK-9050) Expose operator IO counter metrics

2018-11-05 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676292#comment-16676292 ] lining edited comment on FLINK-9050 at 11/6/18 7:42 AM: Hi, [~Zentol]. We have

[jira] [Commented] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676296#comment-16676296 ] ASF GitHub Bot commented on FLINK-10800: zhijiangW commented on issue #7031:

[GitHub] zhijiangW commented on issue #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

2018-11-05 Thread GitBox
zhijiangW commented on issue #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031#issuecomment-436157273 @pnowojski , this is the preparation for [FLINK-10790](https://issues.apache.org/jira/browse/FLINK-10790).

[jira] [Commented] (FLINK-9050) Expose operator IO counter metrics

2018-11-05 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676292#comment-16676292 ] lining commented on FLINK-9050: --- Hi, [~Zentol]. We have done something about this. Can we do it together.

[jira] [Updated] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10800: --- Labels: pull-request-available (was: ) > Abstract the StreamPartitionerTest for common

[jira] [Commented] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

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

[GitHub] zhijiangW opened a new pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

2018-11-05 Thread GitBox
zhijiangW opened a new pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031 ## What is the purpose of the change *There are many duplicated codes in current `ForwardPartitionerTest`,

[jira] [Commented] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676278#comment-16676278 ] ASF GitHub Bot commented on FLINK-10463: xccui edited a comment on issue #6888:

[jira] [Commented] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676277#comment-16676277 ] ASF GitHub Bot commented on FLINK-10463: xccui commented on issue #6888: [FLINK-10463][table]

[GitHub] xccui commented on issue #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call

2018-11-05 Thread GitBox
xccui commented on issue #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call URL: https://github.com/apache/flink/pull/6888#issuecomment-436155099 Thanks for the response @twalthr. @hequn8128, thanks for your contribution, I'll merge this.

[GitHub] xccui edited a comment on issue #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call

2018-11-05 Thread GitBox
xccui edited a comment on issue #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call URL: https://github.com/apache/flink/pull/6888#issuecomment-436155099 Thanks for the response @twalthr. @hequn8128, thanks for your contribution. I'll

[jira] [Commented] (FLINK-10733) Misleading clean_log_files() in common.sh

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

[jira] [Updated] (FLINK-10733) Misleading clean_log_files() in common.sh

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10733: --- Labels: pull-request-available (was: ) > Misleading clean_log_files() in common.sh >

[GitHub] yanghua opened a new pull request #7030: [FLINK-10733] Misleading clean_log_files() in common.sh

2018-11-05 Thread GitBox
yanghua opened a new pull request #7030: [FLINK-10733] Misleading clean_log_files() in common.sh URL: https://github.com/apache/flink/pull/7030 ## What is the purpose of the change *Fix misleading clean_log_files() in common.sh* ## Brief change log - *Fix misleading

[jira] [Created] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

2018-11-05 Thread zhijiang (JIRA)
zhijiang created FLINK-10800: Summary: Abstract the StreamPartitionerTest for common codes Key: FLINK-10800 URL: https://issues.apache.org/jira/browse/FLINK-10800 Project: Flink Issue Type:

[GitHub] tzulitai opened a new pull request #7029: [BP-1.7] [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot

2018-11-05 Thread GitBox
tzulitai opened a new pull request #7029: [BP-1.7] [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot URL: https://github.com/apache/flink/pull/7029 This is a backport of #7028 for `release-1.7`.

[GitHub] tzulitai opened a new pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot

2018-11-05 Thread GitBox
tzulitai opened a new pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot URL: https://github.com/apache/flink/pull/7028 ## What is the purpose of the change Commit 3787b89105c6a005ddca999b0b8a0356e812ede6 added a few new

[jira] [Commented] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

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

[jira] [Updated] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10789: --- Labels: pull-request-available (was: ) > Some new serializer snapshots added after 1.6 are

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-05 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676222#comment-16676222 ] Rong Rong commented on FLINK-9172: -- Thanks for the info [~xuefuz]. I wasn't aware that this ticket was

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

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676221#comment-16676221 ] ASF GitHub Bot commented on FLINK-10798: yanghua commented on issue #7026: [FLINK-10798] Add the

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

2018-11-05 Thread GitBox
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-436144115 @tzulitai @zentol This is an automated message

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676177#comment-16676177 ] ASF GitHub Bot commented on FLINK-5697: --- tzulitai commented on issue #6980: [FLINK-5697] [kinesis]

[GitHub] tzulitai commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-05 Thread GitBox
tzulitai commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#issuecomment-436137288 @tweise will put this on my backlog and try to get to this as soon as I'm finished with 1.7 remaining work.

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676173#comment-16676173 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-5697] [kinesis]

[GitHub] tweise commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-05 Thread GitBox
tweise commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#issuecomment-436137039 @tzulitai @aljoscha PTAL This is an automated message

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-05 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676117#comment-16676117 ] Xuefu Zhang commented on FLINK-9172: Hi [~walterddr], thanks for chiming in. I don't think we are

[jira] [Commented] (FLINK-10799) YARN mode JobManager JVM memory args add -XmsXXXm

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676111#comment-16676111 ] ASF GitHub Bot commented on FLINK-10799: xinchun-wang opened a new pull request #7027:

[GitHub] xinchun-wang opened a new pull request #7027: [FLINK-10799][yarn] YARN mode JobManager JVM memory args add -XmsXXXm

2018-11-05 Thread GitBox
xinchun-wang opened a new pull request #7027: [FLINK-10799][yarn] YARN mode JobManager JVM memory args add -XmsXXXm URL: https://github.com/apache/flink/pull/7027 ## What is the purpose of the change When start JobManager on Yarn mode, only set -Xmx parameter , add -Xms also

[jira] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-05 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676092#comment-16676092 ] zhijiang commented on FLINK-10790: -- As I described above in this jira, the similar logics are

[jira] [Created] (FLINK-10799) YARN mode JobManager JVM memory args add -XmsXXXm

2018-11-05 Thread xinchun (JIRA)
xinchun created FLINK-10799: --- Summary: YARN mode JobManager JVM memory args add -XmsXXXm Key: FLINK-10799 URL: https://issues.apache.org/jira/browse/FLINK-10799 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

2018-11-05 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676066#comment-16676066 ] lining commented on FLINK-10707: Hi, [~wolli]. Look wonderful, can we do it together? > Improve Cluster

[GitHub] yanghua opened a new pull request #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

2018-11-05 Thread GitBox
yanghua opened a new pull request #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion URL: https://github.com/apache/flink/pull/7026 ## What is the purpose of the change *Add the version number of Flink 1.7 to MigrationVersion* ## Brief change log

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

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

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

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10798: --- Labels: pull-request-available (was: ) > Add the version number of Flink 1.7 to

[jira] [Assigned] (FLINK-10634) End-to-end test: Metrics accessible via REST API

2018-11-05 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-10634: Assignee: Biao Liu > End-to-end test: Metrics accessible via REST API >

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

2018-11-05 Thread vinoyang (JIRA)
vinoyang created FLINK-10798: Summary: Add the version number of Flink 1.7 to MigrationVersion Key: FLINK-10798 URL: https://issues.apache.org/jira/browse/FLINK-10798 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676042#comment-16676042 ] vinoyang commented on FLINK-10771: -- [~till.rohrmann] Yes, I know. What I mean is that if it is not used

[jira] [Commented] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2018-11-05 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676041#comment-16676041 ] lining commented on FLINK-7286: --- Hi, [~yew1eb] are you doing this now? > Flink Dashboard fails to display

[jira] [Assigned] (FLINK-10795) STDDEV_POP error

2018-11-05 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-10795: Assignee: winifredtang (was: vinoyang) > STDDEV_POP error > > >

[jira] [Assigned] (FLINK-10795) STDDEV_POP error

2018-11-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10795: Assignee: vinoyang > STDDEV_POP error > > > Key: FLINK-10795 >

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

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

[GitHub] xndai opened a new pull request #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md

2018-11-05 Thread GitBox
xndai opened a new pull request #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md URL: https://github.com/apache/flink/pull/7025 Use the correct link of docs/flinkDev/ide_setup.md#intellij-idea Change-Id: I293b3ed51e5fa54046d1a97614f02e31c93fc899

[jira] [Commented] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675924#comment-16675924 ] ASF GitHub Bot commented on FLINK-10768: xuefuz commented on issue #7011: [FLINK-10768][Table &

[GitHub] xuefuz commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager

2018-11-05 Thread GitBox
xuefuz commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager URL: https://github.com/apache/flink/pull/7011#issuecomment-436088040 Thanks for the PR. I quickly went over the changes and have some high-level

[jira] [Updated] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10797: - Fix Version/s: 1.7.0 > "IntelliJ Setup" link is broken in Readme.md >

[jira] [Updated] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10797: - Affects Version/s: 1.7.0 > "IntelliJ Setup" link is broken in Readme.md >

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675877#comment-16675877 ] ASF GitHub Bot commented on FLINK-10797: TisonKun commented on issue #7024: [FLINK-10797]

[GitHub] TisonKun commented on issue #7024: [FLINK-10797] [README] Fix broken link

2018-11-05 Thread GitBox
TisonKun commented on issue #7024: [FLINK-10797] [README] Fix broken link URL: https://github.com/apache/flink/pull/7024#issuecomment-436074270 I prefer to use related path for keep path issue isolated among versions. Not sure what release(s) should back port to.

[jira] [Updated] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10797: --- Labels: pull-request-available (was: ) > "IntelliJ Setup" link is broken in Readme.md >

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

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

[GitHub] TisonKun opened a new pull request #7024: [FLINK-10797] [README] Fix broken link

2018-11-05 Thread GitBox
TisonKun opened a new pull request #7024: [FLINK-10797] [README] Fix broken link URL: https://github.com/apache/flink/pull/7024 ## What is the purpose of the change File `ide_setup.md` is moved. We do the redirect but not change links where hardcode. ## Verifying this change

[jira] [Assigned] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-10797: Assignee: TisonKun > "IntelliJ Setup" link is broken in Readme.md >

[jira] [Created] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-05 Thread Xiening Dai (JIRA)
Xiening Dai created FLINK-10797: --- Summary: "IntelliJ Setup" link is broken in Readme.md Key: FLINK-10797 URL: https://issues.apache.org/jira/browse/FLINK-10797 Project: Flink Issue Type: Bug

[jira] [Reopened] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-11-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reopened FLINK-10222: -- For correcting fix versions. > Table scalar function expression parses error when function name equals

[jira] [Closed] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-11-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-10222. Resolution: Fixed > Table scalar function expression parses error when function name equals the > exists

[jira] [Updated] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-11-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10222: - Fix Version/s: 1.7.0 > Table scalar function expression parses error when function name equals the >

[jira] [Updated] (FLINK-10697) Create FlinkInMemoryCatalog class, an in-memory catalog that stores Flink's meta objects for production use

2018-11-05 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10697: - Summary: Create FlinkInMemoryCatalog class, an in-memory catalog that stores Flink's meta objects for

[jira] [Updated] (FLINK-10697) Create FlinkInMemoryCatalog class, an in-memory catalog that stores Flink's meta objects

2018-11-05 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10697: - Summary: Create FlinkInMemoryCatalog class, an in-memory catalog that stores Flink's meta objects

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675769#comment-16675769 ] Till Rohrmann commented on FLINK-10771: --- But it is used as you can see here:

[jira] [Commented] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675760#comment-16675760 ] ASF GitHub Bot commented on FLINK-10655: tillrohrmann closed pull request #7005:

[jira] [Resolved] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10655. --- Resolution: Fixed Fix Version/s: (was: 1.5.6) Fixed via master:

[jira] [Commented] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675759#comment-16675759 ] ASF GitHub Bot commented on FLINK-10655: tillrohrmann closed pull request #6920:

[GitHub] tillrohrmann closed pull request #7005: [FLINK-10655][rpc] fix RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-11-05 Thread GitBox
tillrohrmann closed pull request #7005: [FLINK-10655][rpc] fix RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException URL: https://github.com/apache/flink/pull/7005 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[GitHub] tillrohrmann closed pull request #6920: [FLINK-10655][rpc] fix RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-11-05 Thread GitBox
tillrohrmann closed pull request #6920: [FLINK-10655][rpc] fix RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException URL: https://github.com/apache/flink/pull/6920 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Commented] (FLINK-10697) Create an in-memory catalog that stores Flink's meta objects

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675731#comment-16675731 ] ASF GitHub Bot commented on FLINK-10697: bowenli86 closed pull request #6997:

[GitHub] bowenli86 closed pull request #6997: [FLINK-10697][Table & SQL] Create an in-memory catalog that stores Flink's meta objects

2018-11-05 Thread GitBox
bowenli86 closed pull request #6997: [FLINK-10697][Table & SQL] Create an in-memory catalog that stores Flink's meta objects URL: https://github.com/apache/flink/pull/6997 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Created] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

2018-11-05 Thread Bowen Li (JIRA)
Bowen Li created FLINK-10796: Summary: Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager Key: FLINK-10796 URL: https://issues.apache.org/jira/browse/FLINK-10796 Project: Flink

[jira] [Commented] (FLINK-10493) Macro generated CaseClassSerializer considered harmful

2018-11-05 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675634#comment-16675634 ] Elias Levy commented on FLINK-10493: [~tzulitai] correct.  It is not evident that the Scala

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675628#comment-16675628 ] ASF GitHub Bot commented on FLINK-5697: --- jgrier commented on issue #6980: [FLINK-5697] [kinesis]

[GitHub] jgrier commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-05 Thread GitBox
jgrier commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#issuecomment-435998278 Looks good @tweise. This is an automated message from the

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-05 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675483#comment-16675483 ] Bowen Li commented on FLINK-10689: -- [~twalthr] thanks a lot for the discussion! I've started a couple

[jira] [Commented] (FLINK-10769) port InMemoryExternalCatalog to java

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675436#comment-16675436 ] ASF GitHub Bot commented on FLINK-10769: bowenli86 edited a comment on issue #7012:

[GitHub] bowenli86 edited a comment on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java

2018-11-05 Thread GitBox
bowenli86 edited a comment on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java URL: https://github.com/apache/flink/pull/7012#issuecomment-435950340 Thanks, @fhueske. Sorry that the description might be a bit imprecise. I updated descriptions in both the PR and

[jira] [Updated] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

2018-11-05 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10768: - Description: Add a new CatalogManager class and port existing Calcite-directly-related code from

[jira] [Commented] (FLINK-10769) port InMemoryExternalCatalog to java

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675428#comment-16675428 ] ASF GitHub Bot commented on FLINK-10769: bowenli86 commented on issue #7012: [FLINK-10769][Table

[GitHub] bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java

2018-11-05 Thread GitBox
bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java URL: https://github.com/apache/flink/pull/7012#issuecomment-435950340 Thanks, @fhueske. Sorry that the description might be a bit imprecise. I updated descriptions in both the PR and the

[jira] [Updated] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

2018-11-05 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10768: - Description: Add a new CatalogManager class and port existing Calcite-directly-related code from

[jira] [Updated] (FLINK-10769) port InMemoryExternalCatalog to java

2018-11-05 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10769: - Description: In the Flink-Hive integration design, we propose a new FlinkInMemoryCatalog (FLINK-10697)

[jira] [Commented] (FLINK-10520) Job save points REST API fails unless parameters are specified

2018-11-05 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675404#comment-16675404 ] Elias Levy commented on FLINK-10520: [~huide] as I said " the system is configured with a default

[jira] [Commented] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675402#comment-16675402 ] ASF GitHub Bot commented on FLINK-8424: --- bmeriaux commented on issue #6715: [FLINK-8424] update

[GitHub] bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest

2018-11-05 Thread GitBox
bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest URL: https://github.com/apache/flink/pull/6715#issuecomment-435938789 Hi @zentol , could this be merged into 1.7 please ? the driver update is pretty important for stability, there are some

[GitHub] yanghua commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure

2018-11-05 Thread GitBox
yanghua commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#issuecomment-435932622 @pnowojski updated. This is an automated message from the Apache

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675377#comment-16675377 ] ASF GitHub Bot commented on FLINK-10704: yanghua commented on issue #6963: [FLINK-10704] Fix sql

[jira] [Comment Edited] (FLINK-10762) Do not try to request partitions in SingleInputGate per getRecord

2018-11-05 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675079#comment-16675079 ] Piotr Nowojski edited comment on FLINK-10762 at 11/5/18 4:02 PM: -

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675352#comment-16675352 ] ASF GitHub Bot commented on FLINK-5601: --- zentol commented on issue #7013:

[GitHub] zentol commented on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing

2018-11-05 Thread GitBox
zentol commented on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing URL: https://github.com/apache/flink/pull/7013#issuecomment-435927023 Related test-failure: ``` Tests run: 12, Failures: 0, Errors: 3, Skipped: 0, Time elapsed: 10.549 sec <<< FAILURE! - in

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675349#comment-16675349 ] vinoyang commented on FLINK-10771: -- [~till.rohrmann] I mean :  {code:java} public static final String

[jira] [Closed] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10773. - Resolution: Fixed Fix Version/s: 1.5.6 Fixed additionally via: 1.6.3:

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675327#comment-16675327 ] Till Rohrmann commented on FLINK-10771: --- It is a constant, right? Moreover, it can be used as you

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

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

[GitHub] tillrohrmann commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-05 Thread GitBox
tillrohrmann commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#discussion_r230797428 ## File path: flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

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

[GitHub] pnowojski commented on a change in pull request #6963: [FLINK-10704] Fix sql client end to end test failure

2018-11-05 Thread GitBox
pnowojski commented on a change in pull request #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#discussion_r230793009 ## File path: flink-end-to-end-tests/run-pre-commit-tests.sh ## @@ -48,6 +48,7 @@ echo "Flink

[jira] [Commented] (FLINK-10711) flink-end-to-end-tests can fail silently

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

[GitHub] zentol commented on a change in pull request #7023: [FLINK-10711] [e2e] Allow basic error handling with bash

2018-11-05 Thread GitBox
zentol commented on a change in pull request #7023: [FLINK-10711] [e2e] Allow basic error handling with bash URL: https://github.com/apache/flink/pull/7023#discussion_r230781779 ## File path: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ## @@ -17,8 +17,6 @@

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675278#comment-16675278 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-11-05 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-435904341 updated. This is an automated message from the

  1   2   3   4   >