[GitHub] [flink] danny0405 commented on a change in pull request #13865: [FLINK-19906][table-planner] Fix incorrect result when compare two binary fields

2020-11-05 Thread GitBox
danny0405 commented on a change in pull request #13865: URL: https://github.com/apache/flink/pull/13865#discussion_r518578072 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java ## @@ -1116,4 +1116,26

[GitHub] [flink] lirui-apache commented on a change in pull request #13939: [FLINK-19992][hive] Integrate new orc to Hive source

2020-11-05 Thread GitBox
lirui-apache commented on a change in pull request #13939: URL: https://github.com/apache/flink/pull/13939#discussion_r518573163 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveBulkFormatAdapter.java ## @@ -107,24 +11

[GitHub] [flink] flinkbot edited a comment on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722358038 ## CI report: * bdf73f2711715bf90e19bd8387ee86e15216dabb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13930: [FLINK-19974][python][e2e] Fix the bug that kafka related services are not teardown properly after tests finished

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13930: URL: https://github.com/apache/flink/pull/13930#issuecomment-722114476 ## CI report: * 1b07904cff7c6401452f07dfc88775d0d3f84853 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227191#comment-17227191 ] Dian Fu edited comment on FLINK-18926 at 11/6/20, 7:39 AM: --- Me

[jira] [Updated] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18926: Fix Version/s: 1.11.3 > Add a "Environment Variables" document under the "Python API" -> "User > Guide"

[jira] [Commented] (FLINK-19956) $ does not work on variables without being qualified in Scala

2020-11-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227219#comment-17227219 ] Timo Walther commented on FLINK-19956: -- Thanks for the research [~jark]. I forgot t

[jira] [Updated] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-05 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-19687: --- Description: Hi, I want to get job's execution plan in Flink SQL 1.11, but i meet exception  "No ope

[jira] [Updated] (FLINK-20015) Failure to execute streaming SQL query

2020-11-05 Thread Satyam Shekhar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyam Shekhar updated FLINK-20015: --- Summary: Failure to execute streaming SQL query (was: Failure to execute streaming query)

[GitHub] [flink] flinkbot edited a comment on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722358038 ## CI report: * bdf73f2711715bf90e19bd8387ee86e15216dabb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-19665) AlternatingCheckpointBarrierHandlerTest.testMetricsAlternation unstable

2020-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-19665. -- Fix Version/s: 1.12.0 Resolution: Fixed Yes, that's right. Thanks for pointing this out

[jira] [Resolved] (FLINK-19533) Add state assignment to channel state during rescaling

2020-11-05 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19533. - Fix Version/s: 1.12.0 Resolution: Fixed > Add state assignment to channel state during re

[GitHub] [flink] TsReaper commented on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
TsReaper commented on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722916753 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-19533) Add state assignment to channel state during rescaling

2020-11-05 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227203#comment-17227203 ] Arvid Heise commented on FLINK-19533: - Merged into master as a2267fa28a44c4cf4cc9068

[GitHub] [flink] AHeise merged pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-11-05 Thread GitBox
AHeise merged pull request #13735: URL: https://github.com/apache/flink/pull/13735 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Updated] (FLINK-20015) Failure to execute streaming query

2020-11-05 Thread Satyam Shekhar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyam Shekhar updated FLINK-20015: --- Description: Hello,   I have a table T0 with the following schema - root       |-- amoun

[jira] [Updated] (FLINK-20015) Failure to execute streaming query

2020-11-05 Thread Satyam Shekhar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyam Shekhar updated FLINK-20015: --- Description: Hello,   I have a table T0 with the following schema - root       |-- amoun

[jira] [Updated] (FLINK-20015) Failure to execute streaming query

