[GitHub] [flink] flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-510484364 ## CI report: * eac5f74690ddb0b08cb41b029f5b8ac675e63565 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase URL: https://github.com/apache/flink/pull/9191#issuecomment-513649015 ## CI report: * ddd758fdc5714f75114c1cd35cd61e45091cf736 :

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase

2019-07-21 Thread GitBox
flinkbot commented on issue #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase URL: https://github.com/apache/flink/pull/9191#issuecomment-513649015 ## CI report: * ddd758fdc5714f75114c1cd35cd61e45091cf736 : PENDING

[GitHub] [flink] flinkbot commented on issue #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase

2019-07-21 Thread GitBox
flinkbot commented on issue #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase URL: https://github.com/apache/flink/pull/9191#issuecomment-513647351 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

2019-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11767: --- Labels: pull-request-available (was: ) > Update TypeSerializerSnapshotMigrationTestBase

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2019-07-21 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889932#comment-16889932 ] Jiayi Liao commented on FLINK-10806: [~becket_qin] Thanks for pointing this out. What you described

[GitHub] [flink] tzulitai opened a new pull request #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase

2019-07-21 Thread GitBox
tzulitai opened a new pull request #9191: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase to replace TypeSerializerSnapshotMigrationTestBase URL: https://github.com/apache/flink/pull/9191 #What is the purpose of the change This PR introduces a new

[GitHub] [flink] flinkbot edited a comment on issue #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#issuecomment-513625214 ## CI report: *

[jira] [Closed] (FLINK-13094) Provide an easy way to read timers using the State Processor API

2019-07-21 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-13094. --- Resolution: Fixed Fix Version/s: 1.9.0 Merged. master (1.10.0):

[jira] [Updated] (FLINK-13293) Add state processor api to opt/ directory in flink-dist

2019-07-21 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13293: Affects Version/s: (was: 1.10.0) (was: 1.9.0) >

[jira] [Closed] (FLINK-13293) Add state processor api to opt/ directory in flink-dist

2019-07-21 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-13293. --- Resolution: Fixed Fix Version/s: (was: 1.10.0) Merged. master (1.10.0):

[GitHub] [flink] flinkbot edited a comment on issue #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in …

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in … URL: https://github.com/apache/flink/pull/9165#issuecomment-512797712 ## CI report: * c51d878e9c6c9ccce6b1d67969aa029395acc4ea : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-510484364 ## CI report: * eac5f74690ddb0b08cb41b029f5b8ac675e63565 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#issuecomment-510770597 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serialize

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[GitHub] [flink] asfgit closed pull request #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

2019-07-21 Thread GitBox
asfgit closed pull request #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094 This is an automated message from the

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-07-21 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889905#comment-16889905 ] TisonKun commented on FLINK-10052: -- Yes. LeaderContender(jm, rm, dispatcher, etc.) in FLINK is all

[GitHub] [flink] asfgit closed pull request #9133: [FLINK-13293][state-processor-api][build] Add state processor api to opt/ directory in flink-dist

2019-07-21 Thread GitBox
asfgit closed pull request #9133: [FLINK-13293][state-processor-api][build] Add state processor api to opt/ directory in flink-dist URL: https://github.com/apache/flink/pull/9133 This is an automated message from the Apache

[GitHub] [flink] tzulitai commented on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

2019-07-21 Thread GitBox
tzulitai commented on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-513636515 Merging ... This is

[GitHub] [flink] tzulitai commented on issue #9133: [FLINK-13293][state-processor-api][build] Add state processor api to opt/ directory in flink-dist

2019-07-21 Thread GitBox
tzulitai commented on issue #9133: [FLINK-13293][state-processor-api][build] Add state processor api to opt/ directory in flink-dist URL: https://github.com/apache/flink/pull/9133#issuecomment-513636024 +1, merging ... This

[jira] [Closed] (FLINK-13346) indexdb reporter parse data type error

2019-07-21 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-13346. Resolution: Duplicate > indexdb reporter parse data type error > -- >

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-07-21 Thread Quan Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889901#comment-16889901 ] Quan Shi commented on FLINK-10052: -- hi [~Tison] Sounds reasonable. Elect a new leader and recovery

