[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

2021-02-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276920#comment-17276920 ] Zhu Zhu commented on FLINK-21030: - Sounds good to me. [~yunta] would you also take a loo

[GitHub] [flink] flinkbot edited a comment on pull request #14832: [FLINK-20359][k8s] Added Owner Reference to Job Manager in native kub…

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

[jira] [Created] (FLINK-21238) Support to close PythonFunctionFactory manually

2021-02-01 Thread Dian Fu (Jira)
Dian Fu created FLINK-21238: --- Summary: Support to close PythonFunctionFactory manually Key: FLINK-21238 URL: https://issues.apache.org/jira/browse/FLINK-21238 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

2021-02-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276909#comment-17276909 ] Matthias commented on FLINK-21030: -- Yes, the notification of tasks happens right at the

[GitHub] [flink] flinkbot edited a comment on pull request #14801: [FLINK-20942][planner] Digest of FLOAT literals throws UnsupportedOpe…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

2021-02-01 Thread GitBox
gaoyunhaii commented on a change in pull request #14740: URL: https://github.com/apache/flink/pull/14740#discussion_r568377165 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -223,16 +214,25 @@ private boolean

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

2021-02-01 Thread GitBox
gaoyunhaii commented on a change in pull request #14740: URL: https://github.com/apache/flink/pull/14740#discussion_r568375584 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBriefComputerContext.java ## @@ -0,0 +1,39 @@ +/* + * Licensed

[GitHub] [flink] flinkbot commented on pull request #14832: [FLINK-20359][k8s] Added Owner Reference to Job Manager in native kub…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2021-02-01 Thread GitBox
flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 019646dd12750ec211a543f858836637a164d845 UNKNOWN * df7d30894d9bf8f2d5ab361d2c0437d5aec065f9 Azure: [FAILURE](https://dev.azure.com/apache-fl

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

2021-02-01 Thread liuzhuo (Jira)
liuzhuo created FLINK-21237: --- Summary: Reflects the actual running state of the job Key: FLINK-21237 URL: https://issues.apache.org/jira/browse/FLINK-21237 Project: Flink Issue Type: Improvement

[GitHub] [flink-web] xintongsong merged pull request #415: Remove warning about missing DockerHub official images from 1.12.1 release blogpost.

2021-02-01 Thread GitBox
xintongsong merged pull request #415: URL: https://github.com/apache/flink-web/pull/415 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

[jira] [Assigned] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21236: -- Assignee: (was: Kurt Young) > Don't explicitly use HeapMemorySegment in raw format serde

[jira] [Assigned] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21236: -- Assignee: Kurt Young > Don't explicitly use HeapMemorySegment in raw format serde > -

[jira] [Updated] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21236: --- Summary: Don't explicitly use HeapMemorySegment in raw format serde (was: Don't explicitly use Heap

[GitHub] [flink] flinkbot commented on pull request #14832: [FLINK-20359][k8s] Added Owner Reference to Job Manager in native kub…

2021-02-01 Thread GitBox
flinkbot commented on pull request #14832: URL: https://github.com/apache/flink/pull/14832#issuecomment-771420269 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-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276896#comment-17276896 ] Xintong Song commented on FLINK-20359: -- Thanks [~pnowojski]. I've fixed the compili

[jira] [Created] (FLINK-21236) Don't explicitly use HeapMemorySegment in row format serde

2021-02-01 Thread Kurt Young (Jira)
Kurt Young created FLINK-21236: -- Summary: Don't explicitly use HeapMemorySegment in row format serde Key: FLINK-21236 URL: https://issues.apache.org/jira/browse/FLINK-21236 Project: Flink Issue

[GitHub] [flink] xintongsong opened a new pull request #14832: [FLINK-20359][k8s] Added Owner Reference to Job Manager in native kub…

2021-02-01 Thread GitBox
xintongsong opened a new pull request #14832: URL: https://github.com/apache/flink/pull/14832 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

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Support to consume retractions for window aggregate operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2021-02-01 Thread GitBox
flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 019646dd12750ec211a543f858836637a164d845 UNKNOWN * df7d30894d9bf8f2d5ab361d2c0437d5aec065f9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] AHeise commented on a change in pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2021-02-01 Thread GitBox
AHeise commented on a change in pull request #13551: URL: https://github.com/apache/flink/pull/13551#discussion_r568358724 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java ## @@ -41,6 +41,8 @@ * startup options, or the JVM v

[GitHub] [flink] AHeise commented on a change in pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2021-02-01 Thread GitBox
AHeise commented on a change in pull request #13551: URL: https://github.com/apache/flink/pull/13551#discussion_r568358199 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/PseudoRandomValueSelector.java ## @@ -0,0 +1,122 @@ +

[jira] [Updated] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread

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

[jira] [Updated] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread

2021-02-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20943: --- Priority: Minor (was: Major) > AsyncCheckpointRunnable.cleanup() runs in the main task thre

[jira] [Assigned] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread

2021-02-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-20943: -- Assignee: (was: Roman Khachatryan) > AsyncCheckpointRunnable.cleanup() runs in th

[GitHub] [flink-web] xintongsong opened a new pull request #415: Remove warning about missing DockerHub official images from 1.12.1 release blogpost.

2021-02-01 Thread GitBox
xintongsong opened a new pull request #415: URL: https://github.com/apache/flink-web/pull/415 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

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

2021-02-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-20359: I've reverted this change for release-1.12 (10d50dd5732) as it caused the build to fail http

[jira] [Created] (FLINK-21235) leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang

2021-02-01 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21235: - Summary: leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang Key: FLINK-21235 URL: https://issues.apache.org/jira/browse/FLINK-21235 Project: Flink

[jira] [Updated] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

2021-02-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21234: -- Labels: test-stability (was: ) > testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = c

[jira] [Created] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

2021-02-01 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21234: - Summary: testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang Key: FLINK-21234 URL: https://issues.apache.org/jira/browse/FLINK-21234 Project: Flink

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

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

[GitHub] [flink] xintongsong commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-02-01 Thread GitBox
xintongsong commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r568307727 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotStatusSyncer.java ## @@ -79,6 +79,7 @@ void initia

[GitHub] [flink] flinkbot edited a comment on pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

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

[GitHub] [flink] curcur commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-02-01 Thread GitBox
curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r568316262 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,306 @@ +/* + * Licensed to the Ap

[jira] [Commented] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-01 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276851#comment-17276851 ] tim yu commented on FLINK-21231: [~lzljs3620320] thank you > add "SHOW VIEWS" to SQL c

[GitHub] [flink] flinkbot commented on pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-01 Thread GitBox
flinkbot commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-771346642 ## CI report: * 1240dbb9879bedee17ac69d69ab8fd514589febd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276849#comment-17276849 ] Kurt Young commented on FLINK-20663: One more comment to hint that we are pretty saf

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

2021-02-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276846#comment-17276846 ] Zhu Zhu commented on FLINK-21030: - Thanks for the investigation! [~mapohl] Does this mea

[GitHub] [flink] flinkbot commented on pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-01 Thread GitBox
flinkbot commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-771342052 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-21086) CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21086: --- Labels: pull-request-available (was: ) > CheckpointBarrierHandler Insert barriers for chann

[GitHub] [flink] gaoyunhaii opened a new pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-01 Thread GitBox
gaoyunhaii opened a new pull request #14831: URL: https://github.com/apache/flink/pull/14831 ## What is the purpose of the change This PR makes `CheckpointBarrierHandler` inserts barrier for channels that have received EndPartition but not processed it yet. When an input chan

[jira] [Closed] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21207. --- Assignee: sharkd tu Resolution: Fixed Fixed in master: 03871e142746832a64c84756e928da0c3bdff6a2 > 'cs

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21207: Fix Version/s: (was: 1.12.2) > 'csv.disable-quote-character' can not take effect during deserializati

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21207: Issue Type: New Feature (was: Bug) > 'csv.disable-quote-character' can not take effect during deserializ

[GitHub] [flink] wuchong closed pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-02-01 Thread GitBox
wuchong closed pull request #14813: URL: https://github.com/apache/flink/pull/14813 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-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276841#comment-17276841 ] Xintong Song commented on FLINK-20663: -- bq. Regarding to the lock part, do we reall

[jira] [Updated] (FLINK-21086) CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-01 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21086: Summary: CheckpointBarrierHandler Insert barriers for channels received EndOfPartition (was: CheckpointBa

[jira] [Closed] (FLINK-21172) canal-json format include es field

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21172. --- Fix Version/s: 1.13.0 Resolution: Fixed Fixed in master: 195056b11f5266599260832e3e216330b58c5eaf >

[GitHub] [flink] wuchong merged pull request #14792: [FLINK-21172][canal][json] canal-json format include es field

2021-02-01 Thread GitBox
wuchong merged pull request #14792: URL: https://github.com/apache/flink/pull/14792 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-21200) User defined functions refuse to accept multi-set arguments without type hints

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276839#comment-17276839 ] Jark Wu commented on FLINK-21200: - This sounds that we can't natually support MULTISET t

[jira] [Commented] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276838#comment-17276838 ] Jark Wu commented on FLINK-21231: - cc [~fsk119] > add "SHOW VIEWS" to SQL client >

[jira] [Updated] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21231: Affects Version/s: (was: 1.11.1) > add "SHOW VIEWS" to SQL client > -- > >

[jira] [Commented] (FLINK-21225) OverConvertRule does not consider distinct

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276837#comment-17276837 ] Jark Wu commented on FLINK-21225: - Thanks for the investigation [~qingyue]. I assigned t

[jira] [Assigned] (FLINK-21225) OverConvertRule does not consider distinct

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21225: --- Assignee: Jane Chan > OverConvertRule does not consider distinct >

[jira] [Commented] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276835#comment-17276835 ] Jark Wu commented on FLINK-21232: - Hi [~jackwangcs], I'm not familiar with this module.

[GitHub] [flink] flinkbot edited a comment on pull request #14801: [FLINK-20942][planner] Digest of FLOAT literals throws UnsupportedOpe…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

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

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276828#comment-17276828 ] Jark Wu commented on FLINK-21203: - We should be cautious to introduce any public API, be

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276827#comment-17276827 ] Kurt Young commented on FLINK-20663: [~xintongsong] You are correct.  Regarding to

[jira] [Commented] (FLINK-21229) Support ssl connection with schema registry format

2021-02-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276826#comment-17276826 ] Jark Wu commented on FLINK-21229: - Nit: the config option keys should start with {{schem

[jira] [Assigned] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-21231: Assignee: tim yu > add "SHOW VIEWS" to SQL client > -- > >

[jira] [Commented] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276825#comment-17276825 ] Jingsong Lee commented on FLINK-21231: -- Assigned to u [~yulei0824] > add "SHOW VIE

[GitHub] [flink] wangyang0918 commented on pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-02-01 Thread GitBox
wangyang0918 commented on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-771327097 Thanks @xintongsong for refining the description and merging. This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #14801: [FLINK-20942][planner] Digest of FLOAT literals throws UnsupportedOpe…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

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

[jira] [Comment Edited] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276823#comment-17276823 ] Xintong Song edited comment on FLINK-20663 at 2/2/21, 3:15 AM: ---

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276823#comment-17276823 ] Xintong Song commented on FLINK-20663: -- [~ykt836], I don't think that works. {code

[jira] [Closed] (FLINK-20345) Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when executes SplitAggregateRule

2021-02-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20345. Resolution: Fixed master (1.13): a334b921dab093a20120a16589af991302e7cbb9 > Adds an Expand node o

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Support to consume retractions for window aggregate operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #14814: (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] JingsongLi merged pull request #14602: [FLINK-20345][table-planner-blink] Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when executes Spl

2021-02-01 Thread GitBox
JingsongLi merged pull request #14602: URL: https://github.com/apache/flink/pull/14602 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

[jira] [Commented] (FLINK-21208) pyarrow exception when using window with pandas udaf

2021-02-01 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276812#comment-17276812 ] Huang Xingbo commented on FLINK-21208: -- [~liuyufei] Thanks a lot for reporting this

[GitHub] [flink] lirui-apache commented on a change in pull request #14802: [FLINK-21185][table-common][table-api-java] Introduce a new interface…

2021-02-01 Thread GitBox
lirui-apache commented on a change in pull request #14802: URL: https://github.com/apache/flink/pull/14802#discussion_r568281785 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -697,6 +703,9 @@ private void

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276801#comment-17276801 ] Kurt Young commented on FLINK-20663: [~xintongsong] It doesn't need to be such compl

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Support to consume retractions for window aggregate operator

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

[jira] [Commented] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

2021-02-01 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276799#comment-17276799 ] jackwangcs commented on FLINK-21232: Hi [~lirui], [~jark], could you please assign t

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

2021-02-01 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-21232: --- Description: Introduce a pluggable delegation provider via SPI.  Delegation provider could be place

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

2021-02-01 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-21232: --- Description: Introduce a pluggable delegation provider via SPI.  Delegation provider could be place

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276797#comment-17276797 ] Xintong Song commented on FLINK-20663: -- I think option 2) might be a good way to go

[jira] [Updated] (FLINK-21231) add "SHOW VIEWS" to SQL client

2021-02-01 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tim yu updated FLINK-21231: --- Component/s: Table SQL / Client Affects Version/s: 1.11.1 > add "SHOW VIEWS" to SQL client > -

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

2021-02-01 Thread GitBox
xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-771289361 Hi,@becketqin , How does things go? This is an automated message from the Apache Git Service. To respond to th

[GitHub] [flink] becketqin commented on pull request #14824: [release-1.12][FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-02-01 Thread GitBox
becketqin commented on pull request #14824: URL: https://github.com/apache/flink/pull/14824#issuecomment-771287930 @tweise No concern from my side. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] xintongsong closed pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-02-01 Thread GitBox
xintongsong closed pull request #14823: URL: https://github.com/apache/flink/pull/14823 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] xintongsong commented on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-02-01 Thread GitBox
xintongsong commented on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-771287844 Closed via b9e576fb845b817d804da3d68471ff8a4723dcf3 This is an automated message from the Apache Git Service

[jira] [Closed] (FLINK-21139) ThresholdMeterTest.testMarkMultipleEvents unstable

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21139. Resolution: Fixed Fixed via * master (1.13): b9e576fb845b817d804da3d68471ff8a4723dcf3 > Threshold

[GitHub] [flink] xintongsong commented on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-02-01 Thread GitBox
xintongsong commented on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-771287069 @zentol, `ThresholdMeter` is introduced for tracing the rate of starting new worker failures, in FLINK-10868. It's different from `MeterView` in the following ways:

[GitHub] [flink] flinkbot edited a comment on pull request #14814: (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

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

2021-02-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20359. Resolution: Fixed Merged via * master (1.13): 06d94bf2fbb9a920997d88bd44a4b8be36e1078d * release-1

[GitHub] [flink] xintongsong closed pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-02-01 Thread GitBox
xintongsong closed pull request #14591: URL: https://github.com/apache/flink/pull/14591 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

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2021-02-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276776#comment-17276776 ] Kurt Young commented on FLINK-17793: I'm curious about `ResolvedSchema`. What exactl

[GitHub] [flink] flinkbot edited a comment on pull request #14814: (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2021-02-01 Thread GitBox
flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 019646dd12750ec211a543f858836637a164d845 UNKNOWN * df7d30894d9bf8f2d5ab361d2c0437d5aec065f9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-21233) Race condition in CheckpointCoordinator in finishing sync savepoint

2021-02-01 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-21233. - Resolution: Invalid > Race condition in CheckpointCoordinator in finishing sync savepoin

[GitHub] [flink] flinkbot edited a comment on pull request #14814: (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

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

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2021-02-01 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276747#comment-17276747 ] Jiangjie Qin commented on FLINK-10806: -- Hi [~Wosinsan], I think the functionality r

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2021-02-01 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276741#comment-17276741 ] Dominik Wosiński commented on FLINK-10806: -- Hey,  can I tackle this? > Support

[jira] [Updated] (FLINK-21233) Race condition in CheckpointCoordinator in finishing sync savepoint

2021-02-01 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21233: -- Description: I'm writing an integration test and see a failure from time to time (1 pe

[jira] [Commented] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

2021-02-01 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276739#comment-17276739 ] Dominik Wosiński commented on FLINK-21219: -- Thanks, tried looking for that but

  1   2   3   4   >