flinkbot commented on issue #9192: [FLINK-12749] [docs] [examples] Initial
Version of Flink Cluster Playground
URL: https://github.com/apache/flink/pull/9192#issuecomment-513664474
## CI report:
* 74a251ff6fa8c2ff9b13ae5869aacf90146024aa : FAILURE
[Build](https://travis-ci.com/flink
flinkbot commented on issue #9193: [FLINK-13318][table-planner-blink] Fix Blink
planner tests failing on Scala 2.12
URL: https://github.com/apache/flink/pull/9193#issuecomment-513664341
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
beyond1920 opened a new pull request #9193: [FLINK-13318][table-planner-blink]
Fix Blink planner tests failing on Scala 2.12
URL: https://github.com/apache/flink/pull/9193
## What is the purpose of the change
Fix Blink planner tests failing on Scala 2.12. Some query plan in Scala 2.1
[
https://issues.apache.org/jira/browse/FLINK-13318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13318:
---
Labels: pull-request-available (was: )
> Blink planner tests failing on Scala 2.12
> --
flinkbot commented on issue #9192: [FLINK-12749] [docs] [examples] Initial
Version of Flink Cluster Playground
URL: https://github.com/apache/flink/pull/9192#issuecomment-513663619
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
[
https://issues.apache.org/jira/browse/FLINK-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-13349:
-
Priority: Blocker (was: Major)
> Flink sinks should implement consumeDataStream instead of emit
knaufk opened a new pull request #1: [FLINK-12749] [playgrounds] initial
version of flink-cluster-playground
URL: https://github.com/apache/flink-playgrounds/pull/1
see https://github.com/apache/flink/pull/9192
This is an aut
[
https://issues.apache.org/jira/browse/FLINK-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12749:
---
Labels: pull-request-available (was: )
> Getting Started - Docker Playgrounds - Flink Clust
Jingsong Lee created FLINK-13349:
Summary: Flink sinks should implement consumeDataStream instead of
emitDataStream
Key: FLINK-13349
URL: https://issues.apache.org/jira/browse/FLINK-13349
Project: Fli
knaufk opened a new pull request #9192: [FLINK-12749] [docs] [examples] Initial
Version of Flink Cluster Playground
URL: https://github.com/apache/flink/pull/9192
## Purpose of this Change
Adds Flink Cluster Playground to Getting Started section of the documenation
## Brief ch
[
https://issues.apache.org/jira/browse/FLINK-13284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-13284.
-
Resolution: Fixed
Fix Version/s: 1.10.0
Fixed in 1.10.0: 6961d9bad804543a939be231dac36011d5b38c4a
[
https://issues.apache.org/jira/browse/FLINK-13284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13284:
---
Labels: pull-request-available (was: )
> Correct some builtin functions' return type infere
wuchong closed pull request #9146: [FLINK-13284] [table-planner-blink] Correct
some builtin functions' r…
URL: https://github.com/apache/flink/pull/9146
This is an automated message from the Apache Git Service.
To respond to
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: https://github.com/apache/flink
[
https://issues.apache.org/jira/browse/FLINK-13075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-13075:
---
Assignee: Caizhi Weng (was: godfrey he)
> Project pushdown rule shouldn't require the TableSource
[
https://issues.apache.org/jira/browse/FLINK-13075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13075:
Priority: Blocker (was: Major)
> Project pushdown rule shouldn't require the TableSource return a modifie
[
https://issues.apache.org/jira/browse/FLINK-13075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13075:
Fix Version/s: 1.10.0
1.9.0
> Project pushdown rule shouldn't require the TableSource r
[
https://issues.apache.org/jira/browse/FLINK-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-13348:
Summary: ProjectableTableSource is not supported by blink-planner correctly
(was: Table schema is
[
https://issues.apache.org/jira/browse/FLINK-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-13348:
---
Assignee: Caizhi Weng
> Table schema is modified when pushing projection to table source
>
[
https://issues.apache.org/jira/browse/FLINK-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889940#comment-16889940
]
Jingsong Lee commented on FLINK-13348:
--
[~TsReaper] How about rename to
Projectabl
[
https://issues.apache.org/jira/browse/FLINK-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-13348:
Issue Type: Sub-task (was: Test)
Parent: FLINK-13285
> Table schema is modified when push
Caizhi Weng created FLINK-13348:
---
Summary: Table schema is modified when pushing projection to table
source
Key: FLINK-13348
URL: https://issues.apache.org/jira/browse/FLINK-13348
Project: Flink
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
[Build](https://travis-ci.com/flink-ci/f
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 : FAIL
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
[Build](https:
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
[B
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
@fli
[
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 and
[
https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889932#comment-16889932
]
Jiayi Liao commented on FLINK-10806:
[~becket_qin] Thanks for pointing this out. Wha
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 `TypeSerializerUprgadeTest
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:
* 370270831
[
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): 752e7ae6a434
[
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)
> Add
[
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):
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
[Build](h
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
[Build](https://travis-ci.com/flink-ci/f
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:
* 6afb0645f386b618ddc1e9
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: https://github.com/apache/flink
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 Apach
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889905#comment-16889905
]
TisonKun commented on FLINK-10052:
--
Yes. LeaderContender(jm, rm, dispatcher, etc.) in F
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
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
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 i
[
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
> --
>
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889901#comment-16889901
]
Quan Shi commented on FLINK-10052:
--
hi [~Tison]
Sounds reasonable. Elect a new leader
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.
--
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: https://github.com/apache/flink
[
https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889895#comment-16889895
]
Jeff Yang commented on FLINK-13344:
---
I got it . Thanks [~jark]
> Translate "How to Co
[
https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889894#comment-16889894
]
WangHengWei commented on FLINK-13344:
-
[~jark], thanks very much. I'm gonna do it.:D
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889893#comment-16889893
]
TisonKun commented on FLINK-10052:
--
[~quan]
Supposed you have jm-1 and jm-2 execute th
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
[Build](https:
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
---
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 path
[
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 : UnsupportedOperationExcept
[
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
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889630#comment-16889630
]
Xintong Song edited comment on FLINK-13242 at 7/22/19 3:45 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-13318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889891#comment-16889891
]
Jark Wu commented on FLINK-13318:
-
+1 for this approach!
> Blink planner tests failing
[
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
> "JDBCUpsertTa
[
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
> "JDBCUpsertTab
[
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
> "JDB
[
https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889890#comment-16889890
]
Jark Wu commented on FLINK-13289:
-
Thanks [~kakachen] for digging into this. This is def
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: https://github.com/apache/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
URL: https://github.com/apache/flink/pull/9056#discussion_r305664376
##
File path:
flink-table/flink-table-planner/src/m
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 Typ
[
https://issues.apache.org/jira/browse/FLINK-13344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889888#comment-16889888
]
Jark Wu commented on FLINK-13344:
-
Hi [~highfei2...@126.com], this is not a duplicate is
[
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.
> ---
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889887#comment-16889887
]
Quan Shi commented on FLINK-10052:
--
Hi, all.
What if the Job Manager works fine except
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 path
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 path
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
Affect
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 thr
[
https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889886#comment-16889886
]
Jiangjie Qin commented on FLINK-10806:
--
[~wind_ljy] Thanks for the context. Yes, I
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:
* 3702708314892325
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
[Build](https:
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
[
https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889884#comment-16889884
]
Liya Fan commented on FLINK-13221:
--
[~ykt836]. Sure. Thanks a lot.
> Blink planner sho
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
[Build](h
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
M
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 Serv
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.
--
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 import
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:
* 6afb0645f386b618ddc1e9
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:
flink-runtime/src/main/java/org/apache/flink/runti
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:
flink-runt
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:
flink-runt
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:
flink-stre
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 th
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:
flink-runt
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:
flink-runtime/src/test/java/org/apache/flink/runti
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:
flink-runtime/src/test/java/org/apache/flink/runti
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:
flink-runtime/src/test/java/org/apache/flink/runti
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
tabl
[
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 th
[
https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889876#comment-16889876
]
Jiayi Liao commented on FLINK-10806:
[~becket_qin] Firstly it's not only for a newly
[
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 implemented
[
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 D
[
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 Des
[
https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889874#comment-16889874
]
sunjincheng commented on FLINK-12249:
-
And I like the new update about workaround pa
[
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 connect
[
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
>
1 - 100 of 190 matches
Mail list logo
