[jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-2491: Issue Type: New Feature (was: Bug) > Checkpointing only works if all operators/tasks are s

[jira] [Assigned] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-2491: --- Assignee: Yun Gao > Checkpointing only works if all operators/tasks are still runnin

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

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-2491: Summary: Support Checkpoints After Tasks Finished (was: Checkpointing only works if all op

[jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-2491: Fix Version/s: 1.14.0 > Checkpointing only works if all operators/tasks are still running >

[GitHub] [flink] flinkbot edited a comment on pull request #15420: [WIP][FLINK-21356] Implement incremental checkpointing and recovery using state changelog

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

[jira] [Commented] (FLINK-22858) avro-confluent doesn't support confluent schema registry that has security enabled

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356237#comment-17356237 ] Dawid Wysakowicz commented on FLINK-22858: -- I think it duplicates FLINK-21229 w

[jira] [Closed] (FLINK-22858) avro-confluent doesn't support confluent schema registry that has security enabled

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22858. Resolution: Duplicate > avro-confluent doesn't support confluent schema registry that has

[GitHub] [flink] twalthr commented on a change in pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

2021-06-03 Thread GitBox
twalthr commented on a change in pull request #16037: URL: https://github.com/apache/flink/pull/16037#discussion_r644542377 ## File path: flink-connectors/flink-sql-connector-hive-3.1.2/pom.xml ## @@ -69,10 +69,56 @@ under the License. antlr-runtime

[GitHub] [flink] zentol commented on a change in pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
zentol commented on a change in pull request #16064: URL: https://github.com/apache/flink/pull/16064#discussion_r644542905 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/SharedObjects.java ## @@ -0,0 +1,156 @@ +/* +

[GitHub] [flink] xintongsong closed pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

2021-06-03 Thread GitBox
xintongsong closed pull request #15936: URL: https://github.com/apache/flink/pull/15936 -- 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. For queries about this service, pl

[GitHub] [flink] AHeise commented on pull request #15808: [FLINK-21229] add confluent schema registry ssl support

2021-06-03 Thread GitBox
AHeise commented on pull request #15808: URL: https://github.com/apache/flink/pull/15808#issuecomment-853639019 Hi @qingdao81 , thanks for your contribution. I have done a quick review round and it looks good already. Could you please resolve the compile issue (probably with your latest co

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * 54b08d305558c8c6f646c099aaf5d40134bc0bbc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

2021-06-03 Thread GitBox
flinkbot commented on pull request #16063: URL: https://github.com/apache/flink/pull/16063#issuecomment-853640847 ## CI report: * a5833f1f9f82960dcc3d860ed324e4f1fe53a3e9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] AHeise commented on a change in pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
AHeise commented on a change in pull request #16064: URL: https://github.com/apache/flink/pull/16064#discussion_r644549442 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/SharedObjects.java ## @@ -0,0 +1,156 @@ +/* +

[GitHub] [flink] flinkbot commented on pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
flinkbot commented on pull request #16064: URL: https://github.com/apache/flink/pull/16064#issuecomment-853640984 ## CI report: * a915173e65e5993e18916934ed5c8806658dfccd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] AHeise commented on a change in pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
AHeise commented on a change in pull request #16064: URL: https://github.com/apache/flink/pull/16064#discussion_r644550811 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/SharedObjects.java ## @@ -0,0 +1,156 @@ +/* +

[GitHub] [flink] luoyuxia closed pull request #16056: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for json a

2021-06-03 Thread GitBox
luoyuxia closed pull request #16056: URL: https://github.com/apache/flink/pull/16056 -- 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. For queries about this service, pleas

[GitHub] [flink] zentol commented on a change in pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
zentol commented on a change in pull request #16064: URL: https://github.com/apache/flink/pull/16064#discussion_r644551809 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/SharedObjects.java ## @@ -0,0 +1,156 @@ +/* +

[jira] [Commented] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch

2021-06-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356244#comment-17356244 ] Chesnay Schepler commented on FLINK-22859: -- Looks like the image could not be b

[GitHub] [flink] zentol merged pull request #16048: [FLINK-22820] Allow storing SUSPENDED jobs in FileArchivedExecutionGr…

2021-06-03 Thread GitBox
zentol merged pull request #16048: URL: https://github.com/apache/flink/pull/16048 -- 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. For queries about this service, please

[GitHub] [flink] zentol merged pull request #16045: [FLINK-22820] Allow storing SUSPENDED jobs in FileExecutionGraphInfoS…

2021-06-03 Thread GitBox
zentol merged pull request #16045: URL: https://github.com/apache/flink/pull/16045 -- 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. For queries about this service, please

[GitHub] [flink] twalthr closed pull request #16042: [FLINK-22824][connector-kafka] Drop usages of legacy planner in Kafka module

2021-06-03 Thread GitBox
twalthr closed pull request #16042: URL: https://github.com/apache/flink/pull/16042 -- 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. For queries about this service, please

[jira] [Created] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges

2021-06-03 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-22863: Summary: ArrayIndexOutOfBoundsException may happen when building rescale edges Key: FLINK-22863 URL: https://issues.apache.org/jira/browse/FLINK-22863 Project: Flink

[GitHub] [flink] HuangXingBo opened a new pull request #16065: [FLINK-22712][python] Support accessing Row fields by attribute name in PyFlink Row-based Operation

2021-06-03 Thread GitBox
HuangXingBo opened a new pull request #16065: URL: https://github.com/apache/flink/pull/16065 ## What is the purpose of the change *This pull request will support accessing Row fields by attribute name in PyFlink Row-based Operation* ## Brief change log - *Support

[GitHub] [flink] dawidwys opened a new pull request #16066: [FLINK-22815][checkpointing] Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread GitBox
dawidwys opened a new pull request #16066: URL: https://github.com/apache/flink/pull/16066 This is a backport of parts of #16019 and #15294 -- 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 s

[GitHub] [flink] xintongsong opened a new pull request #16067: FLINK-22683-release-1.12

2021-06-03 Thread GitBox
xintongsong opened a new pull request #16067: URL: https://github.com/apache/flink/pull/16067 This is a copy of #15936, opened against the 1.12 branch, for CI verification. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-22820) Stopping Yarn session cluster will cause fatal error

2021-06-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22820. Fix Version/s: 1.13.2 1.12.5 1.14.0 Resolution

[jira] [Updated] (FLINK-22712) Support accessing Row fields by attribute name in PyFlink Row-based Operation

2021-06-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22712: --- Labels: pull-request-available stale-assigned (was: stale-assigned) > Support accessing Row

[jira] [Closed] (FLINK-22824) Drop usages of legacy planner in Kafka modules

2021-06-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22824. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in 1.14.0: 5de3ef9bd2fe498efe4decdf998cedb68a

[jira] [Updated] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22815: --- Labels: pull-request-available (was: ) > Disable unaligned checkpoints for broadcast partit

[GitHub] [flink] flinkbot commented on pull request #16065: [FLINK-22712][python] Support accessing Row fields by attribute name in PyFlink Row-based Operation

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

[jira] [Commented] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges

2021-06-03 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356248#comment-17356248 ] Zhilong Hong commented on FLINK-22863: -- cc [~zhuzh], [~trohrmann] > ArrayIndexOutO

[GitHub] [flink] luoyuxia opened a new pull request #16068: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for j

2021-06-03 Thread GitBox
luoyuxia opened a new pull request #16068: URL: https://github.com/apache/flink/pull/16068 ## What is the purpose of the change *To figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for json and csv format.*

[GitHub] [flink] flinkbot commented on pull request #16066: [FLINK-22815][checkpointing] Disable unaligned checkpoints for broadcast partitioning

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

[GitHub] [flink] flinkbot commented on pull request #16067: FLINK-22683-release-1.12

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

[GitHub] [flink] flinkbot commented on pull request #16068: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for j

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

[GitHub] [flink] AHeise commented on pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
AHeise commented on pull request #16064: URL: https://github.com/apache/flink/pull/16064#issuecomment-853651810 I added a version where the entry-point is not serializable anymore (test examples didn't change). I think this makes it clearer what the intend is: `SharedObjects` just in the s

[jira] [Created] (FLINK-22864) Remove the legacy planner code base

2021-06-03 Thread Timo Walther (Jira)
Timo Walther created FLINK-22864: Summary: Remove the legacy planner code base Key: FLINK-22864 URL: https://issues.apache.org/jira/browse/FLINK-22864 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356254#comment-17356254 ] Dawid Wysakowicz commented on FLINK-22815: -- Fixed in: * master ** e9677357b161d

[jira] [Comment Edited] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356254#comment-17356254 ] Dawid Wysakowicz edited comment on FLINK-22815 at 6/3/21, 7:40 AM: ---

[jira] [Closed] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22686. Fix Version/s: 1.13.2 Resolution: Fixed Fixed in * master ** 4011bde30cf3dee5cccb8e

[jira] [Commented] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356258#comment-17356258 ] Piotr Nowojski commented on FLINK-22815: One more thing. Will recovery from an U

[GitHub] [flink] flinkbot edited a comment on pull request #15420: [WIP][FLINK-21356] Implement incremental checkpointing and recovery using state changelog

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

[GitHub] [flink] flinkbot edited a comment on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16063: URL: https://github.com/apache/flink/pull/16063#issuecomment-853640847 ## CI report: * a5833f1f9f82960dcc3d860ed324e4f1fe53a3e9 UNKNOWN * 13c8a06963d17baccc8e39e0bba83450765a7d55 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #16064: Adding SharedObjects junit rule to ease test development.

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

[GitHub] [flink] flinkbot commented on pull request #16065: [FLINK-22712][python] Support accessing Row fields by attribute name in PyFlink Row-based Operation

2021-06-03 Thread GitBox
flinkbot commented on pull request #16065: URL: https://github.com/apache/flink/pull/16065#issuecomment-853659026 ## CI report: * 081ce88193700e56a6be74c5aae33bf93a212f30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] luoyuxia commented on pull request #16043: [FLINK-21871][hive] Hive streaming source use FIFO FileSplitAssigner instead of LIFO

2021-06-03 Thread GitBox
luoyuxia commented on pull request #16043: URL: https://github.com/apache/flink/pull/16043#issuecomment-853658947 @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 specific

[GitHub] [flink] flinkbot commented on pull request #16066: [FLINK-22815][checkpointing][bp-1.11] Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread GitBox
flinkbot commented on pull request #16066: URL: https://github.com/apache/flink/pull/16066#issuecomment-853659174 ## CI report: * 1c3861d7327bfc38f5e22361e644959a57ed7835 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16067: FLINK-22683-release-1.12

2021-06-03 Thread GitBox
flinkbot commented on pull request #16067: URL: https://github.com/apache/flink/pull/16067#issuecomment-853659357 ## CI report: * 02105e5e11062de0c3c5406c95c0857758422ff2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16068: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for j

2021-06-03 Thread GitBox
flinkbot commented on pull request #16068: URL: https://github.com/apache/flink/pull/16068#issuecomment-853659473 ## CI report: * 6d8914162f2a228448ac0f670b8219ca037d4dee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann commented on a change in pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
tillrohrmann commented on a change in pull request #16064: URL: https://github.com/apache/flink/pull/16064#discussion_r644560962 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/SharedObjects.java ## @@ -0,0 +1,159 @@

[GitHub] [flink] luoyuxia commented on pull request #15250: [FLINK-20318][Connector/kafka]Fix cast question for properies() method in kafka ConnectorDescriptor

2021-06-03 Thread GitBox
luoyuxia commented on pull request #15250: URL: https://github.com/apache/flink/pull/15250#issuecomment-853667302 @hehuiyuan Would you like to add tests to cover this change? I think you can modify KafkaTest directly: change `properties.put("zookeeper.stuff", "12"); proper

[GitHub] [flink] luoyuxia edited a comment on pull request #15250: [FLINK-20318][Connector/kafka]Fix cast question for properies() method in kafka ConnectorDescriptor

2021-06-03 Thread GitBox
luoyuxia edited a comment on pull request #15250: URL: https://github.com/apache/flink/pull/15250#issuecomment-853667302 @hehuiyuan Thank you for your contribution. Would you like to add tests to cover this change? I think you can modify KafkaTest directly: change `proper

[jira] [Updated] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges

2021-06-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22863: Priority: Blocker (was: Critical) > ArrayIndexOutOfBoundsException may happen when building rescale edges

[jira] [Commented] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges

2021-06-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356274#comment-17356274 ] Zhu Zhu commented on FLINK-22863: - Thanks for reporting this issue. [~Thesharing] It is

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 89ca87bf3e877d25c9d95121b54ff0cafe60b9ba Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15420: [WIP][FLINK-21356] Implement incremental checkpointing and recovery using state changelog

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

[GitHub] [flink] flinkbot edited a comment on pull request #15808: [FLINK-21229] add confluent schema registry ssl support

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #15808: URL: https://github.com/apache/flink/pull/15808#issuecomment-829227618 ## CI report: * 070930ab00fecf6d07c01f3d02f4894dd8625a3a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356279#comment-17356279 ] Dawid Wysakowicz commented on FLINK-22815: -- I will double check it, but I think

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

2021-06-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356280#comment-17356280 ] Matthias commented on FLINK-22819: -- I couldn't get anything specific during my initial

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

2021-06-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356280#comment-17356280 ] Matthias edited comment on FLINK-22819 at 6/3/21, 8:20 AM: --- I

[GitHub] [flink] flinkbot edited a comment on pull request #16043: [FLINK-21871][hive] Hive streaming source use FIFO FileSplitAssigner instead of LIFO

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16043: URL: https://github.com/apache/flink/pull/16043#issuecomment-852090989 ## CI report: * 8424f11f1755cc610d82aec7850e4c8f7006d286 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16063: URL: https://github.com/apache/flink/pull/16063#issuecomment-853640847 ## CI report: * a5833f1f9f82960dcc3d860ed324e4f1fe53a3e9 UNKNOWN * 13c8a06963d17baccc8e39e0bba83450765a7d55 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16064: Adding SharedObjects junit rule to ease test development.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16068: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializin

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16068: URL: https://github.com/apache/flink/pull/16068#issuecomment-853659473 ## CI report: * 6d8914162f2a228448ac0f670b8219ca037d4dee UNKNOWN * 35bba68a4bb4c1af5d6f634d2ae24e9cf9de5831 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #16066: [FLINK-22815][checkpointing][bp-1.11] Disable unaligned checkpoints for broadcast partitioning

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

[GitHub] [flink] flinkbot edited a comment on pull request #16065: [FLINK-22712][python] Support accessing Row fields by attribute name in PyFlink Row-based Operation

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16065: URL: https://github.com/apache/flink/pull/16065#issuecomment-853659026 ## CI report: * 081ce88193700e56a6be74c5aae33bf93a212f30 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] humengyu2012 commented on pull request #15123: [FLINK-21686][Table] Make and as functions in hive parser

2021-06-03 Thread GitBox
humengyu2012 commented on pull request #15123: URL: https://github.com/apache/flink/pull/15123#issuecomment-853683703 -- 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. For qu

[GitHub] [flink] flinkbot edited a comment on pull request #16067: FLINK-22683-release-1.12

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16067: URL: https://github.com/apache/flink/pull/16067#issuecomment-853659357 ## CI report: * 02105e5e11062de0c3c5406c95c0857758422ff2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-22819: Assignee: (was: Matthias) > YARNFileReplicationITCase fails with "The YARN application unexpe

[GitHub] [flink] luoyuxia removed a comment on pull request #15123: [FLINK-21686][Table] Make and as functions in hive parser

2021-06-03 Thread GitBox
luoyuxia removed a comment on pull request #15123: URL: https://github.com/apache/flink/pull/15123#issuecomment-851933760 @flinkbot run travis -- 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

[jira] [Commented] (FLINK-21686) Duplicate code in hive parser file should be abstracted into functions

2021-06-03 Thread humengyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356281#comment-17356281 ] humengyu commented on FLINK-21686: -- Thank you for your guidance, I will finish these wo

[jira] [Comment Edited] (FLINK-21686) Duplicate code in hive parser file should be abstracted into functions

2021-06-03 Thread humengyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356281#comment-17356281 ] humengyu edited comment on FLINK-21686 at 6/3/21, 8:27 AM: --- Th

[jira] [Created] (FLINK-22865) Optimize state serialize/deserialize in PyFlink

2021-06-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22865: Summary: Optimize state serialize/deserialize in PyFlink Key: FLINK-22865 URL: https://issues.apache.org/jira/browse/FLINK-22865 Project: Flink Issue Type: I

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 89ca87bf3e877d25c9d95121b54ff0cafe60b9ba Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15123: [FLINK-21686][Table] Make and as functions in hive parser

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #15123: URL: https://github.com/apache/flink/pull/15123#issuecomment-793554080 ## CI report: * Unknown: [CANCELED](TBD) * b1851d6a9409df69b8810e5529f0b35b54f25718 UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #15420: [WIP][FLINK-21356] Implement incremental checkpointing and recovery using state changelog

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

[jira] [Updated] (FLINK-20318) Fix cast question for properies() method in kafka ConnectorDescriptor

2021-06-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20318: - Fix Version/s: 1.14.0 > Fix cast question for properies() method in kafka ConnectorDescriptor >

[jira] [Assigned] (FLINK-20318) Fix cast question for properies() method in kafka ConnectorDescriptor

2021-06-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-20318: Assignee: hehuiyuan > Fix cast question for properies() method in kafka ConnectorDescript

[GitHub] [flink] flinkbot edited a comment on pull request #15808: [FLINK-21229] add confluent schema registry ssl support

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #15808: URL: https://github.com/apache/flink/pull/15808#issuecomment-829227618 ## CI report: * 070930ab00fecf6d07c01f3d02f4894dd8625a3a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16043: [FLINK-21871][hive] Hive streaming source use FIFO FileSplitAssigner instead of LIFO

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16043: URL: https://github.com/apache/flink/pull/16043#issuecomment-852090989 ## CI report: * 8424f11f1755cc610d82aec7850e4c8f7006d286 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16059: [BP][FLINK-22795][sql-client] Throw better exception when executing remote SQL file in SQL Client

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16059: URL: https://github.com/apache/flink/pull/16059#issuecomment-853553208 ## CI report: * 6f19609017657b99af0a8f8f92460cb8c9b11ea8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16068: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializin

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16068: URL: https://github.com/apache/flink/pull/16068#issuecomment-853659473 ## CI report: * 6d8914162f2a228448ac0f670b8219ca037d4dee UNKNOWN * 35bba68a4bb4c1af5d6f634d2ae24e9cf9de5831 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16064: Adding SharedObjects junit rule to ease test development.

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

[jira] [Commented] (FLINK-21195) LimitableBulkFormat is invalid when format is orc

2021-06-03 Thread sujun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356291#comment-17356291 ] sujun commented on FLINK-21195: --- hi [~jark] [~lzljs3620320], I found that the master bran

[GitHub] [flink] fsk119 commented on a change in pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

2021-06-03 Thread GitBox
fsk119 commented on a change in pull request #15317: URL: https://github.com/apache/flink/pull/15317#discussion_r644533090 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlRichExplain.java ## @@ -28,18 +28,21 @@ import java.util.Co

[GitHub] [flink] AHeise commented on a change in pull request #16066: [FLINK-22815][checkpointing][bp-1.11] Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread GitBox
AHeise commented on a change in pull request #16066: URL: https://github.com/apache/flink/pull/16066#discussion_r644609088 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/SnapshotUtils.java ## @@ -48,7 +48,7 @@ private S

[GitHub] [flink] HuangXingBo opened a new pull request #16069: [FLINK-22865][python] Optimize state serialize/deserialize in PyFlink

2021-06-03 Thread GitBox
HuangXingBo opened a new pull request #16069: URL: https://github.com/apache/flink/pull/16069 ## What is the purpose of the change *This pull request optimize state serialize/deserialize in PyFlink* ## Brief change log - *Use dedicated coders to serialize state dat

[GitHub] [flink] dawidwys commented on a change in pull request #16066: [FLINK-22815][checkpointing][bp-1.11] Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread GitBox
dawidwys commented on a change in pull request #16066: URL: https://github.com/apache/flink/pull/16066#discussion_r644612618 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java ## @@ -384,31 +384,25 @@ public TaskAcknowledgeResu

[jira] [Updated] (FLINK-22865) Optimize state serialize/deserialize in PyFlink

2021-06-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22865: --- Labels: pull-request-available (was: ) > Optimize state serialize/deserialize in PyFlink >

[jira] [Commented] (FLINK-20234) Json format supports SE/DE null elements of ARRAY type field

2021-06-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356294#comment-17356294 ] luoyuxia commented on FLINK-20234: -- we can set option h5. debezium-json.ignore-parse-er

[GitHub] [flink] flinkbot commented on pull request #16069: [FLINK-22865][python] Optimize state serialize/deserialize in PyFlink

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

[GitHub] [flink] dawidwys commented on pull request #16066: [FLINK-22815][checkpointing][bp-1.11] Disable unaligned checkpoints for broadcast partitioning

2021-06-03 Thread GitBox
dawidwys commented on pull request #16066: URL: https://github.com/apache/flink/pull/16066#issuecomment-853706120 Sure, I will add more description. Moreover, we want to add a page in the documentation to list all limitations of UC along with an explanation for them. -- This is an automa

[GitHub] [flink] flinkbot edited a comment on pull request #15123: [FLINK-21686][Table] Make and as functions in hive parser

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #15123: URL: https://github.com/apache/flink/pull/15123#issuecomment-793554080 ## CI report: * Unknown: [CANCELED](TBD) * b1851d6a9409df69b8810e5529f0b35b54f25718 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] gaborgsomogyi commented on pull request #16057: [FLINK-22851][security] Add basic authentication support to job dashboard and REST

2021-06-03 Thread GitBox
gaborgsomogyi commented on pull request #16057: URL: https://github.com/apache/flink/pull/16057#issuecomment-853713770 @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 spe

[GitHub] [flink] flinkbot edited a comment on pull request #16057: [FLINK-22851][security] Add basic authentication support to job dashboard and REST

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16057: URL: https://github.com/apache/flink/pull/16057#issuecomment-853165652 ## CI report: * Unknown: [CANCELED](TBD) * 201bcedef3546aac3c634283325579c5d5cd8148 UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16061: URL: https://github.com/apache/flink/pull/16061#issuecomment-853573483 ## CI report: * 4075411aeeb5c59602864c346567dd2edab8a3b9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16064: Adding SharedObjects junit rule to ease test development.

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16064: URL: https://github.com/apache/flink/pull/16064#issuecomment-853640984 ## CI report: * 9874c065688ac124b8da2b31643b7dd64b6dd4c1 UNKNOWN * bd7a3bad9aa645719275a580c578fde42bef50f4 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16062: [FLINK-22854][docs-zh] Translate 'Apache Flink Documentation' index page to Chinese.

2021-06-03 Thread GitBox
flinkbot edited a comment on pull request #16062: URL: https://github.com/apache/flink/pull/16062#issuecomment-853573551 ## CI report: * 3ea58ff61228a768bd49dde7d91c77752475c8f6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16069: [FLINK-22865][python] Optimize state serialize/deserialize in PyFlink

2021-06-03 Thread GitBox
flinkbot commented on pull request #16069: URL: https://github.com/apache/flink/pull/16069#issuecomment-853724353 ## CI report: * f59e1ec1db57c22f9912fb65c192337032938076 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

  1   2   3   4   >