[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-03-02 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_r386301054 ## 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-03-02 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_r386300489 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

2020-03-02 Thread GitBox
TisonKun commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#discussion_r386300563 ## File path:

[jira] [Created] (FLINK-16370) YARNHighAvailabilityITCase fails on JDK11 nightly test: NoSuchMethodError: org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.server.quorum.flexible.QuorumMaj

2020-03-02 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-16370: -- Summary: YARNHighAvailabilityITCase fails on JDK11 nightly test: NoSuchMethodError: org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.server.quorum.flexible.QuorumMaj Key: FLINK-16370

[jira] [Resolved] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR

2020-03-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16360. -- Fix Version/s: 1.11.0 Resolution: Fixed > connector on hive 2.0.1 don't support type

[jira] [Commented] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR

2020-03-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048981#comment-17048981 ] Jingsong Lee commented on FLINK-16360: -- master: d9b9aad6c92bc4f65bae04821a041082b3ed6cf8

[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-03-02 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_r386295617 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink URL: https://github.com/apache/flink/pull/11279#issuecomment-593309320 ## CI report: * 4b6685acc5ab65537e3bd0e9dbd53fef52126e85 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-591843120 ## CI report: * 0017b8a8930024d0e9ce3355d050565a5007831d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11248: [FLINK-16299] Release containers recovered from previous attempt in w…

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11248: [FLINK-16299] Release containers recovered from previous attempt in w… URL: https://github.com/apache/flink/pull/11248#issuecomment-592302068 ## CI report: * b61c045eddf32b77b81238ed06cbd961351f2e3b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#issuecomment-587365636 ## CI report: * 68fbf9d61e9c89eb323d7eb5cc08d18f9f852065 UNKNOWN *

[GitHub] [flink] zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593317405 @flinkbot run travis This is an automated message from

[GitHub] [flink] zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593317565 @flinkbot run azure This is an automated message from

[GitHub] [flink] zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593316748 > @zhengcanbin Thanks a lot for addressing the comments. I have gone though again and the changes look really good to

[GitHub] [flink] lirui-apache commented on issue #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing

2020-03-02 Thread GitBox
lirui-apache commented on issue #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing URL: https://github.com/apache/flink/pull/11275#issuecomment-593314494 Thanks @JingsongLi for the PR. I left some minor comments. Also noted we're doing some mem copy in

[GitHub] [flink] zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593314187 > ``` > echo 'stop' | ./bin/kubernetes-session.sh -Dkubernetes.cluster-id=flink-native-k8s-session-1

[GitHub] [flink] zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#discussion_r386286836 ## File path:

[GitHub] [flink] jinglining removed a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-02 Thread GitBox
jinglining removed a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-593246362 @flinkbot run travis This is an

[GitHub] [flink] zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#discussion_r386286390 ## File path:

[GitHub] [flink] jinglining removed a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-02 Thread GitBox
jinglining removed a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-593246398 @flinkbot run azure This is an

[GitHub] [flink] jinglining commented on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-02 Thread GitBox
jinglining commented on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-593313306 @flinkbot run azure This is an automated

[GitHub] [flink] lirui-apache commented on a change in pull request #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing

2020-03-02 Thread GitBox
lirui-apache commented on a change in pull request #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing URL: https://github.com/apache/flink/pull/11275#discussion_r386270935 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing

2020-03-02 Thread GitBox
lirui-apache commented on a change in pull request #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing URL: https://github.com/apache/flink/pull/11275#discussion_r386279233 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing

2020-03-02 Thread GitBox
lirui-apache commented on a change in pull request #11275: [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing URL: https://github.com/apache/flink/pull/11275#discussion_r386272414 ## File path:

[GitHub] [flink] flinkbot commented on issue #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink

2020-03-02 Thread GitBox
flinkbot commented on issue #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink URL: https://github.com/apache/flink/pull/11279#issuecomment-593309320 ## CI report: * 4b6685acc5ab65537e3bd0e9dbd53fef52126e85 UNKNOWN Bot commands The

[GitHub] [flink] StephanEwen commented on issue #11271: [hotfix][table] Remove unused import in DataStreamConversions

2020-03-02 Thread GitBox
StephanEwen commented on issue #11271: [hotfix][table] Remove unused import in DataStreamConversions URL: https://github.com/apache/flink/pull/11271#issuecomment-593304598 Looks good, merging this, thanks! This is an

[GitHub] [flink] StephanEwen commented on issue #11278: [hotfix] [docs] fix the mismatch between java and scala examples

2020-03-02 Thread GitBox
StephanEwen commented on issue #11278: [hotfix] [docs] fix the mismatch between java and scala examples URL: https://github.com/apache/flink/pull/11278#issuecomment-593302049 Thanks for fixing this. Merging... This is an

[GitHub] [flink] flinkbot edited a comment on issue #11278: [hotfix] [docs] fix the mismatch between java and scala examples

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11278: [hotfix] [docs] fix the mismatch between java and scala examples URL: https://github.com/apache/flink/pull/11278#issuecomment-593259962 ## CI report: * d51ad7d8b1d185562d1e431e2db01621fc9dfa50 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#issuecomment-587365636 ## CI report: * 68fbf9d61e9c89eb323d7eb5cc08d18f9f852065 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 50f940fb6c519f0ea56c5d6c0c0e2f72ef70d9f7 Travis:

[GitHub] [flink] StephanEwen commented on a change in pull request #11235: [FLINK-15980] fix that the notFollowedBy in the end of GroupPattern may be ignored

2020-03-02 Thread GitBox
StephanEwen commented on a change in pull request #11235: [FLINK-15980] fix that the notFollowedBy in the end of GroupPattern may be ignored URL: https://github.com/apache/flink/pull/11235#discussion_r386271750 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #11235: [FLINK-15980] fix that the notFollowedBy in the end of GroupPattern may be ignored

2020-03-02 Thread GitBox
StephanEwen commented on a change in pull request #11235: [FLINK-15980] fix that the notFollowedBy in the end of GroupPattern may be ignored URL: https://github.com/apache/flink/pull/11235#discussion_r386271501 ## File path:

[GitHub] [flink] flinkbot commented on issue #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink

2020-03-02 Thread GitBox
flinkbot commented on issue #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink URL: https://github.com/apache/flink/pull/11279#issuecomment-593300301 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] godfreyhe opened a new pull request #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink

2020-03-02 Thread GitBox
godfreyhe opened a new pull request #11279: [FLINK-16362] [table] Remove deprecated method in StreamTableSink URL: https://github.com/apache/flink/pull/11279 ## What is the purpose of the change

[GitHub] [flink] JingsongLi merged pull request #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type

2020-03-02 Thread GitBox
JingsongLi merged pull request #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type URL: https://github.com/apache/flink/pull/11277 This is an automated message from the Apache Git Service. To

[GitHub] [flink] JingsongLi commented on issue #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type

2020-03-02 Thread GitBox
JingsongLi commented on issue #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type URL: https://github.com/apache/flink/pull/11277#issuecomment-593294545 Unrelated travis fail: https://issues.apache.org/jira/browse/FLINK-16368

[GitHub] [flink] flinkbot edited a comment on issue #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type URL: https://github.com/apache/flink/pull/11277#issuecomment-593254512 ## CI report: * 8fb0e375ba23258bb6425dee43640bffc8bf75c0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 50f940fb6c519f0ea56c5d6c0c0e2f72ef70d9f7 Travis:

[GitHub] [flink] StephanEwen commented on issue #11234: [FLINK-2336][api] Fix ArrayIndexOufOBoundsException in TypeExtractor when mapping

2020-03-02 Thread GitBox
StephanEwen commented on issue #11234: [FLINK-2336][api] Fix ArrayIndexOufOBoundsException in TypeExtractor when mapping URL: https://github.com/apache/flink/pull/11234#issuecomment-593293907 This looks good, thank you for addressing this. Merging this...

[GitHub] [flink] flinkbot edited a comment on issue #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#issuecomment-587365636 ## CI report: * 68fbf9d61e9c89eb323d7eb5cc08d18f9f852065 UNKNOWN *

[jira] [Commented] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

2020-03-02 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048884#comment-17048884 ] Kostas Kloudas commented on FLINK-15805: This is the new issue

[jira] [Created] (FLINK-16369) Allow the StreamingFileSink to restore from a previous (old) savepoint.

2020-03-02 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-16369: -- Summary: Allow the StreamingFileSink to restore from a previous (old) savepoint. Key: FLINK-16369 URL: https://issues.apache.org/jira/browse/FLINK-16369 Project:

[jira] [Comment Edited] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

2020-03-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048882#comment-17048882 ] Zhu Zhu edited comment on FLINK-16357 at 3/2/20 8:54 AM: - I just realized that

[jira] [Closed] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

2020-03-02 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-15805. -- Resolution: Incomplete > StreamingFileSink on S3 fails when firing processing time timers

[jira] [Commented] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

2020-03-02 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048883#comment-17048883 ] Kostas Kloudas commented on FLINK-15805: I will close this issue, as the behaviour of failing

[jira] [Commented] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

2020-03-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048882#comment-17048882 ] Zhu Zhu commented on FLINK-16357: - In the case of a global failure, what's the difference between *

[jira] [Commented] (FLINK-15794) Rethink default value of kubernetes.container.image

2020-03-02 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048881#comment-17048881 ] Yang Wang commented on FLINK-15794: --- [~nielsbasjes] [~trohrmann] I tend to use the fixed the version

[GitHub] [flink] zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#discussion_r386258439 ## File path:

[GitHub] [flink] zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#discussion_r386258439 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type URL: https://github.com/apache/flink/pull/11277#issuecomment-593254512 ## CI report: * 8fb0e375ba23258bb6425dee43640bffc8bf75c0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212 ## CI report: * e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 50f940fb6c519f0ea56c5d6c0c0e2f72ef70d9f7 Travis:

[jira] [Created] (FLINK-16368) ZooKeeperHighAvailabilityITCase test fail

2020-03-02 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16368: Summary: ZooKeeperHighAvailabilityITCase test fail Key: FLINK-16368 URL: https://issues.apache.org/jira/browse/FLINK-16368 Project: Flink Issue Type: Bug

[GitHub] [flink] zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

2020-03-02 Thread GitBox
zhengcanbin commented on a change in pull request #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#discussion_r386255489 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-02 Thread GitBox
wangyang0918 commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r386237469 ## File path: docs/ops/deployment/kubernetes.md ## @@ -112,7 +112,7 @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-02 Thread GitBox
wangyang0918 commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r386253579 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-03-02 Thread GitBox
wangyang0918 commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#discussion_r386252191 ## File path: docs/ops/deployment/kubernetes.md ## @@ -112,7 +112,7 @@

[GitHub] [flink] libenchao commented on a change in pull request #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-02 Thread GitBox
libenchao commented on a change in pull request #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#discussion_r386253447 ## File path:

[jira] [Commented] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

2020-03-02 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048870#comment-17048870 ] Stephan Ewen commented on FLINK-16357: -- Yes, {{OperatorCoordinator#resetToCheckpoint(...)}} is

[GitHub] [flink] lirui-apache commented on a change in pull request #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type

2020-03-02 Thread GitBox
lirui-apache commented on a change in pull request #11277: [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type URL: https://github.com/apache/flink/pull/11277#discussion_r386251018 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386250792 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386248882 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386248066 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386247170 ## File path:

[GitHub] [flink] StephanEwen commented on issue #11196: [FLINK-16246][connector kinesis] Exclude AWS SDK MBean registry from Kinesis build

2020-03-02 Thread GitBox
StephanEwen commented on issue #11196: [FLINK-16246][connector kinesis] Exclude AWS SDK MBean registry from Kinesis build URL: https://github.com/apache/flink/pull/11196#issuecomment-593276364 @guoweiM I was just trying to figure out whether I understood you correctly.

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 70303310b9062e83705e8d3536660784bf963cca Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212 ## CI report: * e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese URL: https://github.com/apache/flink/pull/11168#issuecomment-589576910 ## CI report: * 76146c2111a47b68765168064b4d1dd90448789c Travis:

[jira] [Updated] (FLINK-16366) Introduce executeStatement method in TableEnvironment

2020-03-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16366: --- Description: This issue aims to introduce {{executeStatement}} which synchronously executes the

[jira] [Updated] (FLINK-16367) Introduce createDmlBatch method in TableEnvironment

2020-03-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16367: --- Description: As we deprecates {{execute}} method and {{explain}} method because of buffering

[jira] [Updated] (FLINK-16367) Introduce createDmlBatch method in TableEnvironment

2020-03-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16367: --- Description: As we deprecates {{execute}} method and {{explain}} method because of buffering

[jira] [Updated] (FLINK-16366) Introduce executeStatement method in TableEnvironment

2020-03-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16366: --- Description: This issue aims to introduce {{executeStatement}} which synchronously executes the

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386242695 ## File path:

[jira] [Created] (FLINK-16367) Introduce createDmlBatch method in TableEnvironment

2020-03-02 Thread godfrey he (Jira)
godfrey he created FLINK-16367: -- Summary: Introduce createDmlBatch method in TableEnvironment Key: FLINK-16367 URL: https://issues.apache.org/jira/browse/FLINK-16367 Project: Flink Issue Type:

[GitHub] [flink] hequn8128 commented on a change in pull request #11242: [FLINK-16007][table-planner][table-planner-blink][python] Add PythonCorrelateSplitRule to push down the Java Calls contained in

2020-03-02 Thread GitBox
hequn8128 commented on a change in pull request #11242: [FLINK-16007][table-planner][table-planner-blink][python] Add PythonCorrelateSplitRule to push down the Java Calls contained in Python Correlate node URL: https://github.com/apache/flink/pull/11242#discussion_r386241502 ##

[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-03-02 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_r386241044 ## File path:

[jira] [Created] (FLINK-16366) Introduce executeStatement method in TableEnvironment

2020-03-02 Thread godfrey he (Jira)
godfrey he created FLINK-16366: -- Summary: Introduce executeStatement method in TableEnvironment Key: FLINK-16366 URL: https://issues.apache.org/jira/browse/FLINK-16366 Project: Flink Issue

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386238064 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386237370 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386235093 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386237340 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386240508 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

2020-03-02 Thread GitBox
JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386238978 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11278: [hotfix] [docs] fix the mismatch between java and scala examples

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11278: [hotfix] [docs] fix the mismatch between java and scala examples URL: https://github.com/apache/flink/pull/11278#issuecomment-593259962 ## CI report: * d51ad7d8b1d185562d1e431e2db01621fc9dfa50 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

2020-03-02 Thread GitBox
flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 70303310b9062e83705e8d3536660784bf963cca Travis:

<    1   2   3   4   5   6