[GitHub] [flink] lirui-apache commented on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-21 Thread GitBox
lirui-apache commented on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-513633987 Changed to test with table env. This PR needs to wait until we have #9181 merged.

[GitHub] [flink] flinkbot edited a comment on issue #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serialize

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[jira] [Commented] (FLINK-13344) Translate "How to Contribute" page into Chinese.

2019-07-21 Thread Jeff Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889895#comment-16889895 ] Jeff Yang commented on FLINK-13344: --- I got it . Thanks [~jark] > Translate "How to Contribute" page

[jira] [Commented] (FLINK-13344) Translate "How to Contribute" page into Chinese.

2019-07-21 Thread WangHengWei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889894#comment-16889894 ] WangHengWei commented on FLINK-13344: - [~jark], thanks very much. I'm gonna do it.:D > Translate

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-07-21 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889893#comment-16889893 ] TisonKun commented on FLINK-10052: -- [~quan] Supposed you have jm-1 and jm-2 execute the same job but

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] KurtYoung commented on issue #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread GitBox
KurtYoung commented on issue #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#issuecomment-51363 LGTM, waiting travis pass

[GitHub] [flink] KurtYoung commented on a change in pull request #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUE

2019-07-21 Thread GitBox
KurtYoung commented on a change in pull request #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#discussion_r305665394 ## File

[jira] [Updated] (FLINK-13289) Blink Planner JDBCUpsertTableSink : UnsupportedOperationException "JDBCUpsertTableSink can not support "

2019-07-21 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13289: - Priority: Blocker (was: Major) > Blink Planner JDBCUpsertTableSink :

[jira] [Updated] (FLINK-13342) Flink1.9 document number error

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13342: Priority: Critical (was: Major) > Flink1.9 document number error > -- > >

[jira] [Comment Edited] (FLINK-13242) StandaloneResourceManagerTest fails on travis

2019-07-21 Thread Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889630#comment-16889630 ] Xintong Song edited comment on FLINK-13242 at 7/22/19 3:45 AM: --- Hi

[jira] [Commented] (FLINK-13318) Blink planner tests failing on Scala 2.12

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889891#comment-16889891 ] Jark Wu commented on FLINK-13318: - +1 for this approach! > Blink planner tests failing on Scala 2.12 >

[jira] [Updated] (FLINK-13289) Blink Planner JDBCUpsertTableSink : UnsupportedOperationException "JDBCUpsertTableSink can not support "

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13289: Fix Version/s: 1.10.0 > Blink Planner JDBCUpsertTableSink : UnsupportedOperationException >

[jira] [Updated] (FLINK-13289) Blink Planner JDBCUpsertTableSink : UnsupportedOperationException "JDBCUpsertTableSink can not support "

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13289: Fix Version/s: 1.9.0 > Blink Planner JDBCUpsertTableSink : UnsupportedOperationException >

[jira] [Updated] (FLINK-13289) Blink Planner JDBCUpsertTableSink : UnsupportedOperationException "JDBCUpsertTableSink can not support "

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13289: Component/s: Connectors / JDBC > Blink Planner JDBCUpsertTableSink : UnsupportedOperationException >

[jira] [Commented] (FLINK-13289) Blink Planner JDBCUpsertTableSink : UnsupportedOperationException "JDBCUpsertTableSink can not support "

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889890#comment-16889890 ] Jark Wu commented on FLINK-13289: - Thanks [~kakachen] for digging into this. This is definitely a bug in

[GitHub] [flink] flinkbot edited a comment on issue #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serialize

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[GitHub] [flink] godfreyhe commented on a change in pull request #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner

2019-07-21 Thread GitBox
godfreyhe commented on a change in pull request #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner URL: https://github.com/apache/flink/pull/9056#discussion_r305664376 ## File path:

[jira] [Created] (FLINK-13347) should handle new JoinRelType(SEMI/ANTI) in switch case

