[jira] [Closed] (FLINK-24347) KafkaSource cannot checkpoint if the parallelism is higher than the partition number

2021-09-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-24347. > KafkaSource cannot checkpoint if the parallelism is higher than the partition > number >

[jira] [Assigned] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

2021-09-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-23944: -- Assignee: Yufan Sheng (was: Qingsheng Ren) >

[jira] [Resolved] (FLINK-24347) KafkaSource cannot checkpoint if the parallelism is higher than the partition number

2021-09-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-24347. -- Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed in - master

[GitHub] [flink] StephanEwen commented on pull request #17329: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
StephanEwen commented on pull request #17329: URL: https://github.com/apache/flink/pull/17329#issuecomment-924455791 Manually merged in a595fbbfe0087181f1b92d2d991a885911f290a2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] StephanEwen closed pull request #17329: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
StephanEwen closed pull request #17329: URL: https://github.com/apache/flink/pull/17329 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] StephanEwen merged pull request #17330: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
StephanEwen merged pull request #17330: URL: https://github.com/apache/flink/pull/17330 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-23397) [DOCS] task_failure_recovery page return 404

2021-09-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23397: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[GitHub] [flink] flinkbot edited a comment on pull request #17330: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17330: URL: https://github.com/apache/flink/pull/17330#issuecomment-924142235 ## CI report: * 144c1a4bf5b28d8ad2f3604e1c7148862208d5ad Azure:

[GitHub] [flink] StephanEwen closed pull request #17327: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
StephanEwen closed pull request #17327: URL: https://github.com/apache/flink/pull/17327 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17329: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17329: URL: https://github.com/apache/flink/pull/17329#issuecomment-924120246 ## CI report: * 1187a0d0a8fe25a030e0b3364cc5fafde1132574 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17331: URL: https://github.com/apache/flink/pull/17331#issuecomment-924142360 ## CI report: * 336d7f0aca4d20c49c1f6cb95ac3702511e8033c Azure:

[jira] [Created] (FLINK-24350) Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout

2021-09-21 Thread Xintong Song (Jira)
Xintong Song created FLINK-24350: Summary: Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout Key: FLINK-24350 URL: https://issues.apache.org/jira/browse/FLINK-24350

[GitHub] [flink] hililiwei edited a comment on pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY

2021-09-21 Thread GitBox
hililiwei edited a comment on pull request #17275: URL: https://github.com/apache/flink/pull/17275#issuecomment-924536467 > @hililiwei Would you be able to do that translation in the end? I don't speak Chinese, so I wouldn't be able to do that task. It'd be good if we could close the

[jira] [Commented] (FLINK-24271) Add document for special char in JSON_VALUE

2021-09-21 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418387#comment-17418387 ] liwei li commented on FLINK-24271: -- [~lzljs3620320] Can you help to merge the pr?     > Add document

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r713600160 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-924545241 ## CI report: * ec258f4e17badc0ea8bb0df005b6fe46f7d6b366 Azure:

[jira] [Updated] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed"

2021-09-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24348: --- Issue Type: Bug (was: New Feature) > KafkaTableITCase fail with "ContainerLaunch Container startup

[jira] [Created] (FLINK-24349) Support customized Calalogs via JDBC

2021-09-21 Thread Bo Cui (Jira)
Bo Cui created FLINK-24349: -- Summary: Support customized Calalogs via JDBC Key: FLINK-24349 URL: https://issues.apache.org/jira/browse/FLINK-24349 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24329) PulsarSourceITCase fails due to port conflict

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418376#comment-17418376 ] Xintong Song commented on FLINK-24329: -- Thanks for providing the PR, [~xmarker]. I've assigned you

[jira] [Updated] (FLINK-24349) Support customized Calalogs via JDBC

2021-09-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-24349: --- Issue Type: Improvement (was: Bug) > Support customized Calalogs via JDBC >

[jira] [Updated] (FLINK-24329) PulsarSourceITCase fails due to port conflict

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24329: - Fix Version/s: 1.14.0 > PulsarSourceITCase fails due to port conflict >

[jira] [Updated] (FLINK-24329) PulsarSourceITCase fails due to port conflict

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24329: - Affects Version/s: 1.14.0 > PulsarSourceITCase fails due to port conflict >