2020-11-05 Thread Satyam Shekhar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyam Shekhar updated FLINK-20015: --- Description: Hello,   I have a table T0 with the following schema - {{root}} {{       |--

[GitHub] [flink] AHeise commented on a change in pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-11-05 Thread GitBox
AHeise commented on a change in pull request #13735: URL: https://github.com/apache/flink/pull/13735#discussion_r518555888 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java ## @@ -64,81 +61,64 @@ /** * Snap

[GitHub] [flink] Myasuka merged pull request #13587: [FLINK-18004][docs] Update checkpoint UI related pictures in documentation

2020-11-05 Thread GitBox
Myasuka merged pull request #13587: URL: https://github.com/apache/flink/pull/13587 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Created] (FLINK-20016) Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-05 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-20016: -- Summary: Support TimestampAssigner and WatermarkGenerator for Python DataStream API. Key: FLINK-20016 URL: https://issues.apache.org/jira/browse/FLINK-20016 Proje

[jira] [Created] (FLINK-20015) Failure to execute streaming query

2020-11-05 Thread Satyam Shekhar (Jira)
Satyam Shekhar created FLINK-20015: -- Summary: Failure to execute streaming query Key: FLINK-20015 URL: https://issues.apache.org/jira/browse/FLINK-20015 Project: Flink Issue Type: Bug

[GitHub] [flink] AHeise commented on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-11-05 Thread GitBox
AHeise commented on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-722914106 > Thanks for updating the PR, LGTM. > > I'm only concerned about changing the partitioner upon restart. For example, if the job is modified so that DOP of upstream is no lo

[GitHub] [flink] AHeise commented on a change in pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-11-05 Thread GitBox
AHeise commented on a change in pull request #13735: URL: https://github.com/apache/flink/pull/13735#discussion_r518555888 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java ## @@ -64,81 +61,64 @@ /** * Snap

[GitHub] [flink] flinkbot edited a comment on pull request #13930: [FLINK-19974][python][e2e] Fix the bug that kafka related services are not teardown properly after tests finished

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13930: URL: https://github.com/apache/flink/pull/13930#issuecomment-722114476 ## CI report: * 1b07904cff7c6401452f07dfc88775d0d3f84853 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722358038 ## CI report: * bdf73f2711715bf90e19bd8387ee86e15216dabb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13931: [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13931: URL: https://github.com/apache/flink/pull/13931#issuecomment-722165982 ## CI report: * 83c419b7fbf59830387cdac4418e63c4ae1b3296 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13897: [FLINK-19939][table-planner-blink] Remove redundant union from multiple input node

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13897: URL: https://github.com/apache/flink/pull/13897#issuecomment-720935204 ## CI report: * 6ee9a3823a7b502c7c07daa304148ae60f42d237 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] danny0405 commented on pull request #13865: [FLINK-19906][table-planner] Fix incorrect result when compare two binary fields

2020-11-05 Thread GitBox
danny0405 commented on pull request #13865: URL: https://github.com/apache/flink/pull/13865#issuecomment-722905527 Sure, let me take a look ~ This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] wangyang0918 commented on a change in pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

2020-11-05 Thread GitBox
wangyang0918 commented on a change in pull request #13871: URL: https://github.com/apache/flink/pull/13871#discussion_r518550184 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/TestingRetrievableStateStorageHelper.java ## @@ -41,22 +64,43 @@

[jira] [Closed] (FLINK-18929) Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18929. --- Assignee: (was: Huang Xingbo) Resolution: Abandoned [~hxbks2ks] Agree with you. Let's close this t

[jira] [Closed] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18926. --- Fix Version/s: 1.12.0 Resolution: Fixed Merged to master via e0a0aa606072e48018c178c1c3f47557f445e5ef

[jira] [Updated] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18926: Component/s: API / Python > Add a "Environment Variables" document under the "Python API" -> "User > Gui

[GitHub] [flink] dianfu closed pull request #13935: [FLINK-18926][python][doc] Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section.

2020-11-05 Thread GitBox
dianfu closed pull request #13935: URL: https://github.com/apache/flink/pull/13935 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] wangyang0918 commented on a change in pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

2020-11-05 Thread GitBox
wangyang0918 commented on a change in pull request #13871: URL: https://github.com/apache/flink/pull/13871#discussion_r518547824 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStore.java ## @@ -118,33 +112,22 @@ public b

[GitHub] [flink] flinkbot edited a comment on pull request #13931: [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13931: URL: https://github.com/apache/flink/pull/13931#issuecomment-722165982 ## CI report: * 83c419b7fbf59830387cdac4418e63c4ae1b3296 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13956: [FLINK-20006] Fix the unstable FileSinkITCase

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13956: URL: https://github.com/apache/flink/pull/13956#issuecomment-722868816 ## CI report: * 1de2eca68fe489aadb55ed3084d18f4cd7ea723f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13930: [FLINK-19974][python][e2e] Fix the bug that kafka related services are not teardown properly after tests finished

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13930: URL: https://github.com/apache/flink/pull/13930#issuecomment-722114476 ## CI report: * 1b07904cff7c6401452f07dfc88775d0d3f84853 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13897: [FLINK-19939][table-planner-blink] Remove redundant union from multiple input node

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13897: URL: https://github.com/apache/flink/pull/13897#issuecomment-720935204 ## CI report: * 6ee9a3823a7b502c7c07daa304148ae60f42d237 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * f5ee007a4e17a98cc6252e0f14c023d657b9438a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13956: [FLINK-20006] Fix the unstable FileSinkITCase

2020-11-05 Thread GitBox
flinkbot commented on pull request #13956: URL: https://github.com/apache/flink/pull/13956#issuecomment-722868816 ## CI report: * 1de2eca68fe489aadb55ed3084d18f4cd7ea723f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722358038 ## CI report: * 30b3bcd2da00b89794fe83bee5c5c0113949bbfa Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] vintageplayer commented on pull request #13951: [FLINK-19998] Fixing links for checkpoints & savepoints in the first …

2020-11-05 Thread GitBox
vintageplayer commented on pull request #13951: URL: https://github.com/apache/flink/pull/13951#issuecomment-722862235 @rmetzger Have updated the pull request description. Please take a look. Thanks. This is an automated mes

[GitHub] [flink] wangyang0918 commented on a change in pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

2020-11-05 Thread GitBox
wangyang0918 commented on a change in pull request #13871: URL: https://github.com/apache/flink/pull/13871#discussion_r518538862 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesCheckpointIDCounter.java ## @@ -0,0 +1,150 @@ +/

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * f5ee007a4e17a98cc6252e0f14c023d657b9438a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-19284) Add documentation about how to use Python UDF in the Java Table API

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19284. --- Fix Version/s: (was: 1.11.3) Resolution: Fixed Merged to master via 51cd11e70205eea1e4f88041d6edf

[GitHub] [flink] dianfu closed pull request #13945: [FLINK-19284][python][doc] Add documentation about how to use Python UDF in the Java Table API.

2020-11-05 Thread GitBox
dianfu closed pull request #13945: URL: https://github.com/apache/flink/pull/13945 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] xintongsong commented on a change in pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

2020-11-05 Thread GitBox
xintongsong commented on a change in pull request #13864: URL: https://github.com/apache/flink/pull/13864#discussion_r518531957 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/persistence/StateHandleStore.java ## @@ -0,0 +1,207 @@ +/* + * Licensed to the Apa

[GitHub] [flink] wangyang0918 commented on a change in pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

2020-11-05 Thread GitBox
wangyang0918 commented on a change in pull request #13871: URL: https://github.com/apache/flink/pull/13871#discussion_r518533440 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/TestingRetrievableStateStorageHelper.java ## @@ -30,9 +34,28 @@ */

[GitHub] [flink] flinkbot commented on pull request #13956: [FLINK-20006] Fix the unstable FileSinkITCase

2020-11-05 Thread GitBox
flinkbot commented on pull request #13956: URL: https://github.com/apache/flink/pull/13956#issuecomment-722847196 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 use this comment to track the pro

[GitHub] [flink] gaoyunhaii opened a new pull request #13956: [FLINK-20006] Fix the unstable FileSinkITCase

2020-11-05 Thread GitBox
gaoyunhaii opened a new pull request #13956: URL: https://github.com/apache/flink/pull/13956 ## What is the purpose of the change This PR fixes the unstable `FileSinkITCase`. The original implementation has some logical error, e.g., it does not keep the state for the source function,

[jira] [Updated] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

2020-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20006: --- Labels: pull-request-available test-stability (was: test-stability) > FileSinkITCase.testFi

[GitHub] [flink] flinkbot edited a comment on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722358038 ## CI report: * 30b3bcd2da00b89794fe83bee5c5c0113949bbfa Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 614d1934dd815569b08e7ed0546c0fee1ebcfd18 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangyang0918 commented on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

2020-11-05 Thread GitBox
wangyang0918 commented on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-722834851 @tillrohrmann @xintongsong Thanks for your fruitful comments. I have addressed all of them and force pushed. Please have a check. -

[GitHub] [flink] Shawn-Hx commented on pull request #13949: [hotfix][doc] Chage link format in some docs

2020-11-05 Thread GitBox
Shawn-Hx commented on pull request #13949: URL: https://github.com/apache/flink/pull/13949#issuecomment-722825770 Hi, @sjwiesman I change the link format from `{{ site.baseurl }}/.../xxx.html` to `{% link .../xxx.md %}` in some doc directories. The `build_docs.sh` can be executed wit

[GitHub] [flink] TsReaper removed a comment on pull request #13942: [FLINK-19990][table-planner-blink] MultipleInputNodeCreationProcessor#isChainableSource now considers DataStreamScanProvider

2020-11-05 Thread GitBox
TsReaper removed a comment on pull request #13942: URL: https://github.com/apache/flink/pull/13942#issuecomment-722334386 Thanks for the review @JingsongLi , please do not squash the commits when merging. This is an automate

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 614d1934dd815569b08e7ed0546c0fee1ebcfd18 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-05 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-19940: Issue Type: Bug (was: Improvement) > Task names on web UI should change when an operator chain is

[GitHub] [flink] flinkbot edited a comment on pull request #13955: [FLINK-19934][Connector] Add a new API: SplitEnumeratorContext.runInC…

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13955: URL: https://github.com/apache/flink/pull/13955#issuecomment-722804935 ## CI report: * a4a7d6774aa62d7f3f7fbd850f3024ec7cf5a78d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20014) Resolve CVE-2020-11022 and CVE-2020-11023 in scala-compiler

2020-11-05 Thread Alan Leong (Jira)
Alan Leong created FLINK-20014: -- Summary: Resolve CVE-2020-11022 and CVE-2020-11023 in scala-compiler Key: FLINK-20014 URL: https://issues.apache.org/jira/browse/FLINK-20014 Project: Flink Issu

[GitHub] [flink] flinkbot commented on pull request #13955: [FLINK-19934][Connector] Add a new API: SplitEnumeratorContext.runInC…

2020-11-05 Thread GitBox
flinkbot commented on pull request #13955: URL: https://github.com/apache/flink/pull/13955#issuecomment-722804935 ## CI report: * a4a7d6774aa62d7f3f7fbd850f3024ec7cf5a78d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13935: [FLINK-18926][python][doc] Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section.

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13935: URL: https://github.com/apache/flink/pull/13935#issuecomment-722244949 ## CI report: * 3758f3ad3644ca64bbb7e7bb40db4db903354236 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13841: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13841: URL: https://github.com/apache/flink/pull/13841#issuecomment-718698511 ## CI report: * ba30909849312f20c9ae3cdf2f3b270195eeaac9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

2020-11-05 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-20013: --- Summary: BoundedBlockingSubpartition may leak network buffer if task is failed or canceled Key: FLINK-20013 URL: https://issues.apache.org/jira/browse/FLINK-20013 Proje

[jira] [Commented] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

2020-11-05 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227154#comment-17227154 ] Yingjie Cao commented on FLINK-19925: - Usually, it indicates an unstable network whi

[GitHub] [flink] xintongsong commented on a change in pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

2020-11-05 Thread GitBox
xintongsong commented on a change in pull request #13871: URL: https://github.com/apache/flink/pull/13871#discussion_r518506150 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointStoreUtil.java ## @@ -0,0 +1,68 @@ +/* + * Licensed

[GitHub] [flink] flinkbot commented on pull request #13955: [FLINK-19934][Connector] Add a new API: SplitEnumeratorContext.runInC…

2020-11-05 Thread GitBox
flinkbot commented on pull request #13955: URL: https://github.com/apache/flink/pull/13955#issuecomment-722800657 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 use this comment to track the pro

[GitHub] [flink] stevenzwu opened a new pull request #13955: [FLINK-19934][Connector] Add a new API: SplitEnumeratorContext.runInC…

2020-11-05 Thread GitBox
stevenzwu opened a new pull request #13955: URL: https://github.com/apache/flink/pull/13955 …oordinatorThread(Runnable) ## What is the purpose of the change This PR adds a new API in SplitEnumeratorContext so that enumerator can run all actions in the source coordinator thread

[jira] [Updated] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

2020-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19934: --- Labels: pull-request-available (was: ) > [FLIP-27 source] add new API: SplitEnumeratorConte

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227153#comment-17227153 ] Zhu Zhu commented on FLINK-19964: - We recently noticed the issue FLINK-19994 that pipeli

[GitHub] [flink] flinkbot edited a comment on pull request #13935: [FLINK-18926][python][doc] Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section.

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13935: URL: https://github.com/apache/flink/pull/13935#issuecomment-722244949 ## CI report: * 3758f3ad3644ca64bbb7e7bb40db4db903354236 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13841: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13841: URL: https://github.com/apache/flink/pull/13841#issuecomment-718698511 ## CI report: * 62cc0044b2b3ce6d379a7e71ef440949b6a2d577 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

2020-11-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19994: --- Assignee: Zhu Zhu > All vertices in an DataSet iteration job will be eagerly scheduled > --

[jira] [Commented] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore)