2019-07-21 Thread godfrey he (JIRA)
godfrey he created FLINK-13347: -- Summary: should handle new JoinRelType(SEMI/ANTI) in switch case Key: FLINK-13347 URL: https://issues.apache.org/jira/browse/FLINK-13347 Project: Flink Issue

[jira] [Commented] (FLINK-13344) Translate "How to Contribute" page into Chinese.

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889888#comment-16889888 ] Jark Wu commented on FLINK-13344: - Hi [~highfei2...@126.com], this is not a duplicate issue with

[jira] [Assigned] (FLINK-13344) Translate "How to Contribute" page into Chinese.

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13344: --- Assignee: WangHengWei > Translate "How to Contribute" page into Chinese. >

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-07-21 Thread Quan Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889887#comment-16889887 ] Quan Shi commented on FLINK-10052: -- Hi, all. What if the Job Manager works fine except losing

[GitHub] [flink] liyafan82 commented on a change in pull request #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUE

2019-07-21 Thread GitBox
liyafan82 commented on a change in pull request #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#discussion_r305663679 ## File

[GitHub] [flink] KurtYoung commented on a change in pull request #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUE

2019-07-21 Thread GitBox
KurtYoung commented on a change in pull request #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#discussion_r305663260 ## File

[jira] [Created] (FLINK-13346) indexdb reporter parse data type error

2019-07-21 Thread Jake.zhang (JIRA)
Jake.zhang created FLINK-13346: -- Summary: indexdb reporter parse data type error Key: FLINK-13346 URL: https://issues.apache.org/jira/browse/FLINK-13346 Project: Flink Issue Type: Bug

[GitHub] [flink] JingsongLi commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

2019-07-21 Thread GitBox
JingsongLi commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513625785 @wuchong @zentol Thanks for your attention. About leak resources, there is a clean

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2019-07-21 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889886#comment-16889886 ] Jiangjie Qin commented on FLINK-10806: -- [~wind_ljy] Thanks for the context. Yes, I agree that the

[GitHub] [flink] flinkbot commented on issue #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread GitBox
flinkbot commented on issue #9190: [FLINK-13221][Table SQL / Planner][Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#issuecomment-513625214 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9190: [FLINK-13221][Table SQL / Planner] [Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread GitBox
flinkbot commented on issue #9190: [FLINK-13221][Table SQL / Planner] [Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190#issuecomment-513624385 Thanks a lot for your contribution to

[jira] [Commented] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889884#comment-16889884 ] Liya Fan commented on FLINK-13221: -- [~ykt836]. Sure. Thanks a lot. > Blink planner should set

[GitHub] [flink] flinkbot edited a comment on issue #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in …

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in … URL: https://github.com/apache/flink/pull/9165#issuecomment-512797712 ## CI report: * c51d878e9c6c9ccce6b1d67969aa029395acc4ea : FAILURE

[GitHub] [flink] liyafan82 opened a new pull request #9190: [FLINK-13221][Table SQL / Planner] [Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batc

2019-07-21 Thread GitBox
liyafan82 opened a new pull request #9190: [FLINK-13221][Table SQL / Planner] [Release-1.9] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9190 ## What is the purpose of the change

[GitHub] [flink] JingsongLi closed pull request #9174: [FLINK-13330][table-planner-blink] Remove unnecessary to reduce testing time in blink

2019-07-21 Thread GitBox
JingsongLi closed pull request #9174: [FLINK-13330][table-planner-blink] Remove unnecessary to reduce testing time in blink URL: https://github.com/apache/flink/pull/9174 This is an automated message from the Apache Git

[GitHub] [flink] JingsongLi commented on issue #9174: [FLINK-13330][table-planner-blink] Remove unnecessary to reduce testing time in blink

2019-07-21 Thread GitBox
JingsongLi commented on issue #9174: [FLINK-13330][table-planner-blink] Remove unnecessary to reduce testing time in blink URL: https://github.com/apache/flink/pull/9174#issuecomment-513623907 I close this now, @wuchong will do some work to extract them to daily run.

[GitHub] [flink] JingsongLi commented on issue #9174: [FLINK-13330][table-planner-blink] Remove unnecessary to reduce testing time in blink