[GitHub] [flink] cuibo01 opened a new pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
cuibo01 opened a new pull request #17332: URL: https://github.com/apache/flink/pull/17332 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] hililiwei commented on pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY

2021-09-21 Thread GitBox
hililiwei commented on pull request #17275: URL: https://github.com/apache/flink/pull/17275#issuecomment-924536467 > @hililiwei Would you be able to do that translation in the end? I don't speak Chinese, so I wouldn't be able to do that task. It'd be good if we could close the parent

[jira] [Updated] (FLINK-24159) document of entropy injection may mislead users

2021-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24159: --- Labels: pull-request-available (was: ) > document of entropy injection may mislead users >

[jira] [Commented] (FLINK-23486) Add monitoring/metrics for the ChangelogStateBackend

2021-09-21 Thread xingyuan cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418415#comment-17418415 ] xingyuan cheng commented on FLINK-23486: Hello, it seems that we need to add some monitoring for

[GitHub] [flink] leonardBang commented on a change in pull request #17305: [hotfix][flink-avro] Removed unused variable

2021-09-21 Thread GitBox
leonardBang commented on a change in pull request #17305: URL: https://github.com/apache/flink/pull/17305#discussion_r713532867 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java ## @@ -243,7 +243,6 @@ private

[jira] [Assigned] (FLINK-24329) PulsarSourceITCase fails due to port conflict

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-24329: Assignee: xmarker (was: Xintong Song) > PulsarSourceITCase fails due to port conflict

[GitHub] [flink] KarmaGYZ opened a new pull request #17333: [FLINK-24262][runtime] Remove unused ContainerOverlays

2021-09-21 Thread GitBox
KarmaGYZ opened a new pull request #17333: URL: https://github.com/apache/flink/pull/17333 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Updated] (FLINK-24262) Remove unused ContainerOverlays

2021-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24262: --- Labels: pull-request-available (was: ) > Remove unused ContainerOverlays >

[GitHub] [flink] KarmaGYZ commented on pull request #17333: [FLINK-24262][runtime] Remove unused ContainerOverlays

2021-09-21 Thread GitBox
KarmaGYZ commented on pull request #17333: URL: https://github.com/apache/flink/pull/17333#issuecomment-924535197 cc @zentol -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-09-21 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-24351: - Parent: FLINK-9477 Issue Type: Sub-task (was: Improvement) > translate "JSON Function" pages

[jira] [Commented] (FLINK-24321) The Pod Template supports replaceable content

2021-09-21 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418395#comment-17418395 ] liuzhuo commented on FLINK-24321: - "containerized.master.env." and "containerized.taskmanager.env." only

[GitHub] [flink] flinkbot edited a comment on pull request #17310: [FLINK-24308][docs] Translate Kafka DataStream connector documentation to Chinese

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17310: URL: https://github.com/apache/flink/pull/17310#issuecomment-921625581 ## CI report: * edaf47441984dccce163e0a91c53176a83b27675 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17310: [FLINK-24308][docs] Translate Kafka DataStream connector documentation to Chinese

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17310: URL: https://github.com/apache/flink/pull/17310#issuecomment-921625581 ## CI report: * 932fbd23a1b9172312d8fc87a8d6ed04725e4b95 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 1d20e8536f5cb590b904763fbcec1a5a2d074164 Azure:

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418397#comment-17418397 ] Xintong Song commented on FLINK-20928: --

[GitHub] [flink] flinkbot edited a comment on pull request #17334: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17334: URL: https://github.com/apache/flink/pull/17334#issuecomment-924581916 ## CI report: * 2a5046348d38066feced088fe0e67f86c52f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 1d20e8536f5cb590b904763fbcec1a5a2d074164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-924545241 ## CI report: * ec258f4e17badc0ea8bb0df005b6fe46f7d6b366 Azure:

[GitHub] [flink] xuyangzhong commented on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-21 Thread GitBox
xuyangzhong commented on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-924603078 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink-ml] lindong28 opened a new pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

2021-09-21 Thread GitBox
lindong28 opened a new pull request #4: URL: https://github.com/apache/flink-ml/pull/4 ## What is the purpose of the change This PR updates the Flink ML API according to [FLIP-173](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=184615783). ## Brief change

[jira] [Updated] (FLINK-24349) Support customized Calalogs via JDBC

2021-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24349: --- Labels: pull-request-available (was: ) > Support customized Calalogs via JDBC >

