[GitHub] [flink] wuchong merged pull request #14917: [FLINK-21225][table] Support OVER window distinct aggregates in Table API

2021-02-12 Thread GitBox
wuchong merged pull request #14917: URL: https://github.com/apache/flink/pull/14917 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] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283740#comment-17283740 ] Andrew Roberts commented on FLINK-14034: [~pnowojski] the catch here is, ultimately something

[jira] [Comment Edited] (FLINK-21263) Job hangs under backpressure

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283724#comment-17283724 ] Piotr Nowojski edited comment on FLINK-21263 at 2/12/21, 2:48 PM: -- Hi

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * f2277c1fb0bc95a1bdebc9d140f9eaa56ec18d0b Azure:

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

2021-02-12 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 *

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283735#comment-17283735 ] Piotr Nowojski commented on FLINK-14034: [~arobe...@fuze.com] extending the sink is not a good

[jira] [Commented] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

2021-02-12 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283726#comment-17283726 ] Kezhu Wang commented on FLINK-20580: {quote} If we want to support null values, then returning an

[jira] [Closed] (FLINK-21295) Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21295. --- Resolution: Fixed Fixed in master: 75327e0a14c69c739665a34d8d3a7705b0c11d35 > Support 'useModules' and

[GitHub] [flink] wuchong merged pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-12 Thread GitBox
wuchong merged pull request #14895: URL: https://github.com/apache/flink/pull/14895 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] [Commented] (FLINK-21263) Job hangs under backpressure

2021-02-12 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283724#comment-17283724 ] Arvid Heise commented on FLINK-21263: - Hi Lu, I have not immediately found a known issue that is

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * 1cc67b837c2e6c4e1eb982b482e3798ee5f24a51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * af8de65a4905ae47ab704a75acfcd1b2e897d915 UNKNOWN * 772e076ed9d773e16713236c942f4e30b659d6eb UNKNOWN *

[jira] [Updated] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21306: --- Fix Version/s: 1.13.0 > FlinkSecurityManager might avoid fatal system exits >

[jira] [Closed] (FLINK-18139) Unaligned checkpoints checks wrong channels for inflight data.

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18139. -- > Unaligned checkpoints checks wrong channels for inflight data. >

[GitHub] [flink] SteNicholas commented on a change in pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-02-12 Thread GitBox
SteNicholas commented on a change in pull request #14822: URL: https://github.com/apache/flink/pull/14822#discussion_r575254129 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/TableSinkITCase.scala ## @@

[GitHub] [flink] zentol commented on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-12 Thread GitBox
zentol commented on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-778215873 Oh god, the failure happens because of the DeclarativeSchedulerTest. That test fails the main thread validation checks and then terminates the JVM, killing other tests in the

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-12 Thread GitBox
XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r575246034 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java ## @@ -605,6 +625,414 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * af8de65a4905ae47ab704a75acfcd1b2e897d915 UNKNOWN * 772e076ed9d773e16713236c942f4e30b659d6eb UNKNOWN *

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283708#comment-17283708 ] Andrew Roberts commented on FLINK-14034: [~pnowojski] a wrapper class means re-implementing all

[jira] [Commented] (FLINK-20612) Add benchmarks for scheduler

2021-02-12 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283707#comment-17283707 ] Zhilong Hong commented on FLINK-20612: -- Thanks for reminding, [~pnowojski]. For the first one,

[jira] [Commented] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283704#comment-17283704 ] Piotr Nowojski commented on FLINK-21241: [~yunta] why did you think this issue affected 1.11.x

[jira] [Updated] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21241: --- Fix Version/s: (was: 1.12.2) (was: 1.11.4) > E2E test exception

[jira] [Updated] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21241: --- Affects Version/s: (was: 1.12.1) (was: 1.11.3) > E2E test

[jira] [Commented] (FLINK-21237) Reflects the actual running state of the job

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283701#comment-17283701 ] Till Rohrmann commented on FLINK-21237: --- Thanks for creating this issue [~clevermose]. The problem

[jira] [Closed] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21241. -- Resolution: Duplicate > E2E test exception check might fail if older checkpoint not completed

[jira] [Commented] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283699#comment-17283699 ] Till Rohrmann commented on FLINK-20580: --- Thanks for further looking into the problem [~kezhuw]. I

[jira] [Updated] (FLINK-21237) Reflects the actual running state of the job

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21237: --- Component/s: (was: Runtime / Task) Runtime / Coordination > Reflects

