[GitHub] [flink] flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien…

flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien… URL: https://github.com/apache/flink/pull/11788#issuecomment-615123775 ## CI report: * 149e776d00f9ae15493047dd7165a45c8b1da207 Travis:

[jira] [Closed] (FLINK-16411) Maven central connection timeouts on Azure Pipelines

[ https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16411. -- Resolution: Fixed > Maven central connection timeouts on Azure Pipelines >

[jira] [Commented] (FLINK-16411) Maven central connection timeouts on Azure Pipelines

[ https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086312#comment-17086312 ] Robert Metzger commented on FLINK-16411: For the self-hosted machines in AliCloud, we now use a

[GitHub] [flink] rmetzger closed pull request #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

rmetzger closed pull request #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rmetzger commented on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

rmetzger commented on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#issuecomment-615574269 Thanks for the review. Merging This is an automated

[GitHub] [flink] JingsongLi commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

JingsongLi commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410641117 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

JingsongLi commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410640644 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

JingsongLi commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410636158 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

lirui-apache commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410616395 ## File path:

[jira] [Resolved] (FLINK-17142) Bump ORC version

[ https://issues.apache.org/jira/browse/FLINK-17142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-17142. -- Resolution: Fixed master: f960a2ecdc69575b9f4e0e5ca397708878091a48 > Bump ORC version >

[GitHub] [flink] JingsongLi merged pull request #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

JingsongLi merged pull request #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] lirui-apache commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

lirui-apache commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410610232 ## File path:

[jira] [Created] (FLINK-17229) Add a flink-sql-client-sdk module

molsion created FLINK-17229: --- Summary: Add a flink-sql-client-sdk module Key: FLINK-17229 URL: https://issues.apache.org/jira/browse/FLINK-17229 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17212) Disable the cython tests

[ https://issues.apache.org/jira/browse/FLINK-17212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17212: Parent: (was: FLINK-17115) Issue Type: Bug (was: Sub-task) > Disable the cython tests >

[jira] [Closed] (FLINK-17212) Disable the cython tests

[ https://issues.apache.org/jira/browse/FLINK-17212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17212. --- Resolution: Invalid Mark it as invalid. Let's add the cython support after gcc is available in the azure

[GitHub] [flink] dianfu removed a comment on issue #11790: [FLINK-17212][python] Disable the cython tests

dianfu removed a comment on issue #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790#issuecomment-615543104 Closing this PR. Let's add the cython support after gcc is added in the azure container. Thanks @pnowojski @rmetzger @HuangXingBo

[GitHub] [flink] dianfu closed pull request #11790: [FLINK-17212][python] Disable the cython tests

dianfu closed pull request #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] dianfu commented on issue #11790: [FLINK-17212][python] Disable the cython tests

dianfu commented on issue #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790#issuecomment-615543086 Closing this PR. Let's add the cython support after gcc is added in the azure container. Thanks @pnowojski @rmetzger @HuangXingBo

[GitHub] [flink] dianfu commented on issue #11790: [FLINK-17212][python] Disable the cython tests

dianfu commented on issue #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790#issuecomment-615543104 Closing this PR. Let's add the cython support after gcc is added in the azure container. Thanks @pnowojski @rmetzger @HuangXingBo

[GitHub] [flink] flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11801#issuecomment-615388238 ## CI report: *

[jira] [Updated] (FLINK-16280) Fix sample code errors in the documentation about elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16280: Summary: Fix sample code errors in the documentation about elasticsearch connector (was: Fix sample code

[GitHub] [flink] flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802#issuecomment-615431873 ## CI report: * 1f63e9f1b9f77c0b16ce16a743de535333ba7fff Travis:

[jira] [Closed] (FLINK-16683) Remove scripts for starting Flink on Windows

[ https://issues.apache.org/jira/browse/FLINK-16683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16683. Release Note: Flink no longer supports starting clusters with .bat scripts. Users should

[GitHub] [flink] flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11801#issuecomment-615388238 ## CI report: *

[GitHub] [flink] zentol merged pull request #11793: [FLINK-16683][scripts] Remove Windows scripts

zentol merged pull request #11793: [FLINK-16683][scripts] Remove Windows scripts URL: https://github.com/apache/flink/pull/11793 This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Closed] (FLINK-16895) Remove outdated and defunct build_docs.bat

[ https://issues.apache.org/jira/browse/FLINK-16895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16895. Resolution: Fixed > Remove outdated and defunct build_docs.bat >

[jira] [Commented] (FLINK-16895) Remove outdated and defunct build_docs.bat

[ https://issues.apache.org/jira/browse/FLINK-16895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086120#comment-17086120 ] Chesnay Schepler commented on FLINK-16895: -- master: d6c782f3b9413d2e3ba395c51c5fb90e973b47a1 >

[GitHub] [flink] flinkbot edited a comment on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

flinkbot edited a comment on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#issuecomment-615388166 ## CI report: * 94df0408ca27e31d433a3c1ec1a9a06d64707c37 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts

flinkbot edited a comment on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts URL: https://github.com/apache/flink/pull/11765#issuecomment-614430999 ## CI report: * f22365d16c850c88eb2a89cd5924c554159136a9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759#issuecomment-614064345 ## CI report: * 94c1ed297e994c4419e74b427f321237081f122c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802#issuecomment-615431873 ## CI report: * 1f63e9f1b9f77c0b16ce16a743de535333ba7fff Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759#issuecomment-614064345 ## CI report: * 94c1ed297e994c4419e74b427f321237081f122c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpoi

flinkbot edited a comment on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11798#issuecomment-615305745 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

flinkbot edited a comment on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#issuecomment-615388166 ## CI report: * 94df0408ca27e31d433a3c1ec1a9a06d64707c37 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25

[GitHub] [flink] flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test

flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test URL: https://github.com/apache/flink/pull/11795#issuecomment-615243201 ## CI report: * aed6ce45ce8fad6b6bba4cdb69235e9a3d15e345 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN *

[GitHub] [flink] GJL commented on issue #11783: [FLINK-17181][runtime] Drop generic Types in SchedulingTopology Interface

GJL commented on issue #11783: [FLINK-17181][runtime] Drop generic Types in SchedulingTopology Interface URL: https://github.com/apache/flink/pull/11783#issuecomment-615455317 master: cc30a4ea080abda6bc58515e95fdf74f24792ec8

[GitHub] [flink] GJL closed pull request #11783: [FLINK-17181][runtime] Drop generic Types in SchedulingTopology Interface

GJL closed pull request #11783: [FLINK-17181][runtime] Drop generic Types in SchedulingTopology Interface URL: https://github.com/apache/flink/pull/11783 This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-17180) Implement PipelinedRegion interface for SchedulingTopology

[ https://issues.apache.org/jira/browse/FLINK-17180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-17180: - Fix Version/s: 1.11.0 > Implement PipelinedRegion interface for SchedulingTopology >

[jira] [Closed] (FLINK-17181) Drop generic Types in SchedulingTopology Interface

[ https://issues.apache.org/jira/browse/FLINK-17181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-17181. Resolution: Fixed master: cc30a4ea080abda6bc58515e95fdf74f24792ec8 > Drop generic Types in

[jira] [Updated] (FLINK-17181) Drop generic Types in SchedulingTopology Interface

[ https://issues.apache.org/jira/browse/FLINK-17181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-17181: - Component/s: Runtime / Coordination > Drop generic Types in SchedulingTopology Interface >

[GitHub] [flink] flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts

flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts URL: https://github.com/apache/flink/pull/11793#issuecomment-615233681 ## CI report: * 7f61a76e49a0bd7feb82219a9906959a2181f89b UNKNOWN * 8e91f6152077a329e6879011919b4658b2f6400d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test

flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test URL: https://github.com/apache/flink/pull/11795#issuecomment-615243201 ## CI report: * 365b9719bc3bcf169d8808a62eb7745f5b8dba91 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802#issuecomment-615431873 ## CI report: * 1f63e9f1b9f77c0b16ce16a743de535333ba7fff Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11790: [FLINK-17212][python] Disable the cython tests

flinkbot edited a comment on issue #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790#issuecomment-615142739 ## CI report: * 9648b3c8c06d99e5835e2725d80e68f7f3854bcc UNKNOWN * 2a10199231df7befce8720c636ce2f196024ea70 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien…

flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien… URL: https://github.com/apache/flink/pull/11788#issuecomment-615123775 ## CI report: * 149e776d00f9ae15493047dd7165a45c8b1da207 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts

flinkbot edited a comment on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts URL: https://github.com/apache/flink/pull/11765#issuecomment-614430999 ## CI report: * f22365d16c850c88eb2a89cd5924c554159136a9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink. URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552 ## CI report: * 01280e72a363ee72180dd385dc95e0013f60650f Travis:

[GitHub] [flink] flinkbot commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

flinkbot commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802#issuecomment-615431873 ## CI report: * 1f63e9f1b9f77c0b16ce16a743de535333ba7fff UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN *

[jira] [Commented] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records

[ https://issues.apache.org/jira/browse/FLINK-17197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085997#comment-17085997 ] Roman Khachatryan commented on FLINK-17197: --- Thanks for report and analysis [~TsReaper]. I've

[GitHub] [flink] flinkbot edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

flinkbot edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint URL: https://github.com/apache/flink/pull/11696#issuecomment-611702183 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts

flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts URL: https://github.com/apache/flink/pull/11793#issuecomment-615233681 ## CI report: * 7f61a76e49a0bd7feb82219a9906959a2181f89b UNKNOWN * 8e91f6152077a329e6879011919b4658b2f6400d Travis:

[GitHub] [flink] flinkbot commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

flinkbot commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802#issuecomment-615415261 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 49376ddf5708d3cf924b886de461222780128ba8 UNKNOWN *

[GitHub] [flink] rkhachatryan commented on a change in pull request #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

rkhachatryan commented on a change in pull request #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802#discussion_r410416494 ## File path:

[jira] [Updated] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records

[ https://issues.apache.org/jira/browse/FLINK-17197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17197: --- Labels: pull-request-available (was: ) > ContinuousFileReaderOperator might shade the real

[GitHub] [flink] rkhachatryan opened a new pull request #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

rkhachatryan opened a new pull request #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error URL: https://github.com/apache/flink/pull/11802 ## What is the purpose of the change Currently, `ContinuousFileReaderOperator` switches state to

[GitHub] [flink] flinkbot edited a comment on issue #11796: [FLINK-14258][table][filesystem] Integrate file system connector to streaming sink

flinkbot edited a comment on issue #11796: [FLINK-14258][table][filesystem] Integrate file system connector to streaming sink URL: https://github.com/apache/flink/pull/11796#issuecomment-615254717 ## CI report: * 90fa0d286fbdae57d834d527a8843a8a493d5a0d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 49376ddf5708d3cf924b886de461222780128ba8 UNKNOWN *

[GitHub] [flink] rkhachatryan commented on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints

rkhachatryan commented on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints URL: https://github.com/apache/flink/pull/11754#issuecomment-615402883 Thanks @AHeise , @pnowojski . The last two pushes were to rebase to the current master.

[jira] [Commented] (FLINK-15680) testIsAvailableOrNotAfterRequestAndRecycleMultiSegments timed out

[ https://issues.apache.org/jira/browse/FLINK-15680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085978#comment-17085978 ] Roman Khachatryan commented on FLINK-15680: --- another instance:

[GitHub] [flink] flinkbot edited a comment on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

flinkbot edited a comment on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#issuecomment-615388166 ## CI report: * 94df0408ca27e31d433a3c1ec1a9a06d64707c37 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * d9bf90c0cc650ba4af36abdcef408088ef81baba Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts

flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts URL: https://github.com/apache/flink/pull/11793#issuecomment-615233681 ## CI report: * 7f61a76e49a0bd7feb82219a9906959a2181f89b UNKNOWN * 8e91f6152077a329e6879011919b4658b2f6400d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot edited a comment on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11801#issuecomment-615388238 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien…

flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien… URL: https://github.com/apache/flink/pull/11788#issuecomment-615123775 ## CI report: * 149e776d00f9ae15493047dd7165a45c8b1da207 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors

flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors URL: https://github.com/apache/flink/pull/11683#issuecomment-611422123 ## CI report: * fade42d50aa4a6937b44e1b42919220eb5ec431b UNKNOWN *

[GitHub] [flink] flinkbot commented on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot commented on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11801#issuecomment-615388238 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

flinkbot commented on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#issuecomment-615388166 ## CI report: * 94df0408ca27e31d433a3c1ec1a9a06d64707c37 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #11790: [FLINK-17212][python] Disable the cython tests

flinkbot edited a comment on issue #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790#issuecomment-615142739 ## CI report: * 9648b3c8c06d99e5835e2725d80e68f7f3854bcc UNKNOWN * 2a10199231df7befce8720c636ce2f196024ea70 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * d9bf90c0cc650ba4af36abdcef408088ef81baba Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints

flinkbot edited a comment on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints URL: https://github.com/apache/flink/pull/11754#issuecomment-613990642 ## CI report: * aebef0a50172e17d7cd02b4cd44c15f03b4b2d2e Travis:

[GitHub] [flink] flinkbot commented on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot commented on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11801#issuecomment-615385749 Thanks a lot for your contribution to the

[GitHub] [flink] zlb1028 opened a new pull request #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

zlb1028 opened a new pull request #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11801 ## What is the purpose of the change This pull

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r410380876 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r410380283 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25

[jira] [Commented] (FLINK-17223) System.IO.IOException: No space left on device in misc profile on free Azure builders

[ https://issues.apache.org/jira/browse/FLINK-17223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085953#comment-17085953 ] Robert Metzger commented on FLINK-17223: The reduction in disk space is a "known issue" that

[GitHub] [flink] flinkbot commented on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

flinkbot commented on issue #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#issuecomment-615378518 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] zhijiangW commented on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-615378176 @flinkbot run travis

[GitHub] [flink] rmetzger commented on a change in pull request #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

rmetzger commented on a change in pull request #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800#discussion_r410374580 ## File path: tools/azure-pipelines/jobs-template.yml ## @@ -111,7 +113,9 @@ jobs:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410374050 ## File path:

[GitHub] [flink] rmetzger opened a new pull request #11800: [FLINK-16411][Azure] Use Maven cache in the same data center

rmetzger opened a new pull request #11800: [FLINK-16411][Azure] Use Maven cache in the same data center URL: https://github.com/apache/flink/pull/11800 ## What is the purpose of the change It is a known problem (https://github.com/microsoft/azure-pipelines-tasks/issues/11864) that

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410368726 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410368414 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410367850 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410367542 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

flinkbot edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint URL: https://github.com/apache/flink/pull/11696#issuecomment-611702183 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors

flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors URL: https://github.com/apache/flink/pull/11683#issuecomment-611422123 ## CI report: * fade42d50aa4a6937b44e1b42919220eb5ec431b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode

flinkbot edited a comment on issue #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode URL: https://github.com/apache/flink/pull/11668#issuecomment-610845431 ## CI report: * 7d2e31fab3e7e023346cbec86fbb239c80310895 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410363733 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410362251 ## File path:

[jira] [Updated] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results

[ https://issues.apache.org/jira/browse/FLINK-17228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-17228: Description: We are facing an special scenario, *we want to know if this feature is supported*:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410357221 ## File path:

  1   2   3   4   5   6   7   8   >