[jira] [Updated] (FLINK-20435) Refactor ExecNode

2020-12-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20435: --- Component/s: Table SQL / API > Refactor ExecNode > - > > Key: FLINK-

[jira] [Assigned] (FLINK-20435) Refactor ExecNode

2020-12-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20435: -- Assignee: godfrey he > Refactor ExecNode > - > > Key: FLINK-2

[jira] [Updated] (FLINK-20435) Refactor ExecNode

2020-12-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20435: --- Component/s: (was: Table SQL / API) Table SQL / Planner > Refactor ExecNode > -

[jira] [Created] (FLINK-20436) Simplify type parameter of ExecNod

2020-12-01 Thread godfrey he (Jira)
godfrey he created FLINK-20436: -- Summary: Simplify type parameter of ExecNod Key: FLINK-20436 URL: https://issues.apache.org/jira/browse/FLINK-20436 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #11321: URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 6744bf862394d374ae698fead26a7cb721963eba Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20437) Port ExecNode to Java

2020-12-01 Thread godfrey he (Jira)
godfrey he created FLINK-20437: -- Summary: Port ExecNode to Java Key: FLINK-20437 URL: https://issues.apache.org/jira/browse/FLINK-20437 Project: Flink Issue Type: Sub-task Reporter:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14229: [FLINK-20292][doc] Improve the document about table formats overlap in user fat jar

2020-12-01 Thread GitBox
gaoyunhaii commented on a change in pull request #14229: URL: https://github.com/apache/flink/pull/14229#discussion_r533120403 ## File path: docs/dev/table/connectors/formats/avro-confluent.md ## @@ -45,6 +45,8 @@ Dependencies connector=connector %} +**NOTE:** If you ne

[jira] [Commented] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

2020-12-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241336#comment-17241336 ] Dawid Wysakowicz commented on FLINK-20432: -- Looking into it > SQLClientSchemaR

[jira] [Assigned] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

2020-12-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20432: Assignee: Dawid Wysakowicz > SQLClientSchemaRegistryITCase hangs > --

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 8:19 AM:

[GitHub] [flink] xintongsong commented on a change in pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-12-01 Thread GitBox
xintongsong commented on a change in pull request #14241: URL: https://github.com/apache/flink/pull/14241#discussion_r533154782 ## File path: docs/deployment/security/security-kerberos.md ## @@ -87,15 +87,18 @@ Steps to run a secure Flink cluster in standalone/cluster mode: 2

[jira] [Created] (FLINK-20438) org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output

2020-12-01 Thread Matthias (Jira)
Matthias created FLINK-20438: Summary: org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output Key: FLINK-20438 URL: https://issues.apache.org/jira/browse/FLINK-20438

[GitHub] [flink] rmetzger commented on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

2020-12-01 Thread GitBox
rmetzger commented on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-736315474 I believe we should try to get this in soon, the docs are constantly broken (I broke them too) This is an auto