[jira] [Closed] (FLINK-20893) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel test failed with "TestTimedOutException"

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20893. -- Resolution: Fixed We have rewritten the test in release-1.12 branch to use less resources,

[jira] [Updated] (FLINK-20893) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel test failed with "TestTimedOutException"

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20893: --- Fix Version/s: 1.12.0 >

[jira] [Commented] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

2021-02-12 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283680#comment-17283680 ] Kezhu Wang commented on FLINK-20580: I am kind of prefer third option. If we allow nullable value

[jira] [Updated] (FLINK-14052) Generalize AkkaOptions to RpcOptions

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14052: -- Priority: Minor (was: Major) > Generalize AkkaOptions to RpcOptions >

[jira] [Closed] (FLINK-14052) Generalize AkkaOptions to RpcOptions

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14052. - Resolution: Later Maybe later. > Generalize AkkaOptions to RpcOptions >

[jira] [Commented] (FLINK-14052) Generalize AkkaOptions to RpcOptions

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283677#comment-17283677 ] Till Rohrmann commented on FLINK-14052: --- In general I think that this would still be nice to clean

[jira] [Commented] (FLINK-20612) Add benchmarks for scheduler

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283676#comment-17283676 ] Piotr Nowojski commented on FLINK-20612: [~Thesharing] some benchmarks are a bit unstable. I'm

[jira] [Closed] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9648. Resolution: Won't Fix > Do not store distributed cache entries in ExecutionConfig >

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * 4c8bc864776e0923683d1e60a1da38a12e9a52d0 Azure:

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

2021-02-12 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 *

[jira] [Commented] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

2021-02-12 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283659#comment-17283659 ] Kezhu Wang commented on FLINK-20580: Hi [~trohrmann], after digging a bit, I think we had third

[GitHub] [flink] flinkbot edited a comment on pull request #14919: [FLINK-21338][test] Relax ITCase naming constraints

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14919: URL: https://github.com/apache/flink/pull/14919#issuecomment-776686704 ## CI report: * 7a95b8eb6d45c5e3c38f0c6cbed995b6d81a640b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14930: [FLINK-21339][tests] Enable and fix ExceptionUtilsITCase

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14930: URL: https://github.com/apache/flink/pull/14930#issuecomment-778161603 ## CI report: * 2871d67e16ca1a58ab47320fcac05f36c1011662 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * 4c8bc864776e0923683d1e60a1da38a12e9a52d0 Azure:

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283648#comment-17283648 ] Piotr Nowojski commented on FLINK-10320: CC [~Thesharing] [~zhuzh]? > Introduce JobMaster

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283647#comment-17283647 ] Piotr Nowojski commented on FLINK-14034: I was thinking for a minute if we can provide a more

[GitHub] [flink] flinkbot commented on pull request #14930: [FLINK-21339][tests] Enable and fix ExceptionUtilsITCase

2021-02-12 Thread GitBox
flinkbot commented on pull request #14930: URL: https://github.com/apache/flink/pull/14930#issuecomment-778161603 ## CI report: * 2871d67e16ca1a58ab47320fcac05f36c1011662 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14919: [FLINK-21338][test] Relax ITCase naming constraints

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14919: URL: https://github.com/apache/flink/pull/14919#issuecomment-776686704 ## CI report: * 7a95b8eb6d45c5e3c38f0c6cbed995b6d81a640b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 3728eac2196a5117eb95c617f7a6c77dd77d7f35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 3728eac2196a5117eb95c617f7a6c77dd77d7f35 Azure:

[GitHub] [flink] flinkbot commented on pull request #14930: [FLINK-21339][tests] Enable and fix ExceptionUtilsITCase

2021-02-12 Thread GitBox
flinkbot commented on pull request #14930: URL: https://github.com/apache/flink/pull/14930#issuecomment-778152501 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

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

2021-02-12 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 *

[GitHub] [flink] zentol opened a new pull request #14930: [FLINK-21339][tests] Enable and fix ExceptionUtilsITCase

2021-02-12 Thread GitBox
zentol opened a new pull request #14930: URL: https://github.com/apache/flink/pull/14930 - the test was not run due to a trailing 's' - the test was failing on CI because we set JAVA_TOOL_OPTIONS which affects the output of java processes; we now start the processes with a cleaned

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283631#comment-17283631 ] Stephan Ewen commented on FLINK-21133: -- I see, the remaining problem is that exiting the mailbox

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * 1cc67b837c2e6c4e1eb982b482e3798ee5f24a51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 341578b2d03693afbd8179683c6f2696c229 UNKNOWN * a8b33d4c0b2174cd4ef8d86611cdf714f3728df0 Azure:

[jira] [Comment Edited] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283626#comment-17283626 ] Piotr Nowojski edited comment on FLINK-20376 at 2/12/21, 11:26 AM: ---

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

2021-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283626#comment-17283626 ] Piotr Nowojski commented on FLINK-20376: {{uid("a")}}, {{uid("b")}} and {{uid("c")}} are

[jira] [Created] (FLINK-21368) Consider removing RpcService#getExecutor

2021-02-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21368: Summary: Consider removing RpcService#getExecutor Key: FLINK-21368 URL: https://issues.apache.org/jira/browse/FLINK-21368 Project: Flink Issue Type:

[jira] [Closed] (FLINK-18480) JobManager lost zk connection, HA can not work

2021-02-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-18480. Resolution: Won't Fix I'm gonna close this issue for now. [~AlberyZJG] feel free to open it again if you

[jira] [Closed] (FLINK-17024) Make AkkaRpcService#getExecutor return a custom thread pool

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17024. Resolution: Won't Fix > Make AkkaRpcService#getExecutor return a custom thread pool >

[jira] [Closed] (FLINK-9836) Add template for vote canceling to release guide

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9836. - Resolution: Won't Fix > Add template for vote canceling to release guide >

[jira] [Commented] (FLINK-20696) Yarn Session Blob Directory is not deleted.

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283621#comment-17283621 ] Robert Metzger commented on FLINK-20696: Since there is no more activity on this ticket, I'm

[jira] [Comment Edited] (FLINK-20367) Show the in-use config of job to users

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265925#comment-17265925 ] Robert Metzger edited comment on FLINK-20367 at 2/12/21, 11:06 AM: ---

[jira] [Commented] (FLINK-20367) Show the in-use config of job to users

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283620#comment-17283620 ] Robert Metzger commented on FLINK-20367: Since there's no more activity on this ticket, I'll

[jira] [Commented] (FLINK-14052) Generalize AkkaOptions to RpcOptions

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283619#comment-17283619 ] Chesnay Schepler commented on FLINK-14052: -- [~trohrmann] Do we still want to do this? >

[jira] [Closed] (FLINK-18841) CVE-2018-10237 and CWE-400 occurred in flink dependency

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18841. Resolution: Later The table planner already uses guava 29.0-jre. We can bump the

[jira] [Created] (FLINK-21367) Support objectReuse in JDBC sink

2021-02-12 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21367: - Summary: Support objectReuse in JDBC sink Key: FLINK-21367 URL: https://issues.apache.org/jira/browse/FLINK-21367 Project: Flink Issue Type:

[jira] [Closed] (FLINK-5961) Queryable State is broken for HeapKeyedStateBackend

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5961. Resolution: Won't Do Queryable state is currently no longer supported. > Queryable State is

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 3728eac2196a5117eb95c617f7a6c77dd77d7f35 Azure:

[jira] [Commented] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283615#comment-17283615 ] Till Rohrmann commented on FLINK-18681: --- [~apach...@163.com] do you still experience the problem?

[jira] [Commented] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283614#comment-17283614 ] Chesnay Schepler commented on FLINK-9648: - Given how niche this feature is I don't think it makes

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

2021-02-12 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 *

[jira] [Closed] (FLINK-18451) Flink HA on yarn may appear TaskManager double running when HA is restored

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18451. - Resolution: Abandoned The problem seems to be specific to the reporter's environment. Closing

[jira] [Commented] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

2021-02-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283612#comment-17283612 ] Matthias commented on FLINK-17560: -- [~josson] Did you have a chance to reproduce the issue with an

[jira] [Commented] (FLINK-13660) Cannot submit job on Flink session cluster on kubernetes with multiple JM pods (zk HA) through web frontend

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283611#comment-17283611 ] Chesnay Schepler commented on FLINK-13660: -- This is somewhat a duplicate of FLINK-18312; it

[jira] [Updated] (FLINK-21146) 【SQL】Flink SQL Client not support specify the queue to submit the job

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21146: --- Component/s: (was: Deployment / YARN) > 【SQL】Flink SQL Client not support specify the

[jira] [Commented] (FLINK-18551) Don't need to download flink-conf.yaml when launching taskmanager on Yarn mode

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283609#comment-17283609 ] Till Rohrmann commented on FLINK-18551: --- [~Yumeng] do you wanna try to tackle this issue? > Don't

