[jira] [Created] (FLINK-16112) KafkaDeserializationSchema#isEndOfStream is ill-defined

2020-02-16 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16112: --- Summary: KafkaDeserializationSchema#isEndOfStream is ill-defined Key: FLINK-16112 URL: https://issues.apache.org/jira/browse/FLINK-16112 Project: Flink

[GitHub] [flink] lirui-apache commented on issue #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i…

2020-02-16 Thread GitBox
lirui-apache commented on issue #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i… URL: https://github.com/apache/flink/pull/11093#issuecomment-586856518 @bowenli86 PR updated. Please have a look, thanks.

[GitHub] [flink] flinkbot commented on issue #11106: [FLINK-15708] Add MigrationVersion.v1_10

2020-02-16 Thread GitBox
flinkbot commented on issue #11106: [FLINK-15708] Add MigrationVersion.v1_10 URL: https://github.com/apache/flink/pull/11106#issuecomment-586854778 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We

[jira] [Commented] (FLINK-16111) Kubernetes deployment does not respect "taskmanager.cpu.cores".

2020-02-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038127#comment-17038127 ] Xintong Song commented on FLINK-16111: -- cc [~fly_in_gis] [~azagrebin] > Kubernetes deployment does

[GitHub] [flink] yanghua opened a new pull request #11106: [FLINK-15708] Add MigrationVersion.v1_10

2020-02-16 Thread GitBox
yanghua opened a new pull request #11106: [FLINK-15708] Add MigrationVersion.v1_10 URL: https://github.com/apache/flink/pull/11106 ## What is the purpose of the change *This pull request adds MigrationVersion.v1_10* ## Brief change log - *Add

[jira] [Created] (FLINK-16111) Kubernetes deployment does not respect "taskmanager.cpu.cores".

2020-02-16 Thread Xintong Song (Jira)
Xintong Song created FLINK-16111: Summary: Kubernetes deployment does not respect "taskmanager.cpu.cores". Key: FLINK-16111 URL: https://issues.apache.org/jira/browse/FLINK-16111 Project: Flink

[jira] [Updated] (FLINK-15708) Add MigrationVersion.v1_10

2020-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15708: --- Labels: pull-request-available (was: ) > Add MigrationVersion.v1_10 >

[GitHub] [flink] lirui-apache commented on a change in pull request #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i…

2020-02-16 Thread GitBox
lirui-apache commented on a change in pull request #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i… URL: https://github.com/apache/flink/pull/11093#discussion_r380019248 ## File path:

[GitHub] [flink] shuai-xu commented on a change in pull request #11068: [FLINK-15964] [cep] fix getting event of previous stage in notFollowedBy may throw exception bug

2020-02-16 Thread GitBox
shuai-xu commented on a change in pull request #11068: [FLINK-15964] [cep] fix getting event of previous stage in notFollowedBy may throw exception bug URL: https://github.com/apache/flink/pull/11068#discussion_r380015480 ## File path:

[GitHub] [flink] shuai-xu commented on a change in pull request #11068: [FLINK-15964] [cep] fix getting event of previous stage in notFollowedBy may throw exception bug

2020-02-16 Thread GitBox
shuai-xu commented on a change in pull request #11068: [FLINK-15964] [cep] fix getting event of previous stage in notFollowedBy may throw exception bug URL: https://github.com/apache/flink/pull/11068#discussion_r380015457 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r380005079 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r379996777 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r37056 ## File path:

[GitHub] [flink] shuai-xu commented on issue #11009: [Flink-15873] [cep] fix matches result not returned when existing earlier partial matches

2020-02-16 Thread GitBox
shuai-xu commented on issue #11009: [Flink-15873] [cep] fix matches result not returned when existing earlier partial matches URL: https://github.com/apache/flink/pull/11009#issuecomment-586844458 @dianfu Thank you very much for review. I didn't see any docs to say that this is a design.

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r380001446 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r38855 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r380009278 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r380004457 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r38717 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r380001365 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory

2020-02-16 Thread GitBox
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add Context to TableSourceFactory and TableSinkFactory URL: https://github.com/apache/flink/pull/11047#discussion_r380009489 ## File path:

[jira] [Updated] (FLINK-16106) Add PersistedList to the SDK

2020-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16106: --- Labels: pull-request-available (was: ) > Add PersistedList to the SDK >

[GitHub] [flink-statefun] tzulitai commented on issue #25: [FLINK-16106] Add PersistedList state primitive

2020-02-16 Thread GitBox
tzulitai commented on issue #25: [FLINK-16106] Add PersistedList state primitive URL: https://github.com/apache/flink-statefun/pull/25#issuecomment-586843804 cc @igalshilman This is an automated message from the Apache Git

[GitHub] [flink-statefun] tzulitai opened a new pull request #25: [FLINK-16106] Add PersistedList state primitive

2020-02-16 Thread GitBox
tzulitai opened a new pull request #25: [FLINK-16106] Add PersistedList state primitive URL: https://github.com/apache/flink-statefun/pull/25 This PR introduces a `PersistedList` state primitive to Stateful Functions. - 3491fea: Adds the user-facing SDK classes - 69e8ce6:

[jira] [Commented] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

2020-02-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038113#comment-17038113 ] Jark Wu commented on FLINK-16110: - {{TIMESTAMP(3) ROWTIME}} is the summary string of TimestampType which

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-16 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r379996093 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-16 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r379993355 ## File path:

[jira] [Commented] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

2020-02-16 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038101#comment-17038101 ] Zhenqiu Huang commented on FLINK-16005: --- [~fly_in_gis] Spark actually support the end to end

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-16 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r379991763 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-16 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r379991124 ## File path:

[GitHub] [flink] zhijiangW edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-16 Thread GitBox
zhijiangW edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-586823140 Let's uniform the new class naming and refactor the structure a bit firstly. -

[GitHub] [flink] zhijiangW commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-16 Thread GitBox
zhijiangW commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-586823140 Let's uniform the new class naming and refactor the structure a bit firstly. -

[GitHub] [flink] dianfu merged pull request #11103: [hotfix][docs] Regenerate documentation

2020-02-16 Thread GitBox
dianfu merged pull request #11103: [hotfix][docs] Regenerate documentation URL: https://github.com/apache/flink/pull/11103 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] dianfu commented on issue #11103: [hotfix][docs] Regenerate documentation

2020-02-16 Thread GitBox
dianfu commented on issue #11103: [hotfix][docs] Regenerate documentation URL: https://github.com/apache/flink/pull/11103#issuecomment-586818230 LGTM. This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