[GitHub] [flink] godfreyhe commented on a change in pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-21 Thread GitBox
godfreyhe commented on a change in pull request #17308: URL: https://github.com/apache/flink/pull/17308#discussion_r713557487 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/FileSystemITCaseBase.scala ## @@ -95,6 +95,60 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * 0cc6f3f9235ffe069ca7eb7feac3e641cbe3cb22 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17310: [FLINK-24308][docs] Translate Kafka DataStream connector documentation to Chinese

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17310: URL: https://github.com/apache/flink/pull/17310#issuecomment-921625581 ## CI report: * edaf47441984dccce163e0a91c53176a83b27675 Azure:

[jira] [Commented] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418398#comment-17418398 ] Xintong Song commented on FLINK-24179: --

[GitHub] [flink] zoltar9264 opened a new pull request #17334: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users

2021-09-21 Thread GitBox
zoltar9264 opened a new pull request #17334: URL: https://github.com/apache/flink/pull/17334 ## What is the purpose of the change Document fix described in [FLINK-24159](https://issues.apache.org/jira/browse/FLINK-24159). ## Brief change log alter the checkpoint

[GitHub] [flink] flinkbot commented on pull request #17334: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users

2021-09-21 Thread GitBox
flinkbot commented on pull request #17334: URL: https://github.com/apache/flink/pull/17334#issuecomment-924576693 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

[jira] [Updated] (FLINK-22915) FLIP-173: Support DAG of algorithms

2021-09-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22915: --- Labels: pull-request-available (was: ) > FLIP-173: Support DAG of algorithms >

[GitHub] [flink-ml] lindong28 commented on pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

2021-09-21 Thread GitBox
lindong28 commented on pull request #4: URL: https://github.com/apache/flink-ml/pull/4#issuecomment-924610482 @becketqin Would you have time to review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Assigned] (FLINK-24329) PulsarSourceITCase fails due to port conflict

2021-09-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-24329: Assignee: Xintong Song > PulsarSourceITCase fails due to port conflict >

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * 0cc6f3f9235ffe069ca7eb7feac3e641cbe3cb22 Azure:

[jira] [Commented] (FLINK-22942) Disable upsert into syntax in Flink SQL

2021-09-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418382#comment-17418382 ] Jark Wu commented on FLINK-22942: - We may also need to add a release note for this, even if it was never

[GitHub] [flink] flinkbot commented on pull request #17333: [FLINK-24262][runtime] Remove unused ContainerOverlays

2021-09-21 Thread GitBox
flinkbot commented on pull request #17333: URL: https://github.com/apache/flink/pull/17333#issuecomment-924536995 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

[jira] [Commented] (FLINK-24159) document of entropy injection may mislead users

2021-09-21 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418404#comment-17418404 ] Feifan Wang commented on FLINK-24159: - Thanks [~pnowojski] for reply, I have open a

[GitHub] [flink] flinkbot commented on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
flinkbot commented on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-924530515 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

[jira] [Updated] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-09-21 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-24351: - Description: translate "JSON Function" pages into Chinese,  docs/data/sql_functions_zh.yml  

[jira] [Created] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-09-21 Thread liwei li (Jira)
liwei li created FLINK-24351: Summary: translate "JSON Function" pages into Chinese Key: FLINK-24351 URL: https://issues.apache.org/jira/browse/FLINK-24351 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #17333: [FLINK-24262][runtime] Remove unused ContainerOverlays

2021-09-21 Thread GitBox
flinkbot commented on pull request #17333: URL: https://github.com/apache/flink/pull/17333#issuecomment-924545312 ## CI report: * fad92f7becea65bfd3ae3d9b12a4ee4bf1a5a71b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
flinkbot commented on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-924545241 ## CI report: * ec258f4e17badc0ea8bb0df005b6fe46f7d6b366 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] dianfu commented on a change in pull request #16798: [FLINK-23651][python] Support RabbitMQ in PyFlink

2021-09-21 Thread GitBox
dianfu commented on a change in pull request #16798: URL: https://github.com/apache/flink/pull/16798#discussion_r713559527 ## File path: flink-connectors/flink-sql-connector-rabbitmq/src/main/resources/META-INF/NOTICE ## @@ -0,0 +1,9 @@ +flink-connector-rabbitmq Review

