[GitHub] [flink] Myasuka commented on a change in pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-25 Thread GitBox
Myasuka commented on a change in pull request #14662: URL: https://github.com/apache/flink/pull/14662#discussion_r563315357 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -237,19 +241,29 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 59c613b802406116781770465c74a3b10a2aca10 Azure:

[jira] [Updated] (FLINK-21141) Timeout bug in data stream connect operation when one of the data stream does not have new messages very frequently

2021-01-25 Thread HUANG Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HUANG Hong updated FLINK-21141: --- Summary: Timeout bug in data stream connect operation when one of the data stream does not have new

[jira] [Created] (FLINK-21141) Timeout bug in data stream connect operation

2021-01-25 Thread HUANG Hong (Jira)
HUANG Hong created FLINK-21141: -- Summary: Timeout bug in data stream connect operation Key: FLINK-21141 URL: https://issues.apache.org/jira/browse/FLINK-21141 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14733: [FLINK-20968][table-planner-blink] Remove legacy exec nodes

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14733: URL: https://github.com/apache/flink/pull/14733#issuecomment-765889414 ## CI report: * de291068835c9b7540c3a0544c6dd589f0c3ada2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * 5d701796fc88f998c12bc58ada37b0248ea978c7 Azure:

[jira] [Commented] (FLINK-20416) Need a cached catalog for HiveCatalog

2021-01-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271785#comment-17271785 ] Jark Wu commented on FLINK-20416: - Thanks [~shared_ptr] for updating the design doc, I think the key

[jira] [Created] (FLINK-21140) Extract zip file dependencies before adding to PYTHONPATH

2021-01-25 Thread Dian Fu (Jira)
Dian Fu created FLINK-21140: --- Summary: Extract zip file dependencies before adding to PYTHONPATH Key: FLINK-21140 URL: https://issues.apache.org/jira/browse/FLINK-21140 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-19381) Fix docs about relocatable savepoints

2021-01-25 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu resolved FLINK-19381. -- Resolution: Fixed Merged into master with a9d2b766b2a04b5dc6532381c1f0c60bf56c4e74 > Fix

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * 5d701796fc88f998c12bc58ada37b0248ea978c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14733: [FLINK-20968][table-planner-blink] Remove legacy exec nodes

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14733: URL: https://github.com/apache/flink/pull/14733#issuecomment-765889414 ## CI report: * de291068835c9b7540c3a0544c6dd589f0c3ada2 Azure:

[GitHub] [flink] wenlong88 commented on a change in pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization f

2021-01-25 Thread GitBox
wenlong88 commented on a change in pull request #14729: URL: https://github.com/apache/flink/pull/14729#discussion_r564170827 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecEdge.java ## @@ -21,39 +21,97 @@

[GitHub] [flink] klion26 closed pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

2021-01-25 Thread GitBox
klion26 closed pull request #13488: URL: https://github.com/apache/flink/pull/13488 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] godfreyhe commented on pull request #14733: [FLINK-20968][table-planner-blink] Remove legacy exec nodes

2021-01-25 Thread GitBox
godfreyhe commented on pull request #14733: URL: https://github.com/apache/flink/pull/14733#issuecomment-767255032 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-21069) Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

2021-01-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21069: Fix Version/s: 1.12.2 > Configuration "parallelism.default" doesn't take effect for >

[jira] [Comment Edited] (FLINK-21069) Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

2021-01-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271266#comment-17271266 ] Jark Wu edited comment on FLINK-21069 at 1/26/21, 2:47 AM: --- Fixed in -

[GitHub] [flink] wuchong merged pull request #14751: [BP-1.12][FLINK-21069][table-planner-blink] Configuration parallelism.default doesn't take effect for TableEnvironment#explainSql

2021-01-25 Thread GitBox
wuchong merged pull request #14751: URL: https://github.com/apache/flink/pull/14751 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 #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239 ## CI report: * 35947579b06f3b4d67e151e2fc38565813076008 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14749: [FLINK-21123][fs] Bump beanutils to 1.9.4

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14749: URL: https://github.com/apache/flink/pull/14749#issuecomment-766689736 ## CI report: * 41d24cf8e001a4db55ceae9ccdfe9dee53e9faab Azure:

[jira] [Comment Edited] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-25 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271508#comment-17271508 ] Jane Chan edited comment on FLINK-21045 at 1/26/21, 1:47 AM: - Hi [~jark],

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * bd617892bfec1db1654606355041a6e4b9050304 Azure:

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

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239 ## CI report: * 80ea1fb2b7987d406c153526f420e2c73834bea6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * bd617892bfec1db1654606355041a6e4b9050304 Azure:

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

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239 ## CI report: * 80ea1fb2b7987d406c153526f420e2c73834bea6 Azure:

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

2021-01-25 Thread GitBox
blublinsky commented on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-767211524 Sorry @xintongsong, are we done now? This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] mohitpali commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
mohitpali commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-767211338 Apologies for the confusion, we have close the other PR. We had to create another PR because two developers were working on it and hence the different login. I have included

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 59c613b802406116781770465c74a3b10a2aca10 Azure:

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

2021-01-25 Thread GitBox
xintongsong commented on a change in pull request #14591: URL: https://github.com/apache/flink/pull/14591#discussion_r564142313 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -89,6 +89,17 @@

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

2021-01-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271746#comment-17271746 ] Xintong Song commented on FLINK-20632: -- I tried sign the images for 1.12.1, but couldn't find a way

[GitHub] [flink] SteNicholas commented on pull request #14751: [BP-1.12][FLINK-21069][table-planner-blink] Configuration parallelism.default doesn't take effect for TableEnvironment#explainSql

2021-01-25 Thread GitBox
SteNicholas commented on pull request #14751: URL: https://github.com/apache/flink/pull/14751#issuecomment-767195162 @wuchong , could you please help to review this backport? This is an automated message from the Apache Git

[jira] [Created] (FLINK-21139) java.lang.AssertionError: Expected: a numeric value within <1.0E-6> of <40.0> but: <0.0> differed by <39.999999>

2021-01-25 Thread Ivan Serdyuk (Jira)
Ivan Serdyuk created FLINK-21139: Summary: java.lang.AssertionError: Expected: a numeric value within <1.0E-6> of <40.0> but: <0.0> differed by <39.99> Key: FLINK-21139 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * Unknown: [CANCELED](TBD) * 59c613b802406116781770465c74a3b10a2aca10 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * Unknown: [CANCELED](TBD) * 59c613b802406116781770465c74a3b10a2aca10 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] sjwiesman commented on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
sjwiesman commented on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-767136939 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-21137) Maven plugin surefire failed due to test failure

2021-01-25 Thread Linyu Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271697#comment-17271697 ] Linyu Yao commented on FLINK-21137: --- Thanks for response. I'll rebase my branch. And is there any way

[GitHub] [flink] flinkbot edited a comment on pull request #14749: [FLINK-21123][fs] Bump beanutils to 1.9.4

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14749: URL: https://github.com/apache/flink/pull/14749#issuecomment-766689736 ## CI report: * 718324dc3a3ad151ee2c40efd97b2bff3bc190c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14719: [FLINK-21072] Refactor the SnapshotStrategy hierarchy

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14719: URL: https://github.com/apache/flink/pull/14719#issuecomment-764631410 ## CI report: * 4197ba5c2e6681045851248a784f79b8ebf9ffdd UNKNOWN * 589607a9653384d83bdcd2292c893b2241f2b2c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14749: [FLINK-21123][fs] Bump beanutils to 1.9.4

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14749: URL: https://github.com/apache/flink/pull/14749#issuecomment-766689736 ## CI report: * 718324dc3a3ad151ee2c40efd97b2bff3bc190c1 Azure:

[GitHub] [flink] sjwiesman opened a new pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
sjwiesman opened a new pull request #13912: URL: https://github.com/apache/flink/pull/13912 ## What is the purpose of the change This PR adds the new public classes as described in FLIP-142, JobManagerCheckpointStorage, FileSystemCheckpointStorage, HashMapStateBackend, and

