[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244654#comment-17244654 ] Kezhu Wang commented on FLINK-19435: Seems that this problem still exist. I have pus

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245245#comment-17245245 ] Kezhu Wang commented on FLINK-19435: [~jark] I am willing to take over this. Curren

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245593#comment-17245593 ] Kezhu Wang commented on FLINK-19435: {quote} Do you have use cases that show switchi

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245594#comment-17245594 ] Kezhu Wang commented on FLINK-19435: [~roman_khachatryan] Inside {{DriverManager.get

[jira] [Comment Edited] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245594#comment-17245594 ] Kezhu Wang edited comment on FLINK-19435 at 12/8/20, 1:09 AM:

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245898#comment-17245898 ] Kezhu Wang commented on FLINK-19435: [~lzljs3620320] From capability side, it is nic

[jira] [Created] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

Kezhu Wang created FLINK-20614: -- Summary: Registered sql drivers not deregistered after task finished in session cluster Key: FLINK-20614 URL: https://issues.apache.org/jira/browse/FLINK-20614 Project: F

[jira] [Commented] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250391#comment-17250391 ] Kezhu Wang commented on FLINK-20614: [~chesnay] Sorry, I did not aware of FLINK-1900

[jira] [Created] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider

Kezhu Wang created FLINK-20657: -- Summary: Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider Key: FLINK-20657 URL: https://issues.apache.org

[jira] [Created] (FLINK-20658) Make sure jdbc connection is established by target driver

Kezhu Wang created FLINK-20658: -- Summary: Make sure jdbc connection is established by target driver Key: FLINK-20658 URL: https://issues.apache.org/jira/browse/FLINK-20658 Project: Flink Issue T

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

[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252169#comment-17252169 ] Kezhu Wang commented on FLINK-20432: Two more cases after timeout changed ? * FLINK-

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252182#comment-17252182 ] Kezhu Wang commented on FLINK-20389: Another case about {{NullPointerException}} fro

[jira] [Comment Edited] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252182#comment-17252182 ] Kezhu Wang edited comment on FLINK-20389 at 12/19/20, 1:23 PM: ---

[jira] [Commented] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252423#comment-17252423 ] Kezhu Wang commented on FLINK-20614: [~chesnay] Sorry for ping you again. I thought

[jira] [Commented] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252450#comment-17252450 ] Kezhu Wang commented on FLINK-20657: I see {{SimpleJdbcConnectionProvider}} has been

[jira] [Commented] (FLINK-20658) Make sure jdbc connection is established by target driver

[ https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252454#comment-17252454 ] Kezhu Wang commented on FLINK-20658: It is a step to driver class customization disc

[jira] [Commented] (FLINK-20658) Make sure jdbc connection is established by target driver

[ https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252554#comment-17252554 ] Kezhu Wang commented on FLINK-20658: hmm..., the proposal I posted above actually do

[jira] [Commented] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225024#comment-17225024 ] Kezhu Wang commented on FLINK-19448: [~sewen] Seems that [68c5c2ff779d82a1ff81ffaf6

[jira] [Commented] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225505#comment-17225505 ] Kezhu Wang commented on FLINK-19448: I think I may find the cause. First, let's see

[jira] [Commented] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227464#comment-17227464 ] Kezhu Wang commented on FLINK-19448: I think we can fix this by adding {{elementsQue

[jira] [Commented] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228271#comment-17228271 ] Kezhu Wang commented on FLINK-19448: [~sewen] Yes. Returning {{MORE_AVAILABLE}} is b

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230315#comment-17230315 ] Kezhu Wang commented on FLINK-19864: I think this is probably caused by misuse of {{

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233174#comment-17233174 ] Kezhu Wang commented on FLINK-19864: How about using a combination of {{Thread.isAli

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233643#comment-17233643 ] Kezhu Wang commented on FLINK-19864: [~trohrmann] [~pnowojski] [~chesnay] [~AHeise]

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233772#comment-17233772 ] Kezhu Wang commented on FLINK-19864: [~AHeise] I think {{InputStatus}} is not enough

[jira] [Comment Edited] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233772#comment-17233772 ] Kezhu Wang edited comment on FLINK-19864 at 11/19/20, 1:28 PM: ---

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235480#comment-17235480 ] Kezhu Wang commented on FLINK-19864: [~AHeise] I will open a PR as soon as possible

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190870#comment-17190870 ] Kezhu Wang commented on FLINK-18815: [~trohrmann] Your are right, I made mistake. Af

[jira] [Commented] (FLINK-19212) Failed to serialize the result for RPC call : requestTaskManagerInfo.

[ https://issues.apache.org/jira/browse/FLINK-19212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194971#comment-17194971 ] Kezhu Wang commented on FLINK-19212: [~klden] Seems that this has fixed by [FLINK-1

[jira] [Commented] (FLINK-19266) Test fail when running azure in AbstractCloseableRegistryTest#testClose

[ https://issues.apache.org/jira/browse/FLINK-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198874#comment-17198874 ] Kezhu Wang commented on FLINK-19266: Hi [~hailong wang], it is already reported as

[jira] [Created] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

Kezhu Wang created FLINK-21132: -- Summary: BoundedOneInput.endInput is called when taking synchronous savepoint Key: FLINK-21132 URL: https://issues.apache.org/jira/browse/FLINK-21132 Project: Flink

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

Kezhu Wang created FLINK-21133: -- Summary: FLIP-27 Source does not work with synchronous savepoint Key: FLINK-21133 URL: https://issues.apache.org/jira/browse/FLINK-21133 Project: Flink Issue Typ

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kezhu Wang updated FLINK-21133: --- Affects Version/s: 1.11.3 1.12.1 > FLIP-27 Source does not work with synchron

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272503#comment-17272503 ] Kezhu Wang commented on FLINK-21132: [~pnowojski] For option#2, which is the current

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273052#comment-17273052 ] Kezhu Wang commented on FLINK-21132: I did not find an easy/viable way to distinguis

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274380#comment-17274380 ] Kezhu Wang commented on FLINK-21132: If we agree that stop-with-savepoint should not

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275234#comment-17275234 ] Kezhu Wang commented on FLINK-21132: [~aljoscha] [~pnowojski]  [~roman_khachatryan] 

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276235#comment-17276235 ] Kezhu Wang commented on FLINK-21132: Hi [~roman_khachatryan], thanks for reviewing,

[jira] [Comment Edited] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276235#comment-17276235 ] Kezhu Wang edited comment on FLINK-21132 at 2/1/21, 10:29 AM:

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276558#comment-17276558 ] Kezhu Wang commented on FLINK-21132: Currently, there is no {{runSynchronousSavepoin

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277171#comment-17277171 ] Kezhu Wang commented on FLINK-21132: You are right [~pnowojski], it depends on wheth

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277194#comment-17277194 ] Kezhu Wang commented on FLINK-21132: {quote} Keep in mind that while task is spinnin

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277199#comment-17277199 ] Kezhu Wang commented on FLINK-21132: {quote}It's not ideal what we have at the momen

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277217#comment-17277217 ] Kezhu Wang commented on FLINK-21132: {quote} there will be nobody to relieve the ups

[jira] [Commented] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808>

[ https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278579#comment-17278579 ] Kezhu Wang commented on FLINK-21175: [~maguowei] [~AHeise] [~roman_khachatryan] FLIN

[jira] [Commented] (FLINK-19489) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent gets stuck

[ https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207865#comment-17207865 ] Kezhu Wang commented on FLINK-19489: After dived in, I think this could be a bug of

[jira] [Commented] (FLINK-19427) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent is instable

[ https://issues.apache.org/jira/browse/FLINK-19427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208634#comment-17208634 ] Kezhu Wang commented on FLINK-19427: I could image the execution steps for this fail

[jira] [Commented] (FLINK-19489) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent gets stuck

[ https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208723#comment-17208723 ] Kezhu Wang commented on FLINK-19489: Here are my imaginative execution flows for thi

[jira] [Commented] (FLINK-19489) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent gets stuck

[ https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212498#comment-17212498 ] Kezhu Wang commented on FLINK-19489: Sorry for late update. I have reported it to op

[jira] [Commented] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212533#comment-17212533 ] Kezhu Wang commented on FLINK-19448: Neither did I. But I found {{SourceReaderBase}}

[jira] [Created] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

Kezhu Wang created FLINK-21317: -- Summary: Downstream keyed state not work after FlinkKafkaShuffle Key: FLINK-21317 URL: https://issues.apache.org/jira/browse/FLINK-21317 Project: Flink Issue Typ

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17280863#comment-17280863 ] Kezhu Wang commented on FLINK-21317: Hi [~ym], I found this in code reading not prod

[jira] [Created] (FLINK-21320) Stream from FlinkKafkaShuffle.persistentKeyBy does not end if upstream ends

Kezhu Wang created FLINK-21320: -- Summary: Stream from FlinkKafkaShuffle.persistentKeyBy does not end if upstream ends Key: FLINK-21320 URL: https://issues.apache.org/jira/browse/FLINK-21320 Project: Flin

[jira] [Commented] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask

[ https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281480#comment-17281480 ] Kezhu Wang commented on FLINK-21323: [~mapohl]  [~roman_khachatryan] FLIP-27 sources

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281491#comment-17281491 ] Kezhu Wang commented on FLINK-17170: I think it is problem of {{FlinkKinesisConsumer

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281492#comment-17281492 ] Kezhu Wang commented on FLINK-17170: {quote} In stop-with-savepoint path, {{FlinkKin

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281563#comment-17281563 ] Kezhu Wang commented on FLINK-21132: {quote}I saw a hole in notifyCheckpointAbortAsy

[jira] [Commented] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask

[ https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281568#comment-17281568 ] Kezhu Wang commented on FLINK-21323: [~mapohl] [~roman_khachatryan] [~pnowojski] May

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282188#comment-17282188 ] Kezhu Wang commented on FLINK-21028: [~trohrmann] [~pnowojski] Thanks for renew, I u

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282253#comment-17282253 ] Kezhu Wang commented on FLINK-21133: Hi all, there are actually two cases for FLIP-2

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282263#comment-17282263 ] Kezhu Wang commented on FLINK-21133: [~becket_qin] Sorry for not aware of your comme

[jira] [Comment Edited] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282305#comment-17282305 ] Kezhu Wang edited comment on FLINK-21028 at 2/10/21, 8:29 AM:

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282305#comment-17282305 ] Kezhu Wang commented on FLINK-21028: {quote}but something would have to trigger Sour

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282564#comment-17282564 ] Kezhu Wang commented on FLINK-21133: {quote}I think what stop-with-savepoint should

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

[ https://issues.apache.org/jira/browse/FLINK-19763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283125#comment-17283125 ] Kezhu Wang commented on FLINK-19763: Hi all, I checked the reverted commit and think

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

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283134#comment-17283134 ] Kezhu Wang commented on FLINK-20580: [~mapohl] [~trohrmann]  May be better to not nu

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

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283227#comment-17283227 ] Kezhu Wang commented on FLINK-20580: [~trohrmann] Yeh, I could give it a try. > Mis

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

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283659#comment-17283659 ] Kezhu Wang commented on FLINK-20580: Hi [~trohrmann], after digging a bit, I think w

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

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283680#comment-17283680 ] Kezhu Wang commented on FLINK-20580: I am kind of prefer third option. If we allow

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

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283726#comment-17283726 ] Kezhu Wang commented on FLINK-20580: {quote} If we want to support null values, then

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284169#comment-17284169 ] Kezhu Wang commented on FLINK-21214: Another instance: https://dev.azure.com/apache

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285207#comment-17285207 ] Kezhu Wang commented on FLINK-21133: {quote}I think what stop-with-savepoint should

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285250#comment-17285250 ] Kezhu Wang commented on FLINK-21317: [~pnowojski] Yeh, I could prepare a fix if my p

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285319#comment-17285319 ] Kezhu Wang commented on FLINK-21133: {quote}But this assumption doesn't hold with th

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285319#comment-17285319 ] Kezhu Wang edited comment on FLINK-21133 at 2/16/21, 4:21 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287735#comment-17287735 ] Kezhu Wang commented on FLINK-21133: [~becket_qin] [~pnowojski] [~sewen] Thanks all

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

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288477#comment-17288477 ] Kezhu Wang commented on FLINK-21133: [~trohrmann] Great summarization! About user-c

[jira] [Created] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

Kezhu Wang created FLINK-21467: -- Summary: Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times Key: FLINK-21467 URL: https://issues.apache.or

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290781#comment-17290781 ] Kezhu Wang commented on FLINK-21467: Hi [~pnowojski], I see the possibility. But I t

[jira] [Commented] (FLINK-20658) Make sure jdbc connection is established by target driver

[ https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291751#comment-17291751 ] Kezhu Wang commented on FLINK-20658: [~jark] Sorry for so late response. I confirmed

[jira] [Commented] (FLINK-21386) FromElements ignores returns()

[ https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292152#comment-17292152 ] Kezhu Wang commented on FLINK-21386: I think implementing {{OutputTypeConfigurable}}

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292316#comment-17292316 ] Kezhu Wang commented on FLINK-21467: Hi [~pnowojski], I think the "non deterministic

[jira] [Created] (FLINK-21522) Iterative stream could not work with stop-with-savepoint

Kezhu Wang created FLINK-21522: -- Summary: Iterative stream could not work with stop-with-savepoint Key: FLINK-21522 URL: https://issues.apache.org/jira/browse/FLINK-21522 Project: Flink Issue Ty

[jira] [Commented] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292359#comment-17292359 ] Kezhu Wang commented on FLINK-21025: Another instance https://dev.azure.com/apache-

[jira] [Commented] (FLINK-21386) FromElements ignores returns()

[ https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292765#comment-17292765 ] Kezhu Wang commented on FLINK-21386:  [~chesnay] Combination of #1 and #3 could solv

[jira] [Commented] (FLINK-21386) FromElements ignores returns()

[ https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292839#comment-17292839 ] Kezhu Wang commented on FLINK-21386: [~chesnay] It works for function also, I have v

[jira] [Created] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS

Kezhu Wang created FLINK-12491: -- Summary: Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS Key: FLINK-12491 URL: https://issues.apache.org/jira/browse/FLINK-12491 Project: Fl

[jira] [Commented] (FLINK-18571) when i use sql-client write to hive but throw a exception "This is a bug. Please consider filing an issue"

[ https://issues.apache.org/jira/browse/FLINK-18571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155935#comment-17155935 ] Kezhu Wang commented on FLINK-18571: [~JasonLee] I guess you are using 1.11 client t

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190276#comment-17190276 ] Kezhu Wang commented on FLINK-18815: Seems that recently two cases are leaking while

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173926#comment-17173926 ] Kezhu Wang commented on FLINK-18815: I think this is caused by {{SafetyNetCloseable

[jira] [Commented] (FLINK-32480) Keyed State always returns new value instance

[ https://issues.apache.org/jira/browse/FLINK-32480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754403#comment-17754403 ] Kezhu Wang commented on FLINK-32480: Flink never provide such a guarantee. The "Expe

[jira] [Commented] (FLINK-21821) Clean up Task/StreamTask cancellation and remove unnecessary concurrency

[ https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305690#comment-17305690 ] Kezhu Wang commented on FLINK-21821: Thanks for more context [~pnowojski]. After clo

[jira] [Comment Edited] (FLINK-21821) Clean up Task/StreamTask cancellation and remove unnecessary concurrency

[ https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305690#comment-17305690 ] Kezhu Wang edited comment on FLINK-21821 at 3/21/21, 2:42 PM:

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306227#comment-17306227 ] Kezhu Wang commented on FLINK-21467: Hi  [~pnowojski], here are my imaginative paths

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306805#comment-17306805 ] Kezhu Wang commented on FLINK-21817: I guess we four are probably talking about two

[jira] [Commented] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper

[ https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306807#comment-17306807 ] Kezhu Wang commented on FLINK-21626: [~roman_khachatryan] Thanks, I will. > Conside

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306896#comment-17306896 ] Kezhu Wang commented on FLINK-21564: A small improvement is still a good. I will ope

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307040#comment-17307040 ] Kezhu Wang commented on FLINK-21467: I also think it is part of FLIP-147 [~pnowojski

[jira] [Commented] (FLINK-21821) Clean up Task/StreamTask cancellation and remove unnecessary concurrency

[ https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307050#comment-17307050 ] Kezhu Wang commented on FLINK-21821: I am going to close this ticket as there is no

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307079#comment-17307079 ] Kezhu Wang commented on FLINK-21817: +1 for gradual procedure. {quote} But we may ev

  1   2   >