2020-11-05 Thread Edward Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227149#comment-17227149 ] Edward Chen commented on FLINK-8929: We also met this problem. Flink Version:1.8.1

[GitHub] [flink] flinkbot edited a comment on pull request #13841: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13841: URL: https://github.com/apache/flink/pull/13841#issuecomment-718698511 ## CI report: * 62cc0044b2b3ce6d379a7e71ef440949b6a2d577 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangyang0918 commented on a change in pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

2020-11-05 Thread GitBox
wangyang0918 commented on a change in pull request #13864: URL: https://github.com/apache/flink/pull/13864#discussion_r518504840 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesJobGraphStoreWatcher.java ## @@ -0,0 +1,170 @@ +

[jira] [Closed] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-11-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19868. --- Resolution: Fixed Fixed in master: 2d12d325d77e4727cb74d8a58597eb0ce9ab5aa2 > Csv Serialization schema cont

[GitHub] [flink] wuchong merged pull request #13925: [FLINK-19868][csv] Csv Serialization schema contains line delimiter

2020-11-05 Thread GitBox
wuchong merged pull request #13925: URL: https://github.com/apache/flink/pull/13925 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #13925: [FLINK-19868][csv] Csv Serialization schema contains line delimiter

2020-11-05 Thread GitBox
wuchong commented on pull request #13925: URL: https://github.com/apache/flink/pull/13925#issuecomment-722788212 The failed e2e test seems not related to this PR. Will merge it. This is an automated message from the

