[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

[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

[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] 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 #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] 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] 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 @@

[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] 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 #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] 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 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:

[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 #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-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 >

[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 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-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] 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-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: --

[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 #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] 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 #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-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] 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 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] 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] 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 @@

[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-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] 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] [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:

[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  

[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

[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-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

[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] [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 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 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-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] 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

[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

[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 >

[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-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] [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] [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

[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 >

[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

[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] [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 >

[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 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

[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 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:

[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:

[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

[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) >

[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] 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:

[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] dongjoon-hyun commented on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.7.0

2021-09-21 Thread GitBox
dongjoon-hyun commented on pull request #16644: URL: https://github.com/apache/flink/pull/16644#issuecomment-924229688 Thank you, @mbalassi ! :) -- 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

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

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17327: URL: https://github.com/apache/flink/pull/17327#issuecomment-923962563 ## CI report: * 73c07edc64806c0e9e3d3a7dbffc30eebece0bc2 UNKNOWN * ff7160cbd80d3bc64a2ef0d1e22fb8a28e736ce8 Azure:

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

2021-09-21 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418252#comment-17418252 ] Austin Cawley-Edwards commented on FLINK-24208: --- Great, we're on the same page. Thanks! >

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

2021-09-21 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418244#comment-17418244 ] Yufan Sheng commented on FLINK-23944: - [~dwysakowicz] OK, just assign it to me. I'll do it. >

[GitHub] [flink] flinkbot edited a comment on pull request #17328: Group of hotfix commits fixing a couple of things in the tests

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

[GitHub] [flink] mbalassi commented on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.7.0

2021-09-21 Thread GitBox
mbalassi commented on pull request #16644: URL: https://github.com/apache/flink/pull/16644#issuecomment-924182969 Hi @dongjoon-hyun, Please let us know when you open the updated version. Thanks! -- This is an automated message from the Apache Git Service. To respond to the

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

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

[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] 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] [Commented] (FLINK-24347) KafkaSource cannot checkpoint if the parallelism is higher than the partition number

2021-09-21 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418213#comment-17418213 ] Thomas Weise commented on FLINK-24347: -- Thanks for fixing this. In unbounded executions readers

[GitHub] [flink] flinkbot commented 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 commented on pull request #17331: URL: https://github.com/apache/flink/pull/17331#issuecomment-924142360 ## CI report: * 336d7f0aca4d20c49c1f6cb95ac3702511e8033c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

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

[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:

[jira] [Resolved] (FLINK-23389) AWS Glue Schema Registry JSON support for Apache Flink

2021-09-21 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-23389. --- Resolution: Done > AWS Glue Schema Registry JSON support for Apache Flink >

[GitHub] [flink] dannycranmer merged pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-21 Thread GitBox
dannycranmer merged pull request #16513: URL: https://github.com/apache/flink/pull/16513 -- 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] dannycranmer commented on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-21 Thread GitBox
dannycranmer commented on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-924133186 e2e tests pass locally. Merging -- 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

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

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

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

2021-09-21 Thread GitBox
flinkbot commented on pull request #17330: URL: https://github.com/apache/flink/pull/17330#issuecomment-924116638 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented 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 commented on pull request #17331: URL: https://github.com/apache/flink/pull/17331#issuecomment-924116602 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-24344) Handling of IOExceptions when triggering checkpoints doesn't cause job failover

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

[GitHub] [flink] akalash opened a new pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

2021-09-21 Thread GitBox
akalash opened a new pull request #17331: URL: https://github.com/apache/flink/pull/17331 ## What is the purpose of the change *This PR fixes the situation when the checkpoint exception happens during the checkpoint initialization and doesn't call the

[GitHub] [flink] fapaul opened a new pull request #17330: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
fapaul opened a new pull request #17330: URL: https://github.com/apache/flink/pull/17330 …sm is higher than partitions in KafkaSource Unchanged backport of #17327 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

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

[jira] [Issue Comment Deleted] (FLINK-22819) YARNFileReplicationITCase fails with "The YARN application unexpectedly switched to state FAILED during deployment"

2021-09-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22819: - Comment: was deleted (was: A comment with security level 'jira-users' was removed.) >

[jira] [Issue Comment Deleted] (FLINK-22819) YARNFileReplicationITCase fails with "The YARN application unexpectedly switched to state FAILED during deployment"

2021-09-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22819: - Comment: was deleted (was: A comment with security level 'jira-users' was removed.) >

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

2021-09-21 Thread GitBox
flinkbot commented on pull request #17329: URL: https://github.com/apache/flink/pull/17329#issuecomment-924078549 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] fapaul opened a new pull request #17329: [FLINK-24347][connectors/kafka] Keep idle source readers if paralleli…

2021-09-21 Thread GitBox
fapaul opened a new pull request #17329: URL: https://github.com/apache/flink/pull/17329 …sm is higher than partitions in KafkaSource Unchanged backport of #17327 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17328: Group of hotfix commits fixing a couple of things in the tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

2021-09-21 Thread GitBox
flinkbot edited a comment on pull request #17319: URL: https://github.com/apache/flink/pull/17319#issuecomment-922249634 ## CI report: * 79d47d6765dfc205b1ff9e5d59e0e3b17c668bd9 UNKNOWN * 0414dbd560746bc38d7933485aae047885beea34 Azure:

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

2021-09-21 Thread GitBox
dannycranmer edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-924053719 I would like to verify the e2e tests are passing with Scala 2.12 before merging: -

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

2021-09-21 Thread GitBox
dannycranmer edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-901125917 ✅ 1. The [description] looks good. ✅ 2. There is [consensus] that the contribution should go into to Flink. _This is a logical improvement to the already

  1   2   3   >