[GitHub] [flink] sjwiesman closed pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[GitHub] [flink] zentol commented on pull request #14749: [FLINK-21123][fs] Bump beanutils to 1.9.4

2021-01-25 Thread GitBox
zentol commented on pull request #14749: URL: https://github.com/apache/flink/pull/14749#issuecomment-767103094 > But the same failure occurred in your personal CI as well The branch was just horrendously out-dated and no longer compatible with the docker files.

[GitHub] [flink] flinkbot edited a comment on pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14734: URL: https://github.com/apache/flink/pull/14734#issuecomment-766092219 ## CI report: * 0c94f50f2a8e9a5753479fce0cb18e02a1931c16 Azure:

[jira] [Created] (FLINK-21138) KvStateServerHandler is not invoked with user code classloader

2021-01-25 Thread Maciej Prochniak (Jira)
Maciej Prochniak created FLINK-21138: Summary: KvStateServerHandler is not invoked with user code classloader Key: FLINK-21138 URL: https://issues.apache.org/jira/browse/FLINK-21138 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 791054dcce99cb4cedf93b3f80d775385d6a23e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 9294cc8a4b7e743f0d505424e92cf33e27625c8e Azure:

[jira] [Commented] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

2021-01-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271656#comment-17271656 ] Matthias commented on FLINK-21106: -- Yeah, in the end it's only the newline in front of {{.stream()}}

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 9294cc8a4b7e743f0d505424e92cf33e27625c8e Azure:

[jira] [Closed] (FLINK-21137) Maven plugin surefire failed due to test failure

2021-01-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-21137. Resolution: Duplicate Thanks for reporting this. The test failure you're experiencing is already fixed

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-767029789 You don't need to open a PR for every fix, you can just keep (force) pushing to the branch. Can you close the old PR? I'll review the PR tomorrow.

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

2021-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271592#comment-17271592 ] Piotr Nowojski commented on FLINK-21132: If the correct answer for 1., there seems to be a

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

2021-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271590#comment-17271590 ] Piotr Nowojski commented on FLINK-21132: Thanks for reporting and analysing the issue. Yes, I

[GitHub] [flink] flinkbot edited a comment on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766300412 ## CI report: * c3e8b6b3c25cec2d89b85688871ea897a4054956 Azure:

[jira] [Updated] (FLINK-21137) Maven plugin surefire failed due to test failure

2021-01-25 Thread Linyu Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Linyu Yao updated FLINK-21137: -- Priority: Major (was: Blocker) > Maven plugin surefire failed due to test failure >

[jira] [Created] (FLINK-21137) Maven plugin surefire failed due to test failure

2021-01-25 Thread Linyu Yao (Jira)
Linyu Yao created FLINK-21137: - Summary: Maven plugin surefire failed due to test failure Key: FLINK-21137 URL: https://issues.apache.org/jira/browse/FLINK-21137 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on pull request #14751: [BP-1.12][FLINK-21069][table-planner-blink] Configuration parallelism.default doesn't take effect for TableEnvironment#explainSql

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14751: URL: https://github.com/apache/flink/pull/14751#issuecomment-766812086 ## CI report: * ead6ca94ad390c9083185c7ebdfc853bae7f0a26 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14719: [FLINK-21072] Refactor the SnapshotStrategy hierarchy

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14719: URL: https://github.com/apache/flink/pull/14719#issuecomment-764631410 ## CI report: * 4197ba5c2e6681045851248a784f79b8ebf9ffdd UNKNOWN * cc6c13e40d5b3a60ad6c2df1a3a09049f1cded44 Azure:

[GitHub] [flink] LinyuYao1021 closed pull request #14490: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
LinyuYao1021 closed pull request #14490: URL: https://github.com/apache/flink/pull/14490 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 edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 82b0205e05eaa5bffd0e06e17f2fffe3f51072e7 Azure:

[jira] [Updated] (FLINK-21032) JsonFileCompactionITCase fails on azure

2021-01-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21032: - Priority: Major (was: Blocker) > JsonFileCompactionITCase fails on azure >

[GitHub] [flink] LinyuYao1021 removed a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
LinyuYao1021 removed a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766989857 It's the same one but fixing the compiling error. This is an automated message from the Apache Git