[GitHub] [flink] gaoyunhaii opened a new pull request #13841: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

2020-11-05 Thread GitBox
gaoyunhaii opened a new pull request #13841: URL: https://github.com/apache/flink/pull/13841 ## What is the purpose of the change This PR adds the e2e tests for the new FileSink. In the e2e tests we mainly focus on cases of TaskMangers get killed, thus we only test the streaming mode

[GitHub] [flink] gaoyunhaii closed pull request #13841: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

2020-11-05 Thread GitBox
gaoyunhaii closed pull request #13841: URL: https://github.com/apache/flink/pull/13841 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] Shawn-Hx commented on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-11-05 Thread GitBox
Shawn-Hx commented on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-722783352 kindly ping @wuchong This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Created] (FLINK-20012) Hive 3.1 integration exception

2020-11-05 Thread Dino Zhang (Jira)
Dino Zhang created FLINK-20012: -- Summary: Hive 3.1 integration exception Key: FLINK-20012 URL: https://issues.apache.org/jira/browse/FLINK-20012 Project: Flink Issue Type: Bug Componen

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

[jira] [Created] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

2020-11-05 Thread Dian Fu (Jira)
Dian Fu created FLINK-20011: --- Summary: PageRankITCase.testPrintWithRMatGraph hangs Key: FLINK-20011 URL: https://issues.apache.org/jira/browse/FLINK-20011 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #13761: [FLINK-19741] Allow AbstractStreamOperator to skip restoring timers if subclasses are using raw keyed state