[jira] [Updated] (FLINK-20438) org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20438: - Description: [This build|https://dev.azure.com/mapohl/flink/_build/results?buildId=122&view=logs&j=9dc1

[GitHub] [flink] xintongsong commented on a change in pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-12-01 Thread GitBox
xintongsong commented on a change in pull request #14152: URL: https://github.com/apache/flink/pull/14152#discussion_r533161479 ## File path: docs/dev/table/streaming/joins.zh.md ## @@ -68,6 +68,189 @@ WHERE o.id = s.orderId AND +时态表 Join +-- +注意 只

[GitHub] [flink] leonardBang commented on a change in pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-12-01 Thread GitBox
leonardBang commented on a change in pull request #14152: URL: https://github.com/apache/flink/pull/14152#discussion_r533162365 ## File path: docs/dev/table/streaming/joins.zh.md ## @@ -68,6 +68,189 @@ WHERE o.id = s.orderId AND +时态表 Join +-- +注意 只

[GitHub] [flink-statefun] tzulitai opened a new pull request #182: [FLINK-20334] Introduce module YAML format version 3.0 and function endpoint templating

2020-12-01 Thread GitBox
tzulitai opened a new pull request #182: URL: https://github.com/apache/flink-statefun/pull/182 This PR adds a module YAML format version, 3.0, which supports function endpoint templating. With 3.0, users define function endpoints like so: ``` endpoints: ## An endpo

[jira] [Updated] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

2020-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20334: --- Labels: pull-request-available (was: ) > Introduce function endpoint path templating in mod

[GitHub] [flink] flinkbot edited a comment on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072 ## CI report: * cbab4c049bb5d5c410bc2a256f9285ced1761356 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-20436) Simplify type parameter of ExecNod

2020-12-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20436: --- Description: Currently, {{ExecNode#translateToPlan}} takes {{BatchPlanner}} or {{StreamPlanner}} as

[jira] [Updated] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Affects Version/s: 1.13.0 > DataStreamTests.test_key_by_on_connect_stream is failed on Azure > -

[jira] [Updated] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Component/s: (was: API / Python) > DataStreamTests.test_key_by_on_connect_stream is failed on Azure

[jira] [Updated] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Description:     Here is an instance: [https://dev.azure.com/apache-flink/apache-flink/_build/results

[jira] [Updated] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Component/s: Runtime / Coordination > DataStreamTests.test_key_by_on_connect_stream is failed on Azure >

[jira] [Updated] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Description: The actual failure of is an error in instantiating the logger: {code:java} java.lang.Except

[jira] [Updated] (FLINK-19725) Logger cannot be initialized: LoggerInitializationException is thrown

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Summary: Logger cannot be initialized: LoggerInitializationException is thrown (was: DataStreamTests.te

[jira] [Updated] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Summary: Logger cannot be initialized due to timeout: LoggerInitializationException is thrown (was: Log

[jira] [Commented] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241371#comment-17241371 ] Matthias commented on FLINK-19725: -- Another build failure happened here:  https://dev.a

[jira] [Updated] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Affects Version/s: (was: 1.13.0) 1.12.0 > Logger cannot be initialized due to

[jira] [Created] (FLINK-20439) Consider simplifying or removing mechanism to scheduleOrUpdateConsumers

2020-12-01 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-20439: --- Summary: Consider simplifying or removing mechanism to scheduleOrUpdateConsumers Key: FLINK-20439 URL: https://issues.apache.org/jira/browse/FLINK-20439 Project: Flink

[jira] [Updated] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Fix Version/s: (was: 1.12.0) 1.13.0 > Logger cannot be initialized due to timeout

[jira] [Updated] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19725: --- Priority: Critical (was: Major) > Logger cannot be initialized due to timeout: LoggerInitia

[jira] [Assigned] (FLINK-20418) NPE in IteratorSourceReader

2020-12-01 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-20418: - Assignee: Roman Khachatryan > NPE in IteratorSourceReader > ---

[jira] [Updated] (FLINK-20418) NPE in IteratorSourceReader

2020-12-01 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20418: -- Priority: Blocker (was: Critical) > NPE in IteratorSourceReader > ---

[jira] [Updated] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19725: - Description: The actual failure is an error in instantiating the logger: {code:java} java.lang.Exception

[jira] [Updated] (FLINK-20436) Simplify type parameter of ExecNode

2020-12-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20436: --- Summary: Simplify type parameter of ExecNode (was: Simplify type parameter of ExecNod) > Simplify

[GitHub] [flink] flinkbot edited a comment on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072 ## CI report: * cbab4c049bb5d5c410bc2a256f9285ced1761356 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-20438) SystemProcessingTimeServiceTest fails due to missing output

2020-12-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20438: - Summary: SystemProcessingTimeServiceTest fails due to missing output (was: org.apache.f

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-12-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241381#comment-17241381 ] Leonard Xu commented on FLINK-19863:  The test failed with timeout 30 seconds when r

[jira] [Commented] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink

2020-12-01 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241382#comment-17241382 ] Xuannan Su commented on FLINK-19343: Hi, Jin Xing. Thanks for your comments. 1. I ag

[GitHub] [flink] godfreyhe opened a new pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
godfreyhe opened a new pull request #14270: URL: https://github.com/apache/flink/pull/14270 ## What is the purpose of the change *Just as the description in [FLINK-20436](https://issues.apache.org/jira/browse/FLINK-20436), this pr aims to simplify type parameter of ExecNode, and

[jira] [Commented] (FLINK-20439) Consider simplifying or removing mechanism to scheduleOrUpdateConsumers

2020-12-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241388#comment-17241388 ] Zhu Zhu commented on FLINK-20439: - `JobMasterGateway#scheduleOrUpdateConsumers()` makes

[jira] [Updated] (FLINK-20436) Simplify type parameter of ExecNode

2020-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20436: --- Labels: pull-request-available (was: ) > Simplify type parameter of ExecNode >

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-01 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r533211602 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphVariousFailuesTest.java ## @@ -20,86 +20,31 @@ import

[GitHub] [flink] flinkbot commented on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot commented on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736341110 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] jiasheng55 opened a new pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
jiasheng55 opened a new pull request #14271: URL: https://github.com/apache/flink/pull/14271 …fore installing security modules ## What is the purpose of the change This pull request makes dynamic properties in command line taking effect before installing security modules, so t

[jira] [Updated] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12130: --- Labels: pull-request-available (was: ) > Apply command line options to configuration before

[GitHub] [flink] flinkbot commented on pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
flinkbot commented on pull request #14271: URL: https://github.com/apache/flink/pull/14271#issuecomment-736344099 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] [Updated] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20417: -- Fix Version/s: 1.13.0 1.11.3 1.12.0 > Handle "Too old re

[jira] [Updated] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20417: -- Affects Version/s: 1.12.0 1.11.2 > Handle "Too old resource version" ex

[jira] [Closed] (FLINK-20411) The annotation config do not support complex structure

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-20411. - Resolution: Information Provided > The annotation config do not support complex structure >

[jira] [Updated] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20412: -- Fix Version/s: 1.12.0 > Collect Result Fetching occasionally fails after a JobManager Failover

[jira] [Updated] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20412: -- Affects Version/s: 1.11.2 > Collect Result Fetching occasionally fails after a JobManager Fail

[jira] [Commented] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241402#comment-17241402 ] Till Rohrmann commented on FLINK-20412: --- This is probably also a problem in 1.11 b

[jira] [Updated] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20412: -- Fix Version/s: 1.11.3 > Collect Result Fetching occasionally fails after a JobManager Failover

[GitHub] [flink] flinkbot commented on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot commented on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736353538 ## CI report: * 40d11837b72f31a3c99a6eb8db755acb5309f86e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] jiasheng55 commented on a change in pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
jiasheng55 commented on a change in pull request #14271: URL: https://github.com/apache/flink/pull/14271#discussion_r533233249 ## File path: flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendInfoTest.java ## @@ -45,7 +45,7 @@ public void testMissingOption() th

[GitHub] [flink] tillrohrmann commented on pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-12-01 Thread GitBox
tillrohrmann commented on pull request #14254: URL: https://github.com/apache/flink/pull/14254#issuecomment-736355930 Thanks for the review @wangyang0918, @XComp and @rmetzger. Merging this PR now. This is an automated messa

[GitHub] [flink] jiasheng55 commented on a change in pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
jiasheng55 commented on a change in pull request #14271: URL: https://github.com/apache/flink/pull/14271#discussion_r533234805 ## File path: flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendInfoTest.java ## @@ -55,7 +55,7 @@ public void testUnrecognizedOption

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-12-01 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241404#comment-17241404 ] Victor Wong commented on FLINK-12130: - [~lingyaKK],[~zhouqi], hi, I come up with a n

[GitHub] [flink] rmetzger opened a new pull request #14272: FLINK-20426][docs] Fix broken links after Hadoop page removal

2020-12-01 Thread GitBox
rmetzger opened a new pull request #14272: URL: https://github.com/apache/flink/pull/14272 ## What is the purpose of the change I recently removed the Hadoop page, and forgot to fix some missing links. I also didn't properly update the translated pages ---

[GitHub] [flink] sllence commented on pull request #10356: [FLINK-14902][Connector-JDBC]JDBCTableSource Supports AsyncLookupFunction

2020-12-01 Thread GitBox
sllence commented on pull request #10356: URL: https://github.com/apache/flink/pull/10356#issuecomment-736360172 why close this pr,do we have any problem This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-20426) Broken links to hadoop.md

2020-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20426: --- Labels: pull-request-available (was: ) > Broken links to hadoop.md > --

[GitHub] [flink] flinkbot commented on pull request #14272: FLINK-20426][docs] Fix broken links after Hadoop page removal

2020-12-01 Thread GitBox
flinkbot commented on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736361495 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] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:56 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736353538 ## CI report: * 40d11837b72f31a3c99a6eb8db755acb5309f86e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:56 AM:

[GitHub] [flink] flinkbot commented on pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
flinkbot commented on pull request #14271: URL: https://github.com/apache/flink/pull/14271#issuecomment-736366741 ## CI report: * 4e639c6c4689a3cfc7b8c27d777f89e14b99903d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:57 AM:

[GitHub] [flink] flinkbot commented on pull request #14272: FLINK-20426][docs] Fix broken links after Hadoop page removal

2020-12-01 Thread GitBox
flinkbot commented on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736367051 ## CI report: * 1574a0979dce3046d619573b6e466475028516cb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann closed pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-12-01 Thread GitBox
tillrohrmann closed pull request #14254: URL: https://github.com/apache/flink/pull/14254 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 g

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:59 AM:

[jira] [Closed] (FLINK-20357) Rework HA documentation page

2020-12-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-20357. - Resolution: Fixed Fixed via master: 11d4136768a6072dc5085c06a386fcb9d2e9ba3b 1.12.0: 93bffc0631

[jira] [Created] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in Hop window

2020-12-01 Thread zouyunhe (Jira)
zouyunhe created FLINK-20440: Summary: `LAST_VALUE` aggregate function can not be used in Hop window Key: FLINK-20440 URL: https://issues.apache.org/jira/browse/FLINK-20440 Project: Flink Issue

[jira] [Updated] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in hop window

2020-12-01 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20440: - Summary: `LAST_VALUE` aggregate function can not be used in hop window (was: `LAST_VALUE` aggregate fun

[jira] [Updated] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in Hop window

2020-12-01 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20440: - Description: Hi,  I run a sql job which use `last_value`  aggregate function in a hop window,  the sql

[GitHub] [flink] azagrebin commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-01 Thread GitBox
azagrebin commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r532697063 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java ## @@ -1,637 +0,0 @@ -/* - * Licens

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-01 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r533275538 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java ## @@ -188,7 +188,7 @@ public void start(ComponentMai

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-01 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r533275742 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphNotEnoughResourceTest.java ## @@ -113,29 +119,28 @@ publ

[GitHub] [flink] flinkbot edited a comment on pull request #14270: [FLINK-20436][table-planner-blink] Simplify type parameter of ExecNode

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14270: URL: https://github.com/apache/flink/pull/14270#issuecomment-736353538 ## CI report: * 40d11837b72f31a3c99a6eb8db755acb5309f86e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14271: URL: https://github.com/apache/flink/pull/14271#issuecomment-736366741 ## CI report: * 4e639c6c4689a3cfc7b8c27d777f89e14b99903d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14272: FLINK-20426][docs] Fix broken links after Hadoop page removal

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736367051 ## CI report: * 1574a0979dce3046d619573b6e466475028516cb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-01 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241426#comment-17241426 ] Jiayi Liao commented on FLINK-19970: [~Jamalarm]  Do you figure out the root cause o

[GitHub] [flink] tillrohrmann commented on a change in pull request #14268: [FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDurin

2020-12-01 Thread GitBox
tillrohrmann commented on a change in pull request #14268: URL: https://github.com/apache/flink/pull/14268#discussion_r533296691 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionConnectionHandlingTest.java ## @@ -281,6 +2

[GitHub] [flink] kl0u closed pull request #14157: [FLINK-19969] CLI print run-application help msg

2020-12-01 Thread GitBox
kl0u closed pull request #14157: URL: https://github.com/apache/flink/pull/14157 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 the

[jira] [Created] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery

2020-12-01 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20441: - Summary: Deprecate CheckpointConfig.setPreferCheckpointForRecovery Key: FLINK-20441 URL: https://issues.apache.org/jira/browse/FLINK-20441 Project: Flink I

[jira] [Closed] (FLINK-19969) CliFrontendParser does not provide any help for run-application

2020-12-01 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19969. -- Fix Version/s: 1.13.0 Resolution: Fixed master: 3ecb27dc1ef7cb838d556c53aabb7bf327bc249

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * fe1562c5cda8ecb15f6af1afdf7b6217e6c20c42 UNKNOWN * 20de9eefa4d4eb7c8b740cd88fc69f1e764b

[jira] [Closed] (FLINK-20434) Getting The desired archetype does not exist

2020-12-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20434. Resolution: Not A Problem 1.12 is not released yet. Please use 1.11.2 as the archetype ver

[GitHub] [flink] flinkbot edited a comment on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072 ## CI report: * 97957722ab7b8af6d39a488d883220a14f66b302 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14268: [FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDuringInitiali

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14268: URL: https://github.com/apache/flink/pull/14268#issuecomment-736254887 ## CI report: * 00f90b8b5cffb48983182b4d530a6158061037a4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann opened a new pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

2020-12-01 Thread GitBox
tillrohrmann opened a new pull request #14273: URL: https://github.com/apache/flink/pull/14273 CheckpointConfig.setPreferCheckpointForRecovery(true) can lead to data loss and duplicate outputs. Hence, it is no longer recommended to use. -

[jira] [Updated] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery

2020-12-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20441: --- Labels: pull-request-available (was: ) > Deprecate CheckpointConfig.setPreferCheckpointForR

[GitHub] [flink] flinkbot commented on pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

2020-12-01 Thread GitBox
flinkbot commented on pull request #14273: URL: https://github.com/apache/flink/pull/14273#issuecomment-736422244 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] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-01 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241445#comment-17241445 ] Thomas Wozniakowski commented on FLINK-19970: - Hi [~wind_ljy], No, we didn'

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * fe1562c5cda8ecb15f6af1afdf7b6217e6c20c42 UNKNOWN * 20de9eefa4d4eb7c8b740cd88fc69f1e764b

[GitHub] [flink] flinkbot edited a comment on pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14271: URL: https://github.com/apache/flink/pull/14271#issuecomment-736366741 ## CI report: * 4e639c6c4689a3cfc7b8c27d777f89e14b99903d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14272: [FLINK-20426][docs] Fix broken links after Hadoop page removal

2020-12-01 Thread GitBox
flinkbot edited a comment on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736367051 ## CI report: * 1574a0979dce3046d619573b6e466475028516cb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

2020-12-01 Thread GitBox
flinkbot commented on pull request #14273: URL: https://github.com/apache/flink/pull/14273#issuecomment-736437400 ## CI report: * 842a2f76ac5abee4c8c7f9bf88309650a3565b74 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] florianakos commented on a change in pull request #13995: [FLINK-20055] [runtime/config] - hide sensitive datadog API key from logs

2020-12-01 Thread GitBox
florianakos commented on a change in pull request #13995: URL: https://github.com/apache/flink/pull/13995#discussion_r533341428 ## File path: flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java ## @@ -44,7 +44,8 @@ public static final Strin

  1   2   3   4   >