[jira] [Commented] (FLINK-18171) Do not take client side config options to cluster

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283608#comment-17283608 ] Till Rohrmann commented on FLINK-18171: --- Given the other things we wanna do, is this really

[jira] [Updated] (FLINK-18171) Do not take client side config options to cluster

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18171: -- Component/s: Runtime / Configuration > Do not take client side config options to cluster >

[jira] [Assigned] (FLINK-12221) Distinguish long tail task based on IOMetrics

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-12221: -- Assignee: (was: BoWang) > Distinguish long tail task based on IOMetrics >

[jira] [Assigned] (FLINK-15736) Support Java 17 (LTS)

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15736: - Assignee: (was: Chesnay Schepler) > Support Java 17 (LTS) > -

[jira] [Commented] (FLINK-17549) Support running Stateful Functions on native Kubernetes setup

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283604#comment-17283604 ] Till Rohrmann commented on FLINK-17549: --- [~felixzheng], [~igal] what is the status of this ticket?

[jira] [Closed] (FLINK-9335) Expose client logs via Flink UI

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9335. --- Resolution: Won't Fix > Expose client logs via Flink UI > --- >

[jira] [Closed] (FLINK-5787) Unable to run jobs uploaded from IE

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5787. --- Resolution: Won't Fix > Unable to run jobs uploaded from IE >

[jira] [Commented] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283603#comment-17283603 ] Till Rohrmann commented on FLINK-9648: -- [~chesnay] shall we do this later and close it for the time

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * 1cc67b837c2e6c4e1eb982b482e3798ee5f24a51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 02fe750c8c6a92b2dd4fffb42b84cc68445f300b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-02-12 Thread GitBox
flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * 4c8bc864776e0923683d1e60a1da38a12e9a52d0 Azure:

[jira] [Closed] (FLINK-9747) Release guide ambigous regarding release branches

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9747. - Resolution: Won't Fix > Release guide ambigous regarding release branches >

[jira] [Commented] (FLINK-9747) Release guide ambigous regarding release branches

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283602#comment-17283602 ] Robert Metzger commented on FLINK-9747: --- I don't think this is too much of a problem. This has been

[jira] [Updated] (FLINK-15659) Introduce a client-side StatusWatcher for JM Pods

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15659: -- Priority: Minor (was: Major) > Introduce a client-side StatusWatcher for JM Pods >

[jira] [Commented] (FLINK-13551) Add vertex FlameGraph REST endpoint

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283601#comment-17283601 ] Till Rohrmann commented on FLINK-13551: --- [~afedulov] do you need this ticket for the FlameGraph

[jira] [Assigned] (FLINK-13551) Add vertex FlameGraph REST endpoint

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13551: - Assignee: (was: David Morávek) > Add vertex FlameGraph REST endpoint >

[jira] [Closed] (FLINK-11963) Add time-based cleanup mechanism in history server

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11963. Resolution: Won't Fix > Add time-based cleanup mechanism in history server >

[jira] [Commented] (FLINK-13660) Cannot submit job on Flink session cluster on kubernetes with multiple JM pods (zk HA) through web frontend

2021-02-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283599#comment-17283599 ] Matthias commented on FLINK-13660: -- [~chesnay] should we change the UI here to disable the Jar upload

[jira] [Commented] (FLINK-14869) Force an extended resource to be null if it's value is 0

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283600#comment-17283600 ] Till Rohrmann commented on FLINK-14869: --- cc [~xintongsong]. Is this a problem for the fine grained

[jira] [Commented] (FLINK-9796) Add failure handling to release guide

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283596#comment-17283596 ] Robert Metzger commented on FLINK-9796: --- I extended the guide about the cancellation:

[jira] [Closed] (FLINK-13929) Revisit REST & JM URL

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13929. - Resolution: Abandoned Nobody else seems to have complained about the configuration recently.

[jira] [Closed] (FLINK-9796) Add failure handling to release guide

2021-02-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9796. - Resolution: Fixed > Add failure handling to release guide >

[jira] [Commented] (FLINK-16050) Add Attempt Information

2021-02-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283595#comment-17283595 ] Matthias commented on FLINK-16050: -- [~vthinkxie] [~lining] What's the progress on this issue? It's

[jira] [Updated] (FLINK-13929) Revisit REST & JM URL

2021-02-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13929: -- Priority: Minor (was: Major) > Revisit REST & JM URL > -- > >

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2021-02-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283593#comment-17283593 ] Chesnay Schepler commented on FLINK-10320: -- Is this a duplicate of FLINK-20612? > Introduce

<    1   2   3   >