[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166196#comment-17166196 ] Till Rohrmann commented on FLINK-11127: --- Can this ticket be closed [~rmetzger]? Wh

[jira] [Updated] (FLINK-18724) Integration with DataStream and DataSet API report error

[ https://issues.apache.org/jira/browse/FLINK-18724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18724: - Component/s: (was: API / Core) > Integration with DataStream and DataSet API report

[jira] [Closed] (FLINK-18656) Start Delay metric is always zero for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18656. -- Resolution: Fixed Merged to master as 5dccc996b3 and to release-1.11 as 59c590587f > Start De

[jira] [Reopened] (FLINK-18656) Start Delay metric is always zero for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-18656: > Start Delay metric is always zero for unaligned checkpoints > --

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166180#comment-17166180 ] Roman Khachatryan commented on FLINK-18662: --- I'm also fine with this proposal,

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166171#comment-17166171 ] Zhijiang commented on FLINK-18662: -- Thanks for explanation [~pnowojski]! I get the po

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166167#comment-17166167 ] liufangliang commented on FLINK-18202: -- Hi [~libenchao] , here's my oponion: 1.2 &

[jira] [Closed] (FLINK-18730) Remove Beta tag from SQL Client docs

[ https://issues.apache.org/jira/browse/FLINK-18730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18730. --- Resolution: Fixed - master: c3bf5f92b17565854eee1e5f291f2a16aa8662c5 - relase-1.11: d46ab52a32a4c87154e978f0

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166152#comment-17166152 ] Piotr Nowojski commented on FLINK-18662: [~roman_khachatryan] I would prefer to

[jira] [Commented] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166143#comment-17166143 ] Huyen Levan commented on FLINK-9940: [~maguowei] thanks for spending time looking at

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166140#comment-17166140 ] Zhijiang commented on FLINK-18662: -- The 1 and 2 are consistent with my above proposals.

[jira] [Commented] (FLINK-18663) Fix Flink On YARN AM not exit

[ https://issues.apache.org/jira/browse/FLINK-18663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166125#comment-17166125 ] tartarus commented on FLINK-18663: -- [~trohrmann]  the JobManager's log is too large，so

[jira] [Comment Edited] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166113#comment-17166113 ] Guowei Ma edited comment on FLINK-9940 at 7/28/20, 3:32 AM: H

[jira] [Commented] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166113#comment-17166113 ] Guowei Ma commented on FLINK-9940: -- I read the pr. I think the pr wants to store a set o

[jira] [Updated] (FLINK-18663) Fix Flink On YARN AM not exit

[ https://issues.apache.org/jira/browse/FLINK-18663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-18663: - Attachment: jobmanager.log.noyarn.tar.gz > Fix Flink On YARN AM not exit > -

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

[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166103#comment-17166103 ] Xintong Song commented on FLINK-18681: -- Hi [~apach...@163.com], I checked the log.

[jira] [Comment Edited] (FLINK-18548) Dimension table do not support computed column

[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166098#comment-17166098 ] Leonard Xu edited comment on FLINK-18548 at 7/28/20, 2:57 AM:

[jira] [Commented] (FLINK-18548) Dimension table do not support computed column

[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166098#comment-17166098 ] Leonard Xu commented on FLINK-18548: After FLINK-15366, Flink should support compu

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166049#comment-17166049 ] Zhilong Hong edited comment on FLINK-18496 at 7/28/20, 2:52 AM: --

[jira] [Updated] (FLINK-18548) Dimension table do not support computed column

[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Summary: Dimension table do not support computed column (was: Improve FlinkCalcMergeRule to merge c

[jira] [Updated] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Description: In Flink 1.10, we bring computed column feature, but I found dimension table do not su

[jira] [Updated] (FLINK-15366) Improve FlinkCalcMergeRule to merge calc nodes better

[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15366: --- Description: FlinkCalcMergeRule should merge calc nodes when outer calc do not contains inner calc'

[jira] [Updated] (FLINK-15366) Improve FlinkCalcMergeRule to merge calc nodes better

[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15366: --- Summary: Improve FlinkCalcMergeRule to merge calc nodes better (was: Dimension table do not support

[jira] [Closed] (FLINK-15366) Dimension table do not support computed column

[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15366. --- Resolution: Fixed Fixed in master: cb6db1ae1ebaa43608e4b68994bafec3a372b29e > Dimension table do not suppor

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166078#comment-17166078 ] Jark Wu commented on FLINK-18640: - Yes. The {{PostgresDialect#quoteIdentifier}} is chang

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166077#comment-17166077 ] Dian Fu commented on FLINK-16768: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Comment Edited] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165686#comment-17165686 ] Yumeng Zhang edited comment on FLINK-18706 at 7/28/20, 1:56 AM: --

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166074#comment-17166074 ] Dian Fu commented on FLINK-16768: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166073#comment-17166073 ] Dian Fu commented on FLINK-17730: - It seems that this issue is similar to FLINK-16768(bo

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166067#comment-17166067 ] Dian Fu commented on FLINK-16947: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165660#comment-17165660 ] Zhilong Hong edited comment on FLINK-18496 at 7/28/20, 1:43 AM: --

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166066#comment-17166066 ] Dian Fu commented on FLINK-17730: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166059#comment-17166059 ] 毛宗良 commented on FLINK-18640: - PostgresDialect has overrided the quoteIdentifier method and

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166057#comment-17166057 ] Biao Liu commented on FLINK-18641: -- [~becket_qin], [~pnowojski], the ticket has not bee

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166049#comment-17166049 ] Zhilong Hong commented on FLINK-18496: -- Change `_post` into another folder name wor

[jira] [Updated] (FLINK-18732) Update the hyperlink to the latest version

[ https://issues.apache.org/jira/browse/FLINK-18732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18732: - Description: In  https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/forma

[jira] [Updated] (FLINK-18732) Update the hyperlink to the latest version

[ https://issues.apache.org/jira/browse/FLINK-18732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18732: - Labels: pull-request-available starter (was: ) > Update the hyperlink to the latest version > -

[jira] [Commented] (FLINK-18627) Get unmatch filter method records to side output

[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165978#comment-17165978 ] Roey Shem Tov commented on FLINK-18627: --- [~sjwiesman] a pull request is opened, so

[jira] [Updated] (FLINK-16260) Add docker images based on Java 11

[ https://issues.apache.org/jira/browse/FLINK-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16260: --- Fix Version/s: 1.12.0 > Add docker images based on Java 11 > ---

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165787#comment-17165787 ] Leonid Ilyevsky commented on FLINK-18733: - [~trohrmann] please see two logs from

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165786#comment-17165786 ] Roman Khachatryan commented on FLINK-18662: --- Regarding "Persisted Data", we al

[jira] [Updated] (FLINK-18735) Enhance DataGen source to support more types

[ https://issues.apache.org/jira/browse/FLINK-18735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18735: - Description: DataGen connector is should support most types natively so it can be used in conju

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Attachment: flink-liquidnt-taskexecutor-0-nj1dvloglab01.liquidnet.biz.log > Jobmanager can

[jira] [Created] (FLINK-18735) Enhance DataGen source to support more types

Seth Wiesman created FLINK-18735: Summary: Enhance DataGen source to support more types Key: FLINK-18735 URL: https://issues.apache.org/jira/browse/FLINK-18735 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Attachment: flink-liquidnt-standalonesession-0-nj1dvloglab01.liquidnet.biz.log > Jobmanag

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Attachment: flink-conf.yaml > Jobmanager cannot start in HA mode with Zookeeper >

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165766#comment-17165766 ] Jark Wu commented on FLINK-18640: - I found that {{PostgresDialect}} doesn't quote the id

[jira] [Assigned] (FLINK-18517) kubernetes session test failed with "java.net.SocketException: Broken pipe"

[ https://issues.apache.org/jira/browse/FLINK-18517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-18517: - Assignee: Yang Wang > kubernetes session test failed with "java.net.SocketException: Br

[jira] [Commented] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

[ https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165761#comment-17165761 ] Jark Wu commented on FLINK-18734: - AFAIK, Flink SQL doesn't support Dynamo CDC as a sour

[jira] [Comment Edited] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165756#comment-17165756 ] Till Rohrmann edited comment on FLINK-18733 at 7/27/20, 2:49 PM: -

[jira] [Commented] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165756#comment-17165756 ] Till Rohrmann commented on FLINK-18733: --- Thanks for reporting this issue [~lilyevs

[jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

[ https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinay updated FLINK-18734: -- Labels: CDC documentation (was: ) > Add documentation for DynamoStreams Consumer CDC > --

[jira] [Created] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

Vinay created FLINK-18734: - Summary: Add documentation for DynamoStreams Consumer CDC Key: FLINK-18734 URL: https://issues.apache.org/jira/browse/FLINK-18734 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165705#comment-17165705 ] Piotr Nowojski edited comment on FLINK-18662 at 7/27/20, 1:40 PM:

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18733: - Component/s: Runtime / Coordination > Jobmanager cannot start in HA mode with Zookeeper

[jira] [Comment Edited] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165705#comment-17165705 ] Piotr Nowojski edited comment on FLINK-18662 at 7/27/20, 1:38 PM:

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165710#comment-17165710 ] Roman Khachatryan commented on FLINK-17073: --- Thanks [~echauchot], [~SleePy]!

[jira] [Comment Edited] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165705#comment-17165705 ] Piotr Nowojski edited comment on FLINK-18662 at 7/27/20, 1:36 PM:

[jira] [Comment Edited] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165705#comment-17165705 ] Piotr Nowojski edited comment on FLINK-18662 at 7/27/20, 1:35 PM:

[jira] [Comment Edited] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165705#comment-17165705 ] Piotr Nowojski edited comment on FLINK-18662 at 7/27/20, 1:34 PM:

[jira] [Updated] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-18733: Description: When configured in HA mode, the Jobmanager cannot start at all. First, it is

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165705#comment-17165705 ] Piotr Nowojski commented on FLINK-18662: [~roman_khachatryan] Option 3. might n

[jira] [Closed] (FLINK-18703) Use new data structure converters when legacy types are not present

[ https://issues.apache.org/jira/browse/FLINK-18703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-18703. Fix Version/s: 1.12.0 Resolution: Fixed Fixed in 1.12.0: bd45e046fe774daebe4125159d93a5bf64

[jira] [Created] (FLINK-18733) Jobmanager cannot start in HA mode with Zookeeper

Leonid Ilyevsky created FLINK-18733: --- Summary: Jobmanager cannot start in HA mode with Zookeeper Key: FLINK-18733 URL: https://issues.apache.org/jira/browse/FLINK-18733 Project: Flink Issue

[jira] [Commented] (FLINK-18732) Update the hyperlink to the latest version

[ https://issues.apache.org/jira/browse/FLINK-18732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165701#comment-17165701 ] weizheng commented on FLINK-18732: -- Update the hyperlink to the latest version > Updat

[jira] [Updated] (FLINK-18732) Update the hyperlink to the latest version

[ https://issues.apache.org/jira/browse/FLINK-18732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18732: - Attachment: 1.png > Update the hyperlink to the latest version > ---

[jira] [Created] (FLINK-18732) Update the hyperlink to the latest version

weizheng created FLINK-18732: Summary: Update the hyperlink to the latest version Key: FLINK-18732 URL: https://issues.apache.org/jira/browse/FLINK-18732 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165699#comment-17165699 ] Jun Qin commented on FLINK-18702: - Verified: [this PR|https://github.com/apache/flink/pu

[jira] [Commented] (FLINK-18699) Allow variables for column names in Scala Table API

[ https://issues.apache.org/jira/browse/FLINK-18699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165692#comment-17165692 ] Timo Walther commented on FLINK-18699: -- [~dwysakowicz] Sorry, I saw your comment to

[jira] [Closed] (FLINK-18699) Allow variables for column names in Scala Table API

[ https://issues.apache.org/jira/browse/FLINK-18699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-18699. Fix Version/s: 1.12.0 Resolution: Fixed Fixed in 1.12.0: 367ad8b8a00c3324fed342e8924e8df654

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165689#comment-17165689 ] Chesnay Schepler commented on FLINK-17260: -- I couldn't find anything obvious in

[jira] [Commented] (FLINK-10674) Fix handling of retractions after clean up

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165688#comment-17165688 ] Timo Walther commented on FLINK-10674: -- Hi [~dixingx...@yeah.net], this is very str

[jira] [Assigned] (FLINK-18731) The monotonicity of UNIX_TIMESTAMP function is not correct

[ https://issues.apache.org/jira/browse/FLINK-18731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18731: --- Assignee: godfrey he > The monotonicity of UNIX_TIMESTAMP function is not correct > ---

[jira] [Commented] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165686#comment-17165686 ] Yumeng Zhang commented on FLINK-18706: -- Thank you for replying. Correct me if I'm w

[jira] [Assigned] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18548: --- Assignee: Leonard Xu > Improve FlinkCalcMergeRule to merge calc nodes better >

[jira] [Commented] (FLINK-11779) CLI ignores -m parameter if high-availability is ZOOKEEPER

[ https://issues.apache.org/jira/browse/FLINK-11779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165676#comment-17165676 ] Aljoscha Krettek commented on FLINK-11779: -- And {{jobmanager.rpc.address}}? Tha

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165675#comment-17165675 ] Jark Wu edited comment on FLINK-18496 at 7/27/20, 12:44 PM:

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165675#comment-17165675 ] Jark Wu commented on FLINK-18496: - Thanks a lot for investigating this issue [~Thesharin

[jira] [Commented] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

[ https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165673#comment-17165673 ] Piotr Nowojski commented on FLINK-16404: Ops, sorry I missed the release note :(

[jira] [Updated] (FLINK-18731) The monotonicity of UNIX_TIMESTAMP function is not correct

[ https://issues.apache.org/jira/browse/FLINK-18731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18731: --- Description: Currently, the monotonicity of {{UNIX_TIMESTAMP}} function is always {{INCREASING}}, ac

[jira] [Created] (FLINK-18731) The monotonicity of UNIX_TIMESTAMP function is not correct

godfrey he created FLINK-18731: -- Summary: The monotonicity of UNIX_TIMESTAMP function is not correct Key: FLINK-18731 URL: https://issues.apache.org/jira/browse/FLINK-18731 Project: Flink Issue

[jira] [Commented] (FLINK-18731) The monotonicity of UNIX_TIMESTAMP function is not correct

[ https://issues.apache.org/jira/browse/FLINK-18731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165671#comment-17165671 ] godfrey he commented on FLINK-18731: I would like to fix this > The monotonicity of

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165668#comment-17165668 ] Zhu Zhu commented on FLINK-18496: - Thanks for the updates [~Thesharing]. Really good inv

[jira] [Commented] (FLINK-11779) CLI ignores -m parameter if high-availability is ZOOKEEPER

[ https://issues.apache.org/jira/browse/FLINK-11779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165666#comment-17165666 ] Chesnay Schepler commented on FLINK-11779: -- [~aljoscha] {{rest.address}} is onl

[jira] [Updated] (FLINK-18730) Remove Beta tag from SQL Client docs

[ https://issues.apache.org/jira/browse/FLINK-18730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18730: --- Labels: starter (was: ) > Remove Beta tag from SQL Client docs > --

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165660#comment-17165660 ] Zhilong Hong commented on FLINK-18496: -- I think the issue is related to the posts.

[jira] [Updated] (FLINK-18730) Remove Beta tag from SQL Client docs

[ https://issues.apache.org/jira/browse/FLINK-18730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18730: Issue Type: Improvement (was: Task) > Remove Beta tag from SQL Client docs >

[jira] [Created] (FLINK-18730) Remove Beta tag from SQL Client docs

Jark Wu created FLINK-18730: --- Summary: Remove Beta tag from SQL Client docs Key: FLINK-18730 URL: https://issues.apache.org/jira/browse/FLINK-18730 Project: Flink Issue Type: Task Compone

[jira] [Comment Edited] (FLINK-18729) Make flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165593#comment-17165593 ] shengjk1 edited comment on FLINK-18729 at 7/27/20, 11:53 AM: -

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: In streaming api, flink kafka producer can't auto discovery partition when the change of ka

[jira] [Updated] (FLINK-18729) Make flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Summary: Make flink streaming kafka producer auto discovery partition (was: Flink streaming kafka produ

[GitHub] [flink] pnowojski removed a comment on pull request #12989: [FLINK-18656][network,metrics] Fix startDelay metric for unaligned checkpoints

pnowojski removed a comment on pull request #12989: URL: https://github.com/apache/flink/pull/12989#issuecomment-664346680 Isn't this already happening in `AlternatingCheckpointBarrierHandler#getAlignmentDurationNanos`? This

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, In streaming api, flink kafka producer can't auto discovery partition when the change

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

[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165655#comment-17165655 ] wangtaiyang commented on FLINK-18681: - Hello, the following is the log of the progra

[GitHub] [flink] flinkbot edited a comment on pull request #12995: [FLINK-18517][k8s][release-1.10] Bump fabric8 version from 4.5.2 to 4.9.2

flinkbot edited a comment on pull request #12995: URL: https://github.com/apache/flink/pull/12995#issuecomment-664243022 ## CI report: * 855f9ec792d52b4a6426bba0f3ba1d3916b6d592 UNKNOWN * 9f28a149b48c7b97e5f60602f82fd92ac373d09e UNKNOWN * 03eae06726a348e94b85f885459933e1c23c

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, flink streaming kafka producer can't auto discovery partition when the change of kafka

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

[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangtaiyang updated FLINK-18681: Attachment: dependency.log > The jar package version conflict causes the task to continue to incre

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, flink streaming kafka producer can't auto discovery partition when the change of kafka

[jira] [Commented] (FLINK-11779) CLI ignores -m parameter if high-availability is ZOOKEEPER

[ https://issues.apache.org/jira/browse/FLINK-11779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165650#comment-17165650 ] Aljoscha Krettek commented on FLINK-11779: -- Turns out this is a smidge more com

[GitHub] [flink] pnowojski commented on pull request #12989: [FLINK-18656][network,metrics] Fix startDelay metric for unaligned checkpoints

pnowojski commented on pull request #12989: URL: https://github.com/apache/flink/pull/12989#issuecomment-664346680 Isn't this already happening in `AlternatingCheckpointBarrierHandler#getAlignmentDurationNanos`? This is an a

  1   2   >