2019-07-21 Thread GitBox
JingsongLi commented on issue #9174: [FLINK-13330][table-planner-blink] Remove unnecessary to reduce testing time in blink URL: https://github.com/apache/flink/pull/9174#issuecomment-513623792 Thanks @twalthr @wuchong , this tests should move to crontab and daily run. Every tests is

[GitHub] [flink] flinkbot edited a comment on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#issuecomment-510770597 ## CI report: *

[GitHub] [flink] zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in …

2019-07-21 Thread GitBox
zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in … URL: https://github.com/apache/flink/pull/9165#discussion_r305660149 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305659817 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305659829 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305659842 ## File path:

[GitHub] [flink] liyafan82 commented on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread GitBox
liyafan82 commented on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#issuecomment-513622448 > Thanks @liyafan82 for working on this. I think

[GitHub] [flink] liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
liyafan82 commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305659798 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in …

2019-07-21 Thread GitBox
zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in … URL: https://github.com/apache/flink/pull/9165#discussion_r305658754 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in …

2019-07-21 Thread GitBox
zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in … URL: https://github.com/apache/flink/pull/9165#discussion_r305658703 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in …

2019-07-21 Thread GitBox
zhuzhurk commented on a change in pull request #9165: [FLINK-13055] [runtime] Leverage JM tracked partitions to find out unavailable partitions in … URL: https://github.com/apache/flink/pull/9165#discussion_r305658771 ## File path:

[GitHub] [flink] lirui-apache commented on issue #9181: [FLINK-13210][hive] Hive connector test should dependent on blink planner instead of legacy planner

2019-07-21 Thread GitBox
lirui-apache commented on issue #9181: [FLINK-13210][hive] Hive connector test should dependent on blink planner instead of legacy planner URL: https://github.com/apache/flink/pull/9181#issuecomment-513618686 @JingsongLi thanks for the review. One side note is blink planner requires a

[jira] [Closed] (FLINK-13329) Set env config for sql jobs

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13329. --- Resolution: Won't Fix Fix Version/s: (was: 1.10.0) (was: 1.9.0) Closing

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2019-07-21 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889876#comment-16889876 ] Jiayi Liao commented on FLINK-10806: [~becket_qin] Firstly it's not only for a newly found partition

[jira] [Updated] (FLINK-13341) Some streamTableSink#consumeDataStream(DataStream) don't be implemented as returning the sink transformation DataStreamSink when using blink planner.

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13341: Priority: Critical (was: Major) > Some streamTableSink#consumeDataStream(DataStream) don't be

[jira] [Updated] (FLINK-12567) Rework DescriptorProperties to adapt unified DDL with clause and Descriptor key value pairs

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12567: Fix Version/s: (was: 1.9.0) 1.10.0 > Rework DescriptorProperties to adapt unified

[jira] [Updated] (FLINK-12567) Rework DescriptorProperties to adapt unified DDL with clause and Descriptor key value pairs

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12567: Affects Version/s: (was: 1.8.0) > Rework DescriptorProperties to adapt unified DDL with clause and

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

2019-07-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889874#comment-16889874 ] sunjincheng commented on FLINK-12249: - And I like the new update about workaround patch, in this way

[jira] [Updated] (FLINK-12557) Unify create table DDL with clause and connector descriptor keys

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12557: Fix Version/s: (was: 1.9.0) 1.10.0 > Unify create table DDL with clause and

[jira] [Updated] (FLINK-13105) Add documentation for blink planner's built-in functions

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13105: Priority: Critical (was: Major) > Add documentation for blink planner's built-in functions >

[jira] [Updated] (FLINK-12557) Unify create table DDL with clause and connector descriptor keys

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12557: Affects Version/s: (was: 1.8.0) > Unify create table DDL with clause and connector descriptor keys >

[jira] [Updated] (FLINK-13300) Add OverwritableTableSink bridge logic to flink planner

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13300: Fix Version/s: (was: 1.9.0) > Add OverwritableTableSink bridge logic to flink planner >