[GitHub] [flink] LinyuYao1021 commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
LinyuYao1021 commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766991327 > What's the relationship of this PR to #14490 ? It's the same one but fixing the compiling error.

[GitHub] [flink] LinyuYao1021 commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-25 Thread GitBox
LinyuYao1021 commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766989857 It's the same one but fixing the compiling error. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-21126) Reconsider FLINK_PROPERTIES

2021-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271566#comment-17271566 ] Chesnay Schepler commented on FLINK-21126: -- I'd expect that use case to be coverable by

[jira] [Updated] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-01-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20495: - Priority: Major (was: Blocker) > Elasticsearch6DynamicSinkITCase Hang >

[GitHub] [flink] flinkbot edited a comment on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14754: URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862 ## CI report: * 37484933592e8b5a4f5cf83425ac0b7b612c7480 Azure:

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

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * 15a1f2beef1ddf95687fb4a53cf8a6f906559836 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14719: [FLINK-21072] Refactor the SnapshotStrategy hierarchy

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14719: URL: https://github.com/apache/flink/pull/14719#issuecomment-764631410 ## CI report: * 4197ba5c2e6681045851248a784f79b8ebf9ffdd UNKNOWN * cc6c13e40d5b3a60ad6c2df1a3a09049f1cded44 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 44390d70d9c15b70473e1249e042aed2ae99a7b7 Azure:

[jira] [Commented] (FLINK-21126) Reconsider FLINK_PROPERTIES

2021-01-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271559#comment-17271559 ] Thomas Weise commented on FLINK-21126: -- This environment variable was actually introduced to

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

2021-01-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271558#comment-17271558 ] Dawid Wysakowicz commented on FLINK-20254: -- Hey [~Leonard Xu] any update on the issue? >

[jira] [Commented] (FLINK-20416) Need a cached catalog for HiveCatalog

2021-01-25 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271553#comment-17271553 ] Sebastian Liu commented on FLINK-20416: --- Hi [~jark], [~lirui], After our discussion, I changed

[GitHub] [flink] Myasuka commented on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-25 Thread GitBox
Myasuka commented on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-766969599 @rkhachatryan I use `checkpointException.getCause()` when printing decline checkpoint message to avoid duplicate information in fixup commit.

[jira] [Updated] (FLINK-20416) Need a cached catalog for HiveCatalog

