[jira] [Comment Edited] (FLINK-17961) Create an Elasticsearch source

[ https://issues.apache.org/jira/browse/FLINK-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119635#comment-17119635 ] Etienne Chauchot edited comment on FLINK-17961 at 6/4/20, 1:34 PM: ---

[GitHub] [flink] rkhachatryan commented on a change in pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

rkhachatryan commented on a change in pull request #12478: URL: https://github.com/apache/flink/pull/12478#discussion_r435266519 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -158,6 +159,16

[GitHub] [flink] rkhachatryan commented on a change in pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

rkhachatryan commented on a change in pull request #12478: URL: https://github.com/apache/flink/pull/12478#discussion_r435272756 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -281,6 +281,8

[GitHub] [flink] rkhachatryan commented on a change in pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

rkhachatryan commented on a change in pull request #12478: URL: https://github.com/apache/flink/pull/12478#discussion_r435273439 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -281,6 +281,8

[GitHub] [flink] flinkbot edited a comment on pull request #12352: [FLINK-17717][sql-parser] Throws for DDL create temporary system func…

flinkbot edited a comment on pull request #12352: URL: https://github.com/apache/flink/pull/12352#issuecomment-634517986 ## CI report: * 7dc817125d0684987814d45192eab87a41ebc5b5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12486: [hotfix][docs] Modify the lateness definition according to the descri…

flinkbot edited a comment on pull request #12486: URL: https://github.com/apache/flink/pull/12486#issuecomment-638848235 ## CI report: * 21bab4df76688fccc953d68398fc2cad54b0a26a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

flinkbot edited a comment on pull request #12436: URL: https://github.com/apache/flink/pull/12436#issuecomment-637399261 ## CI report: * 4d1f156fd758a44f4c394a478b6f37bc2de61c86 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12479: [FLINK-17260] Fix StreamingKafkaITCase instabilities

flinkbot edited a comment on pull request #12479: URL: https://github.com/apache/flink/pull/12479#issuecomment-638721700 ## CI report: * 1bef9a6921ec7d86739b7d6821b6f23f8602bd1b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12484: [FLINK-18127][tests] Streamline manual execution of Java E2E tests

flinkbot edited a comment on pull request #12484: URL: https://github.com/apache/flink/pull/12484#issuecomment-638836075 ## CI report: * 30b3c3dfdc501e2f8c54877d6a9c950e688dfd09 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

flinkbot edited a comment on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-638032908 ## CI report: * 12e3932ed8d74a59c0d4c28441b336284a2dffeb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

flinkbot edited a comment on pull request #12485: URL: https://github.com/apache/flink/pull/12485#issuecomment-638848123 ## CI report: * 7fe7332d4767bbfb996e86f1b59d99c8c4713192 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17961) Create an Elasticsearch source

[ https://issues.apache.org/jira/browse/FLINK-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125944#comment-17125944 ] Etienne Chauchot commented on FLINK-17961: -- I just commented in the existing de

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125945#comment-17125945 ] Etienne Chauchot commented on FLINK-16713: -- I just commented in the existing de

[jira] [Commented] (FLINK-18070) Time attribute been materialized after sub graph optimize

[ https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125952#comment-17125952 ] YufeiLiu commented on FLINK-18070: -- [~libenchao] process time have already been materi

[GitHub] [flink] flinkbot edited a comment on pull request #12479: [FLINK-17260] Fix StreamingKafkaITCase instabilities

flinkbot edited a comment on pull request #12479: URL: https://github.com/apache/flink/pull/12479#issuecomment-638721700 ## CI report: * 1bef9a6921ec7d86739b7d6821b6f23f8602bd1b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17829) Add documentation for the new JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-17829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17829: --- Labels: pull-request-available (was: ) > Add documentation for the new JDBC connector > ---

[GitHub] [flink] leonardBang opened a new pull request #12487: [FLINK-17829][docs][jdbc] Add documentation for the new JDBC connector.

leonardBang opened a new pull request #12487: URL: https://github.com/apache/flink/pull/12487 ## What is the purpose of the change *This pull request Add documentation for new JDBC connector.* ## Brief change log - Add new JDBC connector documentation which include

[GitHub] [flink] flinkbot commented on pull request #12487: [FLINK-17829][docs][jdbc] Add documentation for the new JDBC connector.

flinkbot commented on pull request #12487: URL: https://github.com/apache/flink/pull/12487#issuecomment-638886784 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] kl0u closed pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

kl0u closed pull request #12455: URL: https://github.com/apache/flink/pull/12455 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] [Created] (FLINK-18132) Add documentation for the new CSV format

Jark Wu created FLINK-18132: --- Summary: Add documentation for the new CSV format Key: FLINK-18132 URL: https://issues.apache.org/jira/browse/FLINK-18132 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18131) Add documentation for the new JSON format

Jark Wu created FLINK-18131: --- Summary: Add documentation for the new JSON format Key: FLINK-18131 URL: https://issues.apache.org/jira/browse/FLINK-18131 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18133) Add documentation for the new Avro format

Jark Wu created FLINK-18133: --- Summary: Add documentation for the new Avro format Key: FLINK-18133 URL: https://issues.apache.org/jira/browse/FLINK-18133 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17935: --- Fix Version/s: 1.12.0 > Logs could not show up when deploying Flink on Yarn via "--executor"

[jira] [Closed] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17935. -- Resolution: Fixed Fixed on master with a674b5e181a2af050aee4c4f23a86a6c61eda94f and on release

[jira] [Created] (FLINK-18134) Add documentation for the Debezium format

Jark Wu created FLINK-18134: --- Summary: Add documentation for the Debezium format Key: FLINK-18134 URL: https://issues.apache.org/jira/browse/FLINK-18134 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18135) Add documentation for the Canal format

Jark Wu created FLINK-18135: --- Summary: Add documentation for the Canal format Key: FLINK-18135 URL: https://issues.apache.org/jira/browse/FLINK-18135 Project: Flink Issue Type: Sub-task C

[jira] [Updated] (FLINK-15331) [umberlla] Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15331: Summary: [umberlla] Create a table from a changelog (was: Create a table from a changelog) > [umberlla]

[jira] [Updated] (FLINK-15331) [umbrella] Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15331: Summary: [umbrella] Create a table from a changelog (was: [umberlla] Create a table from a changelog) >

[jira] [Reopened] (FLINK-15331) Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-15331: - > Create a table from a changelog > --- > > Key: FLINK-15331 >

[GitHub] [flink] wuchong commented on pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

wuchong commented on pull request #12436: URL: https://github.com/apache/flink/pull/12436#issuecomment-638894806 Build is passed in my repo: https://dev.azure.com/imjark/Flink/_build/results?buildId=136&view=results Merging... ---

[GitHub] [flink] wuchong closed pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

wuchong closed pull request #12436: URL: https://github.com/apache/flink/pull/12436 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

[jira] [Updated] (FLINK-17847) ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

[ https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17847: Fix Version/s: (was: 1.12.0) > ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

[GitHub] [flink] dianfu opened a new pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

dianfu opened a new pull request #12488: URL: https://github.com/apache/flink/pull/12488 ## What is the purpose of the change *The implementation of method `exception` and `set_exception` are not correct. The purpose of the Python CompletableFuture is to hole the results from th

[jira] [Closed] (FLINK-17847) ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

[ https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17847. --- Resolution: Fixed - master (1.12.0): 3ee4c1f0a094d7562f4188b9fc93a2313e872cde - 1.11.0: 79b64fc42598eb799e7e

[jira] [Updated] (FLINK-18126) Correct the exception handling of the Python CompletableFuture

[ https://issues.apache.org/jira/browse/FLINK-18126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18126: --- Labels: pull-request-available (was: ) > Correct the exception handling of the Python Compl

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125362#comment-17125362 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/4/20, 2:50 PM: --

[GitHub] [flink] flinkbot commented on pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

flinkbot commented on pull request #12488: URL: https://github.com/apache/flink/pull/12488#issuecomment-638899477 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-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125989#comment-17125989 ] Stephan Ewen commented on FLINK-14971: -- In the second step I was referring to "comm

[jira] [Comment Edited] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125989#comment-17125989 ] Stephan Ewen edited comment on FLINK-14971 at 6/4/20, 3:02 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #12435: [FLINK-18059] [sql-client] Fix create/drop catalog statement can not be executed in sql client

flinkbot edited a comment on pull request #12435: URL: https://github.com/apache/flink/pull/12435#issuecomment-637372360 ## CI report: * 84524977ee6597667093943fce7c1730ab934c35 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

flinkbot edited a comment on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638593958 ## CI report: * 41240cd524255ffc7cf63d2bc2ee9ff38f3abcbd UNKNOWN * 49c19b93edb74ef702c97a4742f4936145913f35 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12487: [FLINK-17829][docs][jdbc] Add documentation for the new JDBC connector.

flinkbot commented on pull request #12487: URL: https://github.com/apache/flink/pull/12487#issuecomment-638911231 ## CI report: * 91172715268381f9bdaa7b2284fd322a9608a4ca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

flinkbot edited a comment on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-638032908 ## CI report: * 028c7804132598c982cdc82506781df5a4fb753a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

flinkbot edited a comment on pull request #12485: URL: https://github.com/apache/flink/pull/12485#issuecomment-638848123 ## CI report: * 7fe7332d4767bbfb996e86f1b59d99c8c4713192 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

flinkbot commented on pull request #12488: URL: https://github.com/apache/flink/pull/12488#issuecomment-638911342 ## CI report: * 4f60d1df216f704acb71f6546d295ed5dc640e1f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] lsyldliu commented on a change in pull request #12303: [FLINK-17625] [table] Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

lsyldliu commented on a change in pull request #12303: URL: https://github.com/apache/flink/pull/12303#discussion_r435333138 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AppendOnlyTopNFunction.java ## @@ -210,1

[jira] [Commented] (FLINK-17732) RescalingITCase.testSavepointRescalingOutPartitionedOperatorStateList

[ https://issues.apache.org/jira/browse/FLINK-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125998#comment-17125998 ] Robert Metzger commented on FLINK-17732: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-17732) RescalingITCase.testSavepointRescalingOutPartitionedOperatorStateList

[ https://issues.apache.org/jira/browse/FLINK-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17732: --- Affects Version/s: 1.12.0 > RescalingITCase.testSavepointRescalingOutPartitionedOperatorStat

[jira] [Updated] (FLINK-17732) RescalingITCase.testSavepointRescalingOutPartitionedOperatorStateList

[ https://issues.apache.org/jira/browse/FLINK-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17732: --- Labels: test-stability (was: ) > RescalingITCase.testSavepointRescalingOutPartitionedOperat

[jira] [Updated] (FLINK-17732) RescalingITCase.testSavepointRescalingOutPartitionedOperatorStateList

[ https://issues.apache.org/jira/browse/FLINK-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17732: --- Component/s: Tests Runtime / Checkpointing > RescalingITCase.testSavepointR

[GitHub] [flink] rmetzger merged pull request #12458: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

rmetzger merged pull request #12458: URL: https://github.com/apache/flink/pull/12458 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

[jira] [Resolved] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid in Hadoop 3 build profile

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-17404. Resolution: Fixed Merged to master (1.12.0) in https://github.com/apache/flink/commit/921

[GitHub] [flink] rmetzger commented on pull request #12458: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

rmetzger commented on pull request #12458: URL: https://github.com/apache/flink/pull/12458#issuecomment-638918828 Thanks a lot for the review! This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Closed] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid in Hadoop 3 build profile

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17404. -- > Running HA per-job cluster (rocks, non-incremental) gets stuck killing a > non-existing pid in

[GitHub] [flink] wuchong commented on a change in pull request #12303: [FLINK-17625] [table] Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

wuchong commented on a change in pull request #12303: URL: https://github.com/apache/flink/pull/12303#discussion_r435340328 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AppendOnlyTopNFunction.java ## @@ -210,14

[GitHub] [flink] rmetzger merged pull request #12467: [FLINK-16572] Clean up PubSub connector e2e test

rmetzger merged pull request #12467: URL: https://github.com/apache/flink/pull/12467 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] rmetzger commented on pull request #12467: [FLINK-16572] Clean up PubSub connector e2e test

rmetzger commented on pull request #12467: URL: https://github.com/apache/flink/pull/12467#issuecomment-638919331 Thank for your the review. This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126003#comment-17126003 ] Robert Metzger commented on FLINK-16572: Added more debugging in https://github

[GitHub] [flink] walterddr commented on pull request #12462: [FLINK-18045] Fix Kerberos credentials checking

walterddr commented on pull request #12462: URL: https://github.com/apache/flink/pull/12462#issuecomment-638923431 thanks for the quick update. in general the patch looks good to me. I still have only one concern regarding the alternation of 2 public APIs. but IMO `HadoopUtils` are more of

[GitHub] [flink] flinkbot edited a comment on pull request #12487: [FLINK-17829][docs][jdbc] Add documentation for the new JDBC connector.

flinkbot edited a comment on pull request #12487: URL: https://github.com/apache/flink/pull/12487#issuecomment-638911231 ## CI report: * 91172715268381f9bdaa7b2284fd322a9608a4ca Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

flinkbot edited a comment on pull request #12488: URL: https://github.com/apache/flink/pull/12488#issuecomment-638911342 ## CI report: * 4f60d1df216f704acb71f6546d295ed5dc640e1f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] azagrebin commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

azagrebin commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r435362084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -648,26 +648,8 @@ boolean offerSlot(

[GitHub] [flink] azagrebin commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

azagrebin commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r435362084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -648,26 +648,8 @@ boolean offerSlot(

[GitHub] [flink] flinkbot edited a comment on pull request #12326: [FLINK-16577] [table-planner-blink] Fix numeric type mismatch error in  column interval relmetadata

flinkbot edited a comment on pull request #12326: URL: https://github.com/apache/flink/pull/12326#issuecomment-633786013 ## CI report: * 0b14ce7cf01c6664a3a98c35dd1c494a7ad4fc32 UNKNOWN * 8c198bc1bb0b6be3321a01898e09d7492169b47e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] azagrebin commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

azagrebin commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r435362084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -648,26 +648,8 @@ boolean offerSlot(

[GitHub] [flink] flinkbot edited a comment on pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

flinkbot edited a comment on pull request #12488: URL: https://github.com/apache/flink/pull/12488#issuecomment-638911342 ## CI report: * 4f60d1df216f704acb71f6546d295ed5dc640e1f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435366834 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,271 @@ +/* + * Licensed t

[GitHub] [flink] azagrebin commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

azagrebin commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r435362084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -648,26 +648,8 @@ boolean offerSlot(

[GitHub] [flink] leonardBang commented on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

leonardBang commented on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638946255 The PR updated @dawidwys , please help take a look. This is an automated message from the Apache Git Service

[jira] [Assigned] (FLINK-17954) Do not multiplex remote function state into single PersistedTable

[ https://issues.apache.org/jira/browse/FLINK-17954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-17954: --- Assignee: Tzu-Li (Gordon) Tai > Do not multiplex remote function state into

[GitHub] [flink] flinkbot edited a comment on pull request #12471: [FLINK-18073][FLINK-18029][avro] Fix AvroRowDataSerializationSchema is not serializable and add IT cases

flinkbot edited a comment on pull request #12471: URL: https://github.com/apache/flink/pull/12471#issuecomment-638362836 ## CI report: * ec7b1367e121a52731e84f0f5b8610b362c4c169 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12468: [FLINK-18075] Wrap the SerializationSchema in KafkaSerializationSchema in Kafka connector

flinkbot edited a comment on pull request #12468: URL: https://github.com/apache/flink/pull/12468#issuecomment-638243685 ## CI report: * 7bf026a4e23a89df952f6b361ab8fe435c0a612d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

flinkbot edited a comment on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638593958 ## CI report: * 41240cd524255ffc7cf63d2bc2ee9ff38f3abcbd UNKNOWN * 49c19b93edb74ef702c97a4742f4936145913f35 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] HuangZhenQiu commented on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-638957276 @pnowojski For your comments. 1) There is no test that is marked to ignore by this PR. Would you please double-check? 2) Rebased master again. 3) Add join logic to

[jira] [Created] (FLINK-18136) Don't start channel state writing for savepoints (RPC)

Roman Khachatryan created FLINK-18136: - Summary: Don't start channel state writing for savepoints (RPC) Key: FLINK-18136 URL: https://issues.apache.org/jira/browse/FLINK-18136 Project: Flink

[GitHub] [flink] zhijiangW commented on pull request #12460: [FLINK-18063][checkpointing] Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner

zhijiangW commented on pull request #12460: URL: https://github.com/apache/flink/pull/12460#issuecomment-638963043 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] rkhachatryan opened a new pull request #12489: [FLINK-18136] Don't start channel state writing for savepoints (RPC)

rkhachatryan opened a new pull request #12489: URL: https://github.com/apache/flink/pull/12489 ## What is the purpose of the change `StreamTask.triggerCheckpoint` calls `channelStateWriter.start` unconditionally. For savepoints and when unaligned mode is disabled this is incorrect

[jira] [Updated] (FLINK-18136) Don't start channel state writing for savepoints (RPC)

[ https://issues.apache.org/jira/browse/FLINK-18136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18136: --- Labels: pull-request-available (was: ) > Don't start channel state writing for savepoints (

[GitHub] [flink] flinkbot commented on pull request #12489: [FLINK-18136] Don't start channel state writing for savepoints (RPC)

flinkbot commented on pull request #12489: URL: https://github.com/apache/flink/pull/12489#issuecomment-638974327 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 edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * 35ef82ee0bf1d008719a52e8182f9b63f3eddb11 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

flinkbot edited a comment on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638593958 ## CI report: * 41240cd524255ffc7cf63d2bc2ee9ff38f3abcbd UNKNOWN * 49c19b93edb74ef702c97a4742f4936145913f35 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12482: [FLINK-17831][doc] Add documentation for the new Kafka connector

flinkbot edited a comment on pull request #12482: URL: https://github.com/apache/flink/pull/12482#issuecomment-638825868 ## CI report: * c8c39d8552852d4b7fdbd84501052d08d9b0963d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pnowojski commented on a change in pull request #12470: [FLINK-18074][checkpoint] Ensure task could fail when exception thrown out on notified of checkpoint completed/aborted

pnowojski commented on a change in pull request #12470: URL: https://github.com/apache/flink/pull/12470#discussion_r435404303 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -919,9 +920,33 @@ public final Executor

[GitHub] [flink] flinkbot edited a comment on pull request #12352: [FLINK-17717][sql-parser] Throws for DDL create temporary system func…

flinkbot edited a comment on pull request #12352: URL: https://github.com/apache/flink/pull/12352#issuecomment-634517986 ## CI report: * 6d12fc558cc4c24403fc39884d4d7fea41dfffcf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

flinkbot edited a comment on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12489: [FLINK-18136] Don't start channel state writing for savepoints (RPC)

flinkbot commented on pull request #12489: URL: https://github.com/apache/flink/pull/12489#issuecomment-638985663 ## CI report: * 5136fc6b80380c9ff9be14c67d6a286dbac118a5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

flinkbot edited a comment on pull request #12483: URL: https://github.com/apache/flink/pull/12483#issuecomment-638835966 ## CI report: * d8400d687e17309f9c69c296fdbf16a1323a07f4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18038) StateBackendLoader logs application-defined state before it is fully configured

[ https://issues.apache.org/jira/browse/FLINK-18038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126082#comment-17126082 ] Steve Bairos commented on FLINK-18038: -- That's fair. What if we modify the "Configu

[GitHub] [flink] tillrohrmann commented on a change in pull request #12446: [FLINK-16225] Implement user class loading exception handler

tillrohrmann commented on a change in pull request #12446: URL: https://github.com/apache/flink/pull/12446#discussion_r435420178 ## File path: flink-core/src/main/java/org/apache/flink/util/ClassLoaderWithErrorHandler.java ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Sof

[jira] [Updated] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18137: --- Labels: test-stability (was: ) > JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint

[jira] [Created] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

Robert Metzger created FLINK-18137: -- Summary: JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException Key: FLINK-18137 URL: https://issues.apache.org/jira/browse/FLINK-18137

[jira] [Updated] (FLINK-17384) Support reading hbase conf dir from flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17384: -- Summary: Support reading hbase conf dir from flink-conf.yaml (was: support read hbase conf dir from flink.con

[GitHub] [flink] carp84 closed pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

carp84 closed pull request #12144: URL: https://github.com/apache/flink/pull/12144 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 t

[jira] [Created] (FLINK-18138) KeyedComplexChainTest.testMigrationAndRestore fails with AskTimeoutException on CI

Robert Metzger created FLINK-18138: -- Summary: KeyedComplexChainTest.testMigrationAndRestore fails with AskTimeoutException on CI Key: FLINK-18138 URL: https://issues.apache.org/jira/browse/FLINK-18138

[jira] [Updated] (FLINK-17384) Support reading hbase conf dir from flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17384: -- Fix Version/s: (was: 1.11.0) 1.12.0 Issue Type: Improvement (was: Bug) Changing

[GitHub] [flink] flinkbot edited a comment on pull request #12489: [FLINK-18136] Don't start channel state writing for savepoints (RPC)

flinkbot edited a comment on pull request #12489: URL: https://github.com/apache/flink/pull/12489#issuecomment-638985663 ## CI report: * 5136fc6b80380c9ff9be14c67d6a286dbac118a5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

flinkbot edited a comment on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17384) Support reading hbase conf dir from flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17384: -- Description: Currently when using hbase connector with Flink SQL, below manual steps are required: # export

[jira] [Closed] (FLINK-17384) Support reading hbase conf dir from flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-17384. - Release Note: After FLINK-17384 hbase connector supports reading hbase configuration directory from flink-conf.y

[jira] [Commented] (FLINK-17860) Recursively remove channel state directories

[ https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126121#comment-17126121 ] Roman Khachatryan commented on FLINK-17860: --- After fixing FLINK-17988 there is

<    1   2   3   4   5   6   7   >