2020-11-05 Thread GitBox
flinkbot edited a comment on pull request #13761: URL: https://github.com/apache/flink/pull/13761#issuecomment-715133167 ## CI report: * 3b4185f9f38239a2c653be92006d8884786fddec UNKNOWN * c44182c8bc680f25b5550abcaad0f4fbf0136110 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20011: Issue Type: Bug (was: Improvement) > PageRankITCase.testPrintWithRMatGraph hangs > --

[jira] [Updated] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20011: Labels: test-stability (was: ) > PageRankITCase.testPrintWithRMatGraph hangs > --

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

2020-11-05 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227142#comment-17227142 ] Yang Wang commented on FLINK-19909: --- Sorry for the late response. I have gone through

[GitHub] [flink] JingsongLi edited a comment on pull request #13724: [FLINK-19581][orc] Introduce Orc ColumnarRow File source bulk Format

2020-11-05 Thread GitBox
JingsongLi edited a comment on pull request #13724: URL: https://github.com/apache/flink/pull/13724#issuecomment-722776712 Hi @StephanEwen, `int[] selected` in `VectorizedRowBatch` is used by Hive vectorization computation engine. (Hive filter node can do zero-copy filter). ORC `RecordRead

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227140#comment-17227140 ] Dian Fu commented on FLINK-18570: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227139#comment-17227139 ] Dian Fu commented on FLINK-19699: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227138#comment-17227138 ] Dian Fu commented on FLINK-20006: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227137#comment-17227137 ] Dian Fu commented on FLINK-20006: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227136#comment-17227136 ] Dian Fu commented on FLINK-16908: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Closed] (FLINK-19995) 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one exception

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-19995. Resolution: Won't Fix > 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one > exc

[jira] [Commented] (FLINK-19995) 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one exception

2020-11-05 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227133#comment-17227133 ] zhisheng commented on FLINK-19995: -- I restart the SQL Client, but not the Flink Cluster

[jira] [Commented] (FLINK-17424) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to download error

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227132#comment-17227132 ] Dian Fu commented on FLINK-17424: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

2020-11-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227130#comment-17227130 ] Dian Fu commented on FLINK-20006: - https://dev.azure.com/apache-flink/apache-flink/_buil

  1   2   3   4   5   6   7   >