2021-01-25 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20416: -- Summary: Need a cached catalog for HiveCatalog (was: Need a cached catalog for batch SQL

[GitHub] [flink] flinkbot commented on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-01-25 Thread GitBox
flinkbot commented on pull request #14754: URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862 ## CI report: * 37484933592e8b5a4f5cf83425ac0b7b612c7480 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14746: [FLINK-21020][build] Bump Jackson to 2.10.5.1

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14746: URL: https://github.com/apache/flink/pull/14746#issuecomment-766587422 ## CI report: * 6d38e4ebf6ed9265a3b4981af0e9876d20791a38 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14745: [FLINK-21020][build] Bump Jackson to 2.10.5.1

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14745: URL: https://github.com/apache/flink/pull/14745#issuecomment-766587307 ## CI report: * 15afb719b7c64b2d8c7204d530efbccd57d63866 Azure:

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

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * fc9eebe10a60640303df43899888d783af9293a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14734: URL: https://github.com/apache/flink/pull/14734#issuecomment-766092219 ## CI report: * 721dd38bb286722cbb1a6925dbedbb3614930b20 Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #14719: [FLINK-21072] Refactor the SnapshotStrategy hierarchy

2021-01-25 Thread GitBox
dawidwys commented on a change in pull request #14719: URL: https://github.com/apache/flink/pull/14719#discussion_r563884695 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotStrategyRunner.java ## @@ -0,0 +1,132 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-19462) Checkpoint statistics for unfinished task snapshots

2021-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-19462. -- Resolution: Fixed Merged as b8cf87a..6e77cfdff8a > Checkpoint statistics for unfinished

[GitHub] [flink] pnowojski merged pull request #14635: [FLINK-19462][checkpointing] Update failed checkpoint stats

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

[GitHub] [flink] flinkbot commented on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-01-25 Thread GitBox
flinkbot commented on pull request #14754: URL: https://github.com/apache/flink/pull/14754#issuecomment-766954030 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-21127) Stores finished status for fully finished operators

2021-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21127: --- Labels: pull-request-available (was: ) > Stores finished status for fully finished

[GitHub] [flink] gaoyunhaii opened a new pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-01-25 Thread GitBox
gaoyunhaii opened a new pull request #14754: URL: https://github.com/apache/flink/pull/14754 ## What is the purpose of the change Stores the information of whether an operator is fully finished into the checkpoint metadata. To not have to introduce a new version of checkpoint

[jira] [Closed] (FLINK-21130) Add bin/ directory to PATH in docker image

2021-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21130. Fix Version/s: (was: 1.13.0) Resolution: Duplicate This is already

[GitHub] [flink] flinkbot edited a comment on pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14734: URL: https://github.com/apache/flink/pull/14734#issuecomment-766092219 ## CI report: * 721dd38bb286722cbb1a6925dbedbb3614930b20 Azure:

[jira] [Commented] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

2021-01-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271520#comment-17271520 ] Aljoscha Krettek commented on FLINK-21106: -- Side note: I'm just using the most recent IntelliJ

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

2021-01-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-21133: - Component/s: Runtime / Checkpointing > FLIP-27 Source does not work with synchronous

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

2021-01-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-21133: - Component/s: API / Core > FLIP-27 Source does not work with synchronous savepoint >

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-25 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271508#comment-17271508 ] Jane Chan commented on FLINK-21045: --- Hi [~jark], [~nicholasjiang], I apologized for the late reply. 

[GitHub] [flink] aljoscha commented on a change in pull request #14719: [FLINK-21072] Refactor the SnapshotStrategy hierarchy

2021-01-25 Thread GitBox
aljoscha commented on a change in pull request #14719: URL: https://github.com/apache/flink/pull/14719#discussion_r563860681 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotStrategyRunner.java ## @@ -0,0 +1,132 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-19465) Add CheckpointStorage interface

2021-01-25 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-19465. Resolution: Fixed > Add CheckpointStorage interface > --- > >

[jira] [Commented] (FLINK-19465) Add CheckpointStorage interface

2021-01-25 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271404#comment-17271404 ] Seth Wiesman commented on FLINK-19465: -- merged in master: 2426d84268ad330ec661a0ea6bedb2a3a2bd08e6

[GitHub] [flink] sjwiesman commented on pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

2021-01-25 Thread GitBox
sjwiesman commented on pull request #13797: URL: https://github.com/apache/flink/pull/13797#issuecomment-766924751 Merged in 2426d84268ad330ec661a0ea6bedb2a3a2bd08e6 This is an automated message from the Apache Git Service.

[GitHub] [flink] sjwiesman closed pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

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

[GitHub] [flink] sjwiesman commented on pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

2021-01-25 Thread GitBox
sjwiesman commented on pull request #13797: URL: https://github.com/apache/flink/pull/13797#issuecomment-766908446 Thanks! Will merge and rebase the follow-up later today. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #14752: [BP-1.12][FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined on DataStream

2021-01-25 Thread GitBox
flinkbot edited a comment on pull request #14752: URL: https://github.com/apache/flink/pull/14752#issuecomment-766852027 ## CI report: * 718ea7506d43d8193c56b0c0028e5301e4978018 Azure:

[GitHub] [flink] sjwiesman commented on a change in pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

2021-01-25 Thread GitBox
sjwiesman commented on a change in pull request #13797: URL: https://github.com/apache/flink/pull/13797#discussion_r563825336 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java ## @@ -79,6 +81,9 @@

[jira] [Created] (FLINK-21136) Reactive Mode: Adjust timeout behavior in declarative scheduler

2021-01-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21136: -- Summary: Reactive Mode: Adjust timeout behavior in declarative scheduler Key: FLINK-21136 URL: https://issues.apache.org/jira/browse/FLINK-21136 Project: Flink

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

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

<    1   2   3   4   5   6   >