[GitHub] [flink] flinkbot edited a comment on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * 384aa1d095bc02c376ec2a0af43501a19e2a81ef Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * 384aa1d095bc02c376ec2a0af43501a19e2a81ef Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG)

2021-01-15 Thread Ya Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ya Xiao updated FLINK-20996: Description: We are a security research team at Virginia Tech. We are doing an empirical study about the

[jira] [Commented] (FLINK-20990) Service account property ignored for Kubernetes Standalone deployment

2021-01-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266513#comment-17266513 ] Yang Wang commented on FLINK-20990: --- Thanks for sharing the result. I believe it could

[jira] [Created] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG)

2021-01-15 Thread Ya Xiao (Jira)
Ya Xiao created FLINK-20996: --- Summary: Using a cryptographically weak Pseudo Random Number Generator (PRNG) Key: FLINK-20996 URL: https://issues.apache.org/jira/browse/FLINK-20996 Project: Flink I

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-01-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266490#comment-17266490 ] Huang Xingbo commented on FLINK-20329: -- [https://dev.azure.com/apache-flink/apache-

[jira] [Commented] (FLINK-19519) Add support for port range in taskmanager.data.port

2021-01-15 Thread Truong Duc Kien (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266472#comment-17266472 ] Truong Duc Kien commented on FLINK-19519: - Sure. I'll do it. > Add support for

[GitHub] [flink] flinkbot edited a comment on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * 8dc1342fec505ced26932fae17a394b456b2dac2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14619: [FLINK-20862][table] Support creating DataType from TypeInformation

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14619: URL: https://github.com/apache/flink/pull/14619#issuecomment-758635914 ## CI report: * 421fbf52f2ec18801b430ddeec0be5332a56788f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14594: URL: https://github.com/apache/flink/pull/14594#issuecomment-756890853 ## CI report: * bdfba9d2127fd0f843c3d57a953decec82eb15ff Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14594: URL: https://github.com/apache/flink/pull/14594#issuecomment-756890853 ## CI report: * 2062801ba381ee60fedb9c8ce07b6000dd485ab7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tianon commented on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-15 Thread GitBox
tianon commented on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761165429 I agree that the Docker image being a complete black box is a bad thing, which is exactly why I'm confused by this PR. Let me try to rephrase what I'm suggesting: Take a

[jira] [Updated] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

2021-01-15 Thread Robert Cullen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Cullen updated FLINK-20995: -- Description: Exception on this line: {code:java} try (CloseableIterator iterator = log_counts.

[jira] [Created] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

2021-01-15 Thread Robert Cullen (Jira)
Robert Cullen created FLINK-20995: - Summary: Calling execute() on org.apache.flink.table.api.Table Throws Exception Key: FLINK-20995 URL: https://issues.apache.org/jira/browse/FLINK-20995 Project: Fli

[GitHub] [flink] flinkbot edited a comment on pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness. [1.12]

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14668: URL: https://github.com/apache/flink/pull/14668#issuecomment-761008611 ## CI report: * d7d35f0247f4437fc215e06b698a8e2b8d45ddc2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sjwiesman commented on pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
sjwiesman commented on pull request #14594: URL: https://github.com/apache/flink/pull/14594#issuecomment-761162607 @twalthr I appreciate the review. I've pushed an update that I hope addresses all of your comments. This is

[jira] [Updated] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-01-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-20994: - Description: The Python table Api offers three table environment: * TableEnvironment * StreamT

[GitHub] [flink] sjwiesman commented on a change in pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
sjwiesman commented on a change in pull request #14594: URL: https://github.com/apache/flink/pull/14594#discussion_r558555284 ## File path: docs/dev/table/common.md ## @@ -116,173 +106,119 @@ table_result... -**Note:** Table API and SQL queries can be easily integrated wi

[jira] [Created] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-01-15 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-20994: Summary: Add public method to create TableEnvironment in PyFlink Key: FLINK-20994 URL: https://issues.apache.org/jira/browse/FLINK-20994 Project: Flink Issue

[jira] [Updated] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA

2021-01-15 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated FLINK-20982: -- Description: I'm experimenting with Flink 1.12 release and testing out Kubernetes HA f

[jira] [Assigned] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20833: -- Assignee: Zhenqiu Huang > Expose pluggable interface for exception analysis and metr

[GitHub] [flink] flinkbot edited a comment on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * f24833aedc768cdd4c3fa9426e7ed07814c82923 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * f24833aedc768cdd4c3fa9426e7ed07814c82923 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] XComp commented on a change in pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
XComp commented on a change in pull request #14666: URL: https://github.com/apache/flink/pull/14666#discussion_r558504220 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -275,7 +275,9 @@ public void killCluster(St

[GitHub] [flink] XComp commented on a change in pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
XComp commented on a change in pull request #14666: URL: https://github.com/apache/flink/pull/14666#discussion_r558501302 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -118,7 +118,7 @@ public String getClusterDe

[GitHub] [flink] flinkbot edited a comment on pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14667: URL: https://github.com/apache/flink/pull/14667#issuecomment-760951289 ## CI report: * 6e5bff743c94d18e0163c3695fce58f6ed114077 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * 384aa1d095bc02c376ec2a0af43501a19e2a81ef Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
tillrohrmann commented on a change in pull request #14666: URL: https://github.com/apache/flink/pull/14666#discussion_r558462987 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -275,7 +275,9 @@ public void killClu

[GitHub] [flink] flinkbot edited a comment on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * f24833aedc768cdd4c3fa9426e7ed07814c82923 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14619: [FLINK-20862][table] Support creating DataType from TypeInformation

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14619: URL: https://github.com/apache/flink/pull/14619#issuecomment-758635914 ## CI report: * bf7a6ff4b9608d651332cce78581e9146660c62f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14619: [FLINK-20862][table] Support creating DataType from TypeInformation

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14619: URL: https://github.com/apache/flink/pull/14619#issuecomment-758635914 ## CI report: * bf7a6ff4b9608d651332cce78581e9146660c62f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] twalthr commented on pull request #14619: [FLINK-20862][table] Support creating DataType from TypeInformation

2021-01-15 Thread GitBox
twalthr commented on pull request #14619: URL: https://github.com/apache/flink/pull/14619#issuecomment-761052302 Thanks for the feedback @dawidwys. I have updated the PR. This is an automated message from the Apache Git Servi

[jira] [Commented] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266180#comment-17266180 ] Timo Walther commented on FLINK-20919: -- Beginning from 1.12, we provide an easy to

[jira] [Comment Edited] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266160#comment-17266160 ] Timo Walther edited comment on FLINK-20919 at 1/15/21, 4:41 PM: --

[jira] [Closed] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-20919. - Resolution: Information Provided Closing this ticket since it was a problem of how to use the Ta

[GitHub] [flink] flinkbot edited a comment on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-759553978 ## CI report: * a01de0515efdd96e388a8ee1cc299311f90ab07b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] XComp commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
XComp commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r558416279 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/security/FlinkSecurityManagerTest.java ## @@ -0,0 +1,415 @@ +/* + * Licensed to the Apac

[jira] [Updated] (FLINK-19763) Missing test MetricUtilsTest.testNonHeapMetricUsageNotStatic

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19763: - Description: We have tests for the heap and metaspace to check whether the metric is dynamically genera

[jira] [Commented] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266160#comment-17266160 ] Till Rohrmann commented on FLINK-20919: --- Hi [~Janze], I was able to reproduce your

[GitHub] [flink] zentol edited a comment on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-15 Thread GitBox
zentol edited a comment on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-760922830 @tianon This is just a first step to facilitate easier refactorings. Migrating more (ideally all) of the docker-specific logic into the scripts is the long-term goal, whic

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

2021-01-15 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266157#comment-17266157 ] Yordan Pavlov commented on FLINK-16267: --- Thank you guys [~yunta], [~xintongsong] y

[GitHub] [flink] XComp commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
XComp commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r558408690 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/security/FlinkSecurityManager.java ## @@ -0,0 +1,220 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] sjwiesman commented on a change in pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
sjwiesman commented on a change in pull request #14594: URL: https://github.com/apache/flink/pull/14594#discussion_r558397412 ## File path: docs/dev/table/common.md ## @@ -1185,43 +1037,48 @@ val table: Table = tableEnv.fromDataStream(stream, $"_2" as "myInt", $"_1" as "m #

[GitHub] [flink] sjwiesman commented on a change in pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
sjwiesman commented on a change in pull request #14594: URL: https://github.com/apache/flink/pull/14594#discussion_r558396808 ## File path: docs/dev/table/common.md ## @@ -116,173 +106,119 @@ table_result... -**Note:** Table API and SQL queries can be easily integrated wi

[GitHub] [flink] flinkbot edited a comment on pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness.

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14668: URL: https://github.com/apache/flink/pull/14668#issuecomment-761008611 ## CI report: * d7d35f0247f4437fc215e06b698a8e2b8d45ddc2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-10515) Improve tokenisation of program args passed as string

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266130#comment-17266130 ] Matthias commented on FLINK-10515: -- [~vthinkxie] Can we implement the deprecated tokeni

[GitHub] [flink] rmetzger commented on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
rmetzger commented on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-761008849 During my manual test, it seems that I can intercept a System.exit() in user code of a batch job: ``` 2021-01-15 16:16:01,950 WARN org.apache.flink.runtime.security.

[GitHub] [flink] flinkbot commented on pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness.

2021-01-15 Thread GitBox
flinkbot commented on pull request #14668: URL: https://github.com/apache/flink/pull/14668#issuecomment-761008611 ## CI report: * d7d35f0247f4437fc215e06b698a8e2b8d45ddc2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-20990) Service account property ignored for Kubernetes Standalone deployment

2021-01-15 Thread Damian G (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265971#comment-17265971 ] Damian G edited comment on FLINK-20990 at 1/15/21, 3:18 PM:

[jira] [Closed] (FLINK-20990) Service account property ignored for Kubernetes Standalone deployment

2021-01-15 Thread Damian G (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian G closed FLINK-20990. Resolution: Invalid > Service account property ignored for Kubernetes Standalone deployment >

[GitHub] [flink] flinkbot commented on pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness.

2021-01-15 Thread GitBox
flinkbot commented on pull request #14668: URL: https://github.com/apache/flink/pull/14668#issuecomment-760995341 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] AHeise opened a new pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness.

2021-01-15 Thread GitBox
AHeise opened a new pull request #14668: URL: https://github.com/apache/flink/pull/14668 Backport of #14608 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] rmetzger commented on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
rmetzger commented on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-760989075 Code looks good to me. I'll do one final manual test, and then merge the PR. This is an automated message from

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r558359969 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java ## @@ -115,4 +127,35 @@ public static boolean isDeclarativeRe

[GitHub] [flink] flinkbot edited a comment on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-759553978 ## CI report: * dfad170401c7a97ed51e8e419ca1a73d0ee5f9a4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20953) Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20953: Component/s: Table SQL / Ecosystem > Option 'canal-json.database.include' and 'canal-json.table.include' s

[jira] [Closed] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20348. --- Resolution: Fixed Fixed in master: 3786d3b1e55e063c7453d9813335dc5c2906bf7b > Make "schema-registry.subject

[GitHub] [flink] wuchong merged pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-15 Thread GitBox
wuchong merged pull request #14530: URL: https://github.com/apache/flink/pull/14530 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] [Updated] (FLINK-20937) Fails when DROP a table with illegal watermark definition

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20937: Summary: Fails when DROP a table with illegal watermark definition (was: Fails when DROP a table with ill

[jira] [Updated] (FLINK-20937) Fails when DROP a table with illegalwatermark definition

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20937: Summary: Fails when DROP a table with illegalwatermark definition (was: Drop table can fails, when i crea

[jira] [Closed] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20937. --- Resolution: Fixed Fixed in master: de19a27fc58688712c86079333e3af3a6ccaa235 > Drop table can fails, when i

[GitHub] [flink] wuchong merged pull request #14640: [FLINK-20937][Table API/SQL]Drop table can fails, when i create a tab…

2021-01-15 Thread GitBox
wuchong merged pull request #14640: URL: https://github.com/apache/flink/pull/14640 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] [Closed] (FLINK-20953) Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20953. --- Resolution: Fixed Fixed in master: 3fea150713c970d8f1dd54670049115116029af4 > Option 'canal-json.database.i

[GitHub] [flink] wuchong merged pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread GitBox
wuchong merged pull request #14652: URL: https://github.com/apache/flink/pull/14652 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] [Assigned] (FLINK-10515) Improve tokenisation of program args passed as string

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-10515: Assignee: Matthias (was: Andrey Zagrebin) > Improve tokenisation of program args passed as strin

[jira] [Commented] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266070#comment-17266070 ] Till Rohrmann commented on FLINK-19067: --- I think this scenario can happen as you d

[GitHub] [flink] flinkbot edited a comment on pull request #14665: [FLINK-20858][python][table-planner-blink] Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14665: URL: https://github.com/apache/flink/pull/14665#issuecomment-760792355 ## CI report: * b1df7f6879a63390c8f252db85f8f338a4f29427 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 18ccb0196ac6025aff2aab2102ee6f0403e0d921 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] hwanju commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
hwanju commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r558339332 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java ## @@ -115,4 +127,35 @@ public static boolean isDeclarativeReso

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266066#comment-17266066 ] Jark Wu commented on FLINK-20972: - Since this is a {{LOG.info}} and will be logged for e

[jira] [Commented] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2021-01-15 Thread Boris Lublinsky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266064#comment-17266064 ] Boris Lublinsky commented on FLINK-20359: - I can't find it any more   > Suppor

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r558333937 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java ## @@ -115,4 +127,35 @@ public static boolean isDeclarativeRe

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

2021-01-15 Thread GitBox
rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r558329410 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/security/FlinkSecurityManager.java ## @@ -0,0 +1,220 @@ +/* + * Licensed to the Apach

[GitHub] [flink] flinkbot edited a comment on pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14667: URL: https://github.com/apache/flink/pull/14667#issuecomment-760951289 ## CI report: * 6e5bff743c94d18e0163c3695fce58f6ed114077 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * 1a07f8eafb9f951a217ec7622525958a4eeaf333 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14530: URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495 ## CI report: * fc88c9bf8bb2cb2c92695441dffcc1be5a21b1c1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

2021-01-15 Thread GitBox
flinkbot commented on pull request #14667: URL: https://github.com/apache/flink/pull/14667#issuecomment-760951289 ## CI report: * 6e5bff743c94d18e0163c3695fce58f6ed114077 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 83d11e2d31f495d56a0566c95f5d1045ae5ef0c3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266048#comment-17266048 ] Robert Metzger commented on FLINK-19067: Thank you for your detailed analysis. I

[jira] [Assigned] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19067: -- Assignee: Robert Metzger > resource_manager and dispatcher register on different node

[GitHub] [flink] flinkbot edited a comment on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * c9f9cf0caee79ac6382288b98ec98cad50a706cc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] AHeise merged pull request #14608: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness.

2021-01-15 Thread GitBox
AHeise merged pull request #14608: URL: https://github.com/apache/flink/pull/14608 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] flinkbot edited a comment on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * f24833aedc768cdd4c3fa9426e7ed07814c82923 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 4224ed129067a1550f812e8803c3298d523c2495 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14664: [FLINK-20989][table-planner-blink] Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14664: URL: https://github.com/apache/flink/pull/14664#issuecomment-760781140 ## CI report: * ebfe3612fb61d00749d4be184c7362beb52c15f0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14644: [FLINK-20840][table-planner] Properly transpose projection to join

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14644: URL: https://github.com/apache/flink/pull/14644#issuecomment-760117761 ## CI report: * 4e70987ec082764822d1eefa8356454ea6a274b9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * e0aa9de7e35bc1ac79a3d938454a9b5368445c69 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * c9f9cf0caee79ac6382288b98ec98cad50a706cc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

2021-01-15 Thread GitBox
flinkbot commented on pull request #14667: URL: https://github.com/apache/flink/pull/14667#issuecomment-760934204 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

[jira] [Closed] (FLINK-20993) Cleaning up checkpoint during shutdown may fail JM

2021-01-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-20993. - Resolution: Duplicate > Cleaning up checkpoint during shutdown may fail JM > ---

[GitHub] [flink] AHeise opened a new pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

2021-01-15 Thread GitBox
AHeise opened a new pull request #14667: URL: https://github.com/apache/flink/pull/14667 Unchanged backport of #14655. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Created] (FLINK-20993) Cleaning up checkpoint during shutdown may fail JM

2021-01-15 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20993: - Summary: Cleaning up checkpoint during shutdown may fail JM Key: FLINK-20993 URL: https://issues.apache.org/jira/browse/FLINK-20993 Project: Flink

[jira] [Created] (FLINK-20992) Checkpoint cleanup can kill JobMaster

2021-01-15 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20992: - Summary: Checkpoint cleanup can kill JobMaster Key: FLINK-20992 URL: https://issues.apache.org/jira/browse/FLINK-20992 Project: Flink Issue Type: Bug

[GitHub] [flink] AHeise merged pull request #14655: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable.

2021-01-15 Thread GitBox
AHeise merged pull request #14655: URL: https://github.com/apache/flink/pull/14655 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] flinkbot commented on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot commented on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * f24833aedc768cdd4c3fa9426e7ed07814c82923 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 1bac0fae97e00f2c2f5b2d9b0ad7f1ae97845804 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14660: [FLINK-20883][table-api-java] Support calling SQL expressions in Table API

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14660: URL: https://github.com/apache/flink/pull/14660#issuecomment-760748649 ## CI report: * 08a9fff38a4698b216fbc9cd5c25c7875db0e827 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 307e51f7f0aec480cd035bee12764f8ec10be2d7 UNKNOWN * f3d72bd76a56f59b9c5cde33d4722f5f67ef815d Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14644: [FLINK-20840][table-planner] Properly transpose projection to join

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14644: URL: https://github.com/apache/flink/pull/14644#issuecomment-760117761 ## CI report: * 0cf0db156a0ff0f1d5bca545e736732052085f73 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14640: [FLINK-20937][Table API/SQL]Drop table can fails, when i create a tab…

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14640: URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828 ## CI report: * f913de48135dfcd55733736432a234707959975a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   >