[jira] [Updated] (FLINK-13300) Add OverwritableTableSink bridge logic to flink planner

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13300: Affects Version/s: (was: 1.9.0) > Add OverwritableTableSink bridge logic to flink planner >

[GitHub] [flink] sunjincheng121 commented on issue #9141: [FLINK-12249][table] Fix type equivalence check problems for Window Aggregates

2019-07-21 Thread GitBox
sunjincheng121 commented on issue #9141: [FLINK-12249][table] Fix type equivalence check problems for Window Aggregates URL: https://github.com/apache/flink/pull/9141#issuecomment-513617339 Thanks for the update @hequn8128! I agree with @dawidwys @hequn8128 that this issue is not the

[jira] [Commented] (FLINK-13177) make FunctionCatalog able to reference functions across catalogs

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889870#comment-16889870 ] Jark Wu commented on FLINK-13177: - Hi [~phoenixjiangnan], do we need this in 1.9.0? > make

[jira] [Updated] (FLINK-11433) JOIN on a table having a column of type MULTISET gives a NPE

2019-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11433: Priority: Minor (was: Major) > JOIN on a table having a column of type MULTISET gives a NPE >

[GitHub] [flink] JingsongLi commented on issue #9181: [FLINK-13210][hive] Hive connector test should dependent on blink planner instead of legacy planner

2019-07-21 Thread GitBox
JingsongLi commented on issue #9181: [FLINK-13210][hive] Hive connector test should dependent on blink planner instead of legacy planner URL: https://github.com/apache/flink/pull/9181#issuecomment-513613380 @lirui-apache Thanks for your contribution, LGTM

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

2019-07-21 Thread GitBox
flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[jira] [Comment Edited] (FLINK-13231) Add a ratelimiter to pubsub source

2019-07-21 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889868#comment-16889868 ] Jiangjie Qin edited comment on FLINK-13231 at 7/22/19 1:54 AM: --- [~Xeli] 

[jira] [Commented] (FLINK-13231) Add a ratelimiter to pubsub source

2019-07-21 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889868#comment-16889868 ] Jiangjie Qin commented on FLINK-13231: -- [~Xeli] The rate limiter is actually a per consumer / per

[GitHub] [flink] KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305650403 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305650383 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305650367 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch

2019-07-21 Thread GitBox
KurtYoung commented on a change in pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#discussion_r305650341 ## File path:

[jira] [Commented] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889864#comment-16889864 ] Kurt Young commented on FLINK-13221: I changed this to 1.9.0's blocker, since this is a crucial one

[jira] [Updated] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13221: --- Fix Version/s: 1.10.0 1.9.0 > Blink planner should set ScheduleMode to >

[jira] [Updated] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13221: --- Priority: Blocker (was: Major) > Blink planner should set ScheduleMode to >

[jira] [Updated] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13221: --- Issue Type: Bug (was: Improvement) > Blink planner should set ScheduleMode to >

[jira] [Commented] (FLINK-13199) ARM support for Flink

2019-07-21 Thread wangxiyuan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889861#comment-16889861 ] wangxiyuan commented on FLINK-13199: Hi Chesnay:   It's similar. The difference is that which CI

[GitHub] [flink] TsReaper commented on a change in pull request #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, f

2019-07-21 Thread GitBox
TsReaper commented on a change in pull request #9139: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[GitHub] [flink] sjwiesman edited a comment on issue #9161: [FLINK-13262][docs] Add documentation for the new Table & SQL API type system

2019-07-21 Thread GitBox
sjwiesman edited a comment on issue #9161: [FLINK-13262][docs] Add documentation for the new Table & SQL API type system URL: https://github.com/apache/flink/pull/9161#issuecomment-513228516 @twalthr Looks good to me +1 This

[GitHub] [flink] tweise commented on issue #9187: [FLINK-12595][kinesis] Interrupt thread at right time to avoid deadlock

2019-07-21 Thread GitBox
tweise commented on issue #9187: [FLINK-12595][kinesis] Interrupt thread at right time to avoid deadlock URL: https://github.com/apache/flink/pull/9187#issuecomment-513580704 @flinkbot approve all This is an automated

  1   2   >