2020-02-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16110: --- Description: {{TIMESTAMP(3) *ROWTIME*}} is the string representation of {{TimestampType(true,

[jira] [Updated] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

2020-02-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16110: --- Description: {{TIMESTAMP(3) *ROWTIME*}} is the string representation of {{TimestampType(true,

[jira] [Updated] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

2020-02-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16110: --- Summary: LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

[jira] [Created] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and TIMESTAMP(3) *PROCTIME*

2020-02-16 Thread godfrey he (Jira)
godfrey he created FLINK-16110: -- Summary: LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and TIMESTAMP(3) *PROCTIME* Key: FLINK-16110 URL: https://issues.apache.org/jira/browse/FLINK-16110

[jira] [Assigned] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

2020-02-16 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15961: --- Assignee: Huang Xingbo > Introduce Python Physical Correlate RelNodes which are

[jira] [Comment Edited] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038086#comment-17038086 ] Xintong Song edited comment on FLINK-15959 at 2/17/20 4:18 AM: --- bq. How

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038086#comment-17038086 ] Xintong Song commented on FLINK-15959: -- bq. How about put it into ClusterOptions, start with

[GitHub] [flink] flinkbot commented on issue #11105: [FLINK-16109][python] Move the Python scalar operators and table operators to separate package

2020-02-16 Thread GitBox
flinkbot commented on issue #11105: [FLINK-16109][python] Move the Python scalar operators and table operators to separate package URL: https://github.com/apache/flink/pull/11105#issuecomment-586810362 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Commented] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

2020-02-16 Thread Manas Kale (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038084#comment-17038084 ] Manas Kale commented on FLINK-6726: --- Hi, is there any progress on this issue? I have a similar use

[jira] [Commented] (FLINK-16058) Could not start TaskManager in flink 1.10.0

2020-02-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038083#comment-17038083 ] Yang Wang commented on FLINK-16058: --- [~blablabla123] Flink depends the commons-cli with version 1.3.1.

[jira] [Updated] (FLINK-16109) Move the Python scalar operators and table operators to separate package

2020-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16109: --- Labels: pull-request-available (was: ) > Move the Python scalar operators and table

[GitHub] [flink] HuangXingBo opened a new pull request #11105: [FLINK-16109][python] Move the Python scalar operators and table operators to separate package

2020-02-16 Thread GitBox
HuangXingBo opened a new pull request #11105: [FLINK-16109][python] Move the Python scalar operators and table operators to separate package URL: https://github.com/apache/flink/pull/11105 ## What is the purpose of the change *This pull request will move the Python scalar operators

[GitHub] [flink] HuangXingBo commented on issue #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

2020-02-16 Thread GitBox
HuangXingBo commented on issue #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#issuecomment-586809475 > @HuangXingBo Thanks a lot for the

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379227379 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379227379 ## File path:

[jira] [Created] (FLINK-16109) Move the Python scalar operators and table operators to separate package

2020-02-16 Thread Dian Fu (Jira)
Dian Fu created FLINK-16109: --- Summary: Move the Python scalar operators and table operators to separate package Key: FLINK-16109 URL: https://issues.apache.org/jira/browse/FLINK-16109 Project: Flink

[jira] [Assigned] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-02-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16108: --- Assignee: Jark Wu > StreamSQLExample is failed if running in blink planner >

[GitHub] [flink] bowenli86 commented on a change in pull request #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i…

2020-02-16 Thread GitBox
bowenli86 commented on a change in pull request #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i… URL: https://github.com/apache/flink/pull/11093#discussion_r379973331 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i…

2020-02-16 Thread GitBox
bowenli86 commented on a change in pull request #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i… URL: https://github.com/apache/flink/pull/11093#discussion_r379973331 ## File path:

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038072#comment-17038072 ] YufeiLiu commented on FLINK-15959: -- [~xintongsong]Got it, check total Executors less than maximum

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038071#comment-17038071 ] YufeiLiu commented on FLINK-15959: -- [~xintongsong] Got it, check total Executors less than maximum

[jira] [Issue Comment Deleted] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Comment: was deleted (was: [~xintongsong] Got it, check total Executors less than maximum before

[jira] [Created] (FLINK-16108) StreamSQLExample is failed if running in blink planner

2020-02-16 Thread Jark Wu (Jira)
Jark Wu created FLINK-16108: --- Summary: StreamSQLExample is failed if running in blink planner Key: FLINK-16108 URL: https://issues.apache.org/jira/browse/FLINK-16108 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on issue #11104: [FLINK-16051] make Overview-Subtasks ID starts from 1

2020-02-16 Thread GitBox
flinkbot commented on issue #11104: [FLINK-16051] make Overview-Subtasks ID starts from 1 URL: https://github.com/apache/flink/pull/11104#issuecomment-586800028 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

2020-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16051: --- Labels: pull-request-available (was: ) > Subtask ID in Overview-Subtasks should start from

[GitHub] [flink] buptljy opened a new pull request #11104: [FLINK-16051] make Overview-Subtasks ID starts from 1

2020-02-16 Thread GitBox
buptljy opened a new pull request #11104: [FLINK-16051] make Overview-Subtasks ID starts from 1 URL: https://github.com/apache/flink/pull/11104 ## What is the purpose of the change The subtask id in Subtask UI starts from 0 which is not consistent with other ID in backpressure /

[jira] [Updated] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

2020-02-16 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-16051: --- Description: The subtask id in Subtask UI starts from 0 which is not consistent with other ID in

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379968783 ## File path:

[jira] [Updated] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

2020-02-16 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-16051: --- Summary: Subtask ID in Overview-Subtasks should start from 1 (was: Subtask id in Checkpoint UI not

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379968783 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379968881 ## File path:

[jira] [Updated] (FLINK-16051) Subtask id in Checkpoint UI not consistent with Subtask UI

2020-02-16 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16051: - Issue Type: Improvement (was: Bug) > Subtask id in Checkpoint UI not consistent with Subtask UI >

[jira] [Assigned] (FLINK-16051) Subtask id in Checkpoint UI not consistent with Subtask UI

2020-02-16 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-16051: Assignee: Jiayi Liao > Subtask id in Checkpoint UI not consistent with Subtask UI >

[jira] [Assigned] (FLINK-16082) Translate "Overview" page of "Streaming Concepts" into Chinese

2020-02-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16082: --- Assignee: Benchao Li > Translate "Overview" page of "Streaming Concepts" into Chinese >

[jira] [Assigned] (FLINK-16081) Translate "Overview" page of "Table API & SQL" into Chinese

2020-02-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16081: --- Assignee: Benchao Li > Translate "Overview" page of "Table API & SQL" into Chinese >

[GitHub] [flink] hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379951593 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -168,6 +168,14 @@

[GitHub] [flink] hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379951593 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -168,6 +168,14 @@

[GitHub] [flink] flinkbot commented on issue #11103: [hotfix][docs] Regenerate documentation

2020-02-16 Thread GitBox
flinkbot commented on issue #11103: [hotfix][docs] Regenerate documentation URL: https://github.com/apache/flink/pull/11103#issuecomment-586789425 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] [flink] HuangXingBo opened a new pull request #11103: [hotfix][docs] Regenerate documentation

2020-02-16 Thread GitBox
HuangXingBo opened a new pull request #11103: [hotfix][docs] Regenerate documentation URL: https://github.com/apache/flink/pull/11103 ## What is the purpose of the change *Regenerate documentation of k8 configuration* ## Brief change log -

[GitHub] [flink] hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379951593 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -168,6 +168,14 @@

[jira] [Commented] (FLINK-16081) Translate "Overview" page of "Table API & SQL" into Chinese

2020-02-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038038#comment-17038038 ] Benchao Li commented on FLINK-16081: [~jark] I can help translate this one. > Translate "Overview"

[jira] [Commented] (FLINK-16082) Translate "Overview" page of "Streaming Concepts" into Chinese

2020-02-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038040#comment-17038040 ] Benchao Li commented on FLINK-16082: [~jark] I can help translate this one. > Translate "Overview"

[GitHub] [flink] flinkbot commented on issue #11102: [FLINK-16084][docs] Translate /dev/table/streaming/time_attributes.zh.md

2020-02-16 Thread GitBox
flinkbot commented on issue #11102: [FLINK-16084][docs] Translate /dev/table/streaming/time_attributes.zh.md URL: https://github.com/apache/flink/pull/11102#issuecomment-586788166 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-16084) Translate "Time Attributes" page of "Streaming Concepts" into Chinese

2020-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16084: --- Labels: pull-request-available (was: ) > Translate "Time Attributes" page of "Streaming

[GitHub] [flink] libenchao opened a new pull request #11102: [FLINK-16084][docs] Translate /dev/table/streaming/time_attributes.zh.md

2020-02-16 Thread GitBox
libenchao opened a new pull request #11102: [FLINK-16084][docs] Translate /dev/table/streaming/time_attributes.zh.md URL: https://github.com/apache/flink/pull/11102 ## What is the purpose of the change Translate /dev/table/streaming/time_attributes.zh.md ## Brief

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038036#comment-17038036 ] Xintong Song commented on FLINK-15959: -- Minor: I would suggest to replace

[jira] [Assigned] (FLINK-16088) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

2020-02-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16088: --- Assignee: QinChao > Translate "Query Configuration" page of "Streaming Concepts" into Chinese >

[jira] [Commented] (FLINK-16088) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

2020-02-16 Thread QinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038034#comment-17038034 ] QinChao commented on FLINK-16088: - Hi Jark, can you assign this to me? I will finish this as soon as

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038027#comment-17038027 ] Xintong Song commented on FLINK-15959: -- [~liuyufei], thanks for updating the proposal. Regarding

[GitHub] [flink] hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-16 Thread GitBox
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379951593 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -168,6 +168,14 @@

[jira] [Assigned] (FLINK-16106) Add PersistedList to the SDK

2020-02-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-16106: --- Assignee: Tzu-Li (Gordon) Tai > Add PersistedList to the SDK >

[jira] [Created] (FLINK-16107) github link on statefun.io should point to https://github.com/apache/flink-statefun

2020-02-16 Thread Bowen Li (Jira)
Bowen Li created FLINK-16107: Summary: github link on statefun.io should point to https://github.com/apache/flink-statefun Key: FLINK-16107 URL: https://issues.apache.org/jira/browse/FLINK-16107 Project:

[GitHub] [flink] lonerzzz commented on issue #11042: FLINK-15744 Some TaskManager Task exceptions are logged as info

2020-02-16 Thread GitBox
lonerzzz commented on issue #11042: FLINK-15744 Some TaskManager Task exceptions are logged as info URL: https://github.com/apache/flink/pull/11042#issuecomment-586757018 @zentol @aljoscha Upon reading the issue #5399, it didn't seem that any firm position was taken on the issue. The

[GitHub] [flink] zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-16 Thread GitBox
zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379933502 ## File path: flink-ml-parent/flink-ml-lib/pom.xml ## @@ -57,4 +57,30 @@ under the

[GitHub] [flink] zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-16 Thread GitBox
zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379933420 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -168,6 +168,14 @@

[jira] [Created] (FLINK-16106) Add PersistedList to the SDK

2020-02-16 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16106: Summary: Add PersistedList to the SDK Key: FLINK-16106 URL: https://issues.apache.org/jira/browse/FLINK-16106 Project: Flink Issue Type: Task

[jira] [Comment Edited] (FLINK-13978) Switch to Azure Pipelines as a CI tool for Flink

2020-02-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037916#comment-17037916 ] Robert Metzger edited comment on FLINK-13978 at 2/16/20 6:59 PM: -

[jira] [Reopened] (FLINK-13978) Switch to Azure Pipelines as a CI tool for Flink

2020-02-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-13978: > Switch to Azure Pipelines as a CI tool for Flink >

[jira] [Resolved] (FLINK-13978) Switch to Azure Pipelines as a CI tool for Flink

2020-02-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-13978. Fix Version/s: 1.11.0 Resolution: Fixed Resolved in "master" in

[GitHub] [flink] asfgit closed pull request #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-16 Thread GitBox
asfgit closed pull request #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k…

2020-02-16 Thread GitBox
flinkbot edited a comment on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k… URL: https://github.com/apache/flink/pull/11101#issuecomment-586719516 ## CI report: * 994704592f9aa725e5370210c6df1c6de0c2ddc8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-16 Thread GitBox
flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#issuecomment-580319851 ## CI report: * 322bf186867ed0ec1a867ba7919e39e3c437aba0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-16 Thread GitBox
flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#issuecomment-580319851 ## CI report: * 322bf186867ed0ec1a867ba7919e39e3c437aba0 Travis:

[jira] [Assigned] (FLINK-16070) Blink planner can not extract correct unique key for UpsertStreamTableSink

2020-02-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16070: --- Assignee: godfrey he > Blink planner can not extract correct unique key for UpsertStreamTableSink

[GitHub] [flink] flinkbot commented on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k…

2020-02-16 Thread GitBox
flinkbot commented on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k… URL: https://github.com/apache/flink/pull/11101#issuecomment-586719516 ## CI report: * 994704592f9aa725e5370210c6df1c6de0c2ddc8 UNKNOWN Bot commands The

[jira] [Closed] (FLINK-15702) Make sqlClient classloader aligned with other components

2020-02-16 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-15702. - Assignee: liupengcheng Resolution: Fixed master via 946d25ea9c912a1c190540e74dfd28cd9e9bede6 >

  1   2   >