[GitHub] [flink] flinkbot edited a comment on pull request #17333: [FLINK-24262][runtime] Remove unused ContainerOverlays

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17333: URL: https://github.com/apache/flink/pull/17333#issuecomment-924545312 ## CI report: * fad92f7becea65bfd3ae3d9b12a4ee4bf1a5a71b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-924545241 ## CI report: * ec258f4e17badc0ea8bb0df005b6fe46f7d6b366 Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

2021-09-21 Thread GitBox
godfreyhe commented on a change in pull request #17311: URL: https://github.com/apache/flink/pull/17311#discussion_r713572846 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/utils/FlinkRexUtilTest.scala ## @@ -458,9 +461,64 @@

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

2021-09-21 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418400#comment-17418400 ] Steven Zhen Wu commented on FLINK-23886: Just to add another data point. We observed the same

[GitHub] [flink] flinkbot commented on pull request #17334: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users

2021-09-21 Thread GitBox
flinkbot commented on pull request #17334: URL: https://github.com/apache/flink/pull/17334#issuecomment-924581916 ## CI report: * 2a5046348d38066feced088fe0e67f86c52f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 1d20e8536f5cb590b904763fbcec1a5a2d074164 Azure:

[GitHub] [flink] dawidwys closed pull request #17182: [release] Create 1.14 release-notes

2021-09-21 Thread GitBox
dawidwys closed pull request #17182: URL: https://github.com/apache/flink/pull/17182 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-24344) Handling of IOExceptions when triggering checkpoints doesn't cause job failover

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24344: --- Description: When running

[GitHub] [flink] flinkbot edited a comment on pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17245: URL: https://github.com/apache/flink/pull/17245#issuecomment-917600794 ## CI report: * bc2102f6f4ddb7084ea717e3745cd9a97dcf4469 Azure:

[jira] [Commented] (FLINK-24337) WEB UI build failure in Flink 1.15-SNAPSHOT current code

2021-09-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417949#comment-17417949 ] Chesnay Schepler commented on FLINK-24337: -- I would recommend to add this to your git config:

[GitHub] [flink] dawidwys merged pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

2021-09-21 Thread GitBox
dawidwys merged pull request #17204: URL: https://github.com/apache/flink/pull/17204 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Assigned] (FLINK-24159) document of entropy injection may mislead users

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24159: -- Assignee: Feifan Wang > document of entropy injection may mislead users >

[jira] [Updated] (FLINK-24159) document of entropy injection may mislead users

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24159: --- Affects Version/s: 1.14.0 1.12.5 1.13.2 >

[jira] [Commented] (FLINK-24208) Allow idempotent savepoint triggering

2021-09-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417954#comment-17417954 ] Chesnay Schepler commented on FLINK-24208: -- ?? I would assume sending the same `triggerId` if

[jira] [Commented] (FLINK-24177) Add epoll exception check

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417959#comment-17417959 ] Piotr Nowojski commented on FLINK-24177: [~skyguard1], as [~chesnay] has pointed out in the PR,

[jira] [Created] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure

2021-09-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-24343: Summary: Revisit Scheduler and Coordinator Startup Procedure Key: FLINK-24343 URL: https://issues.apache.org/jira/browse/FLINK-24343 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17256: [FLINK-23385][table] Implement COALESCE function

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17256: URL: https://github.com/apache/flink/pull/17256#issuecomment-918040209 ## CI report: * 25fb8010703524981f7934402ebe46b266dc551e UNKNOWN * fc08e36cc78168a51b599b146783813e9d5cba3a Azure:

[GitHub] [flink] Airblader commented on a change in pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-09-21 Thread GitBox
Airblader commented on a change in pull request #16962: URL: https://github.com/apache/flink/pull/16962#discussion_r711971100 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/MySQLCatalog.java ## @@ -0,0 +1,499 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[jira] [Commented] (FLINK-21456) TableResult#print() should correctly stringify values of all data types in SQL format

2021-09-21 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417936#comment-17417936 ] Francesco Guardiani commented on FLINK-21456: - After some investigation on unifying the ,

[GitHub] [flink-web] syhily commented on a change in pull request #466: Add Apache Flink release 1.14.0

2021-09-21 Thread GitBox
syhily commented on a change in pull request #466: URL: https://github.com/apache/flink-web/pull/466#discussion_r712771498 ## File path: _posts/2021-09-21-release-1.14.0.md ## @@ -0,0 +1,182 @@ +--- +layout: post +title: "Apache Flink 1.14.0 Release Announcement" +date:

[jira] [Commented] (FLINK-24159) document of entropy injection may mislead users

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417956#comment-17417956 ] Piotr Nowojski commented on FLINK-24159: Yes [~Feifan Wang], it makes sense what you are

[jira] [Updated] (FLINK-24189) Buffer debloating for multiple gates

2021-09-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24189: - Summary: Buffer debloating for multiple gates (was: Buffer debloating for multiply

[jira] [Updated] (FLINK-24249) login from keytab fail when disk damage

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24249: --- Description:            flink on yarn will localize user keytab on local machine disk,

[jira] [Commented] (FLINK-19792) Interval join with equal time attributes is not recognized

2021-09-21 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417971#comment-17417971 ] Francesco Guardiani commented on FLINK-19792: - I tried to replicate the issue with the

[jira] [Comment Edited] (FLINK-19792) Interval join with equal time attributes is not recognized

2021-09-21 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417971#comment-17417971 ] Francesco Guardiani edited comment on FLINK-19792 at 9/21/21, 8:14 AM:

[jira] [Created] (FLINK-24344) Handling of IOExceptions when triggering checkpoints doesn't cause job failover

2021-09-21 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24344: -- Summary: Handling of IOExceptions when triggering checkpoints doesn't cause job failover Key: FLINK-24344 URL: https://issues.apache.org/jira/browse/FLINK-24344

[jira] [Commented] (FLINK-23189) Count and fail the task when the disk is error on JobManager

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417981#comment-17417981 ] Piotr Nowojski commented on FLINK-23189: The feature implemented in this ticket doesn't work as

[GitHub] [flink] Airblader commented on a change in pull request #17264: [FLINK-24253][JDBC] Load JdbcDialects via Service Loaders

2021-09-21 Thread GitBox
Airblader commented on a change in pull request #17264: URL: https://github.com/apache/flink/pull/17264#discussion_r712737082 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java ## @@ -18,80 +18,252 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * 8aebff6d6408a9210dcf95342eb31df8f9e1fee3 Azure:

[GitHub] [flink] dawidwys commented on pull request #17182: [release] Create 1.14 release-notes

2021-09-21 Thread GitBox
dawidwys commented on pull request #17182: URL: https://github.com/apache/flink/pull/17182#issuecomment-923718155 Thanks all for reviews. I will merge it in the current state. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

2021-09-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24207: --- Component/s: (was: Runtime / Checkpointing) API / DataStream > Add

[GitHub] [flink] Airblader commented on a change in pull request #17256: [FLINK-23385][table] Implement COALESCE function

2021-09-21 Thread GitBox
Airblader commented on a change in pull request #17256: URL: https://github.com/apache/flink/pull/17256#discussion_r712721877 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/RemoveUnreachableCoalesceArgumentsRule.java

[GitHub] [flink] syhily commented on pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

2021-09-21 Thread GitBox
syhily commented on pull request #17319: URL: https://github.com/apache/flink/pull/17319#issuecomment-923702381 > > @xmarker `PortBindingUtils` should also be removed. > > Hi syhily , thinks for review,I checked again and PortBindingUtils import has been removed by the second commit

[jira] [Closed] (FLINK-22942) Disable upsert into syntax in Flink SQL

2021-09-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22942. Fix Version/s: 1.15.0 Resolution: Implemented Implemented in

[GitHub] [flink] flinkbot edited a comment on pull request #17256: [FLINK-23385][table] Implement COALESCE function

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17256: URL: https://github.com/apache/flink/pull/17256#issuecomment-918040209 ## CI report: * 25fb8010703524981f7934402ebe46b266dc551e UNKNOWN * fc08e36cc78168a51b599b146783813e9d5cba3a Azure:

[jira] [Updated] (FLINK-24345) Translate "File Systems" page of "Internals" into Chinese

2021-09-21 Thread Liebing Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liebing Yu updated FLINK-24345: --- Description: The page url is 

[jira] [Commented] (FLINK-2491) Support Checkpoints After Tasks Finished

2021-09-21 Thread Joe Moser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417997#comment-17417997 ] Joe Moser commented on FLINK-2491: -- [~gaoyunhaii] [~dwysakowicz] what do you think about closing this

  1   2   3   >