[GitHub] [flink] flinkbot edited a comment on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

flinkbot edited a comment on pull request #12447: URL: https://github.com/apache/flink/pull/12447#issuecomment-637744551 ## CI report: * a3b95a59180c019a5c34da7d5905502606f38121 Azure:

[GitHub] [flink-docker] rmetzger edited a comment on pull request #9: [FLINK-16260][docker] Add docker images based on Java 11

rmetzger edited a comment on pull request #9: URL: https://github.com/apache/flink-docker/pull/9#issuecomment-639052230 @iemejia any chance you can finish this in the next one or two weeks? Flink 1.11 is around the corner, and it would be nice to have Java 11 images ready at that

[GitHub] [flink-docker] rmetzger commented on pull request #9: [FLINK-16260][docker] Add docker images based on Java 11

rmetzger commented on pull request #9: URL: https://github.com/apache/flink-docker/pull/9#issuecomment-639052230 @iemejia any chance you can finish this in the next one or two weeks? Flink 1.11 is around the corner, and it would be nice to have Java 11 images ready at that occasion.

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

[GitHub] [flink] flinkbot commented on pull request #12490: [FLINK-17974][docs] Extend docker documentation

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

[GitHub] [flink] rmetzger commented on a change in pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

rmetzger commented on a change in pull request #12447: URL: https://github.com/apache/flink/pull/12447#discussion_r435472328 ## File path: tools/ci/compile.sh ## @@ -54,10 +54,22 @@ if [ $EXIT_CODE != 0 ]; then exit $EXIT_CODE fi -echo " Checking Scaladocs

[jira] [Updated] (FLINK-17974) Test new Flink Docker image

[ https://issues.apache.org/jira/browse/FLINK-17974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17974: --- Labels: pull-request-available release-testing (was: release-testing) > Test new Flink

[GitHub] [flink] rmetzger opened a new pull request #12490: [FLINK-17974][docs] Extend docker documentation

rmetzger opened a new pull request #12490: URL: https://github.com/apache/flink/pull/12490 ## What is the purpose of the change While testing the new docker images, I found that some details were missing on the documentation page.

[jira] [Comment Edited] (FLINK-17974) Test new Flink Docker image

[ https://issues.apache.org/jira/browse/FLINK-17974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125244#comment-17125244 ] Robert Metzger edited comment on FLINK-17974 at 6/4/20, 6:34 PM: -

[jira] [Comment Edited] (FLINK-17974) Test new Flink Docker image

[ https://issues.apache.org/jira/browse/FLINK-17974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125244#comment-17125244 ] Robert Metzger edited comment on FLINK-17974 at 6/4/20, 6:18 PM: -

[jira] [Assigned] (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:all-tabpanel ] Yu Li reassigned FLINK-18038: - Fix Version/s: 1.12.0 Assignee: Steve Bairos Issue Type: Improvement (was: Bug)

[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: * 2c7be46e975aaaef574cc3620169a3b3178b310e Azure:

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

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

[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: * fef42fb8497d9822a12ab18114ecb0ea4f36509f Azure:

[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=17126121#comment-17126121 ] Roman Khachatryan commented on FLINK-17860: --- After fixing FLINK-17988 there is no immediate

[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

[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

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

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

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

[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

[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

[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

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

[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

[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=17126082#comment-17126082 ] Steve Bairos commented on FLINK-18038: -- That's fair. What if we modify the "Configuring

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

[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

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

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

[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

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

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

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

[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

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

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

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

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

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

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

[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

[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

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

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

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

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

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

[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

[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=17126003#comment-17126003 ] Robert Metzger commented on FLINK-16572: Added more debugging in

[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

[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

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

[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

[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

[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

[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

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

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

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

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

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

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

[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

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

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

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

[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

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

[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=17125989#comment-17125989 ] Stephan Ewen edited comment on FLINK-14971 at 6/4/20, 3:02 PM: --- In the

[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=17125989#comment-17125989 ] Stephan Ewen commented on FLINK-14971: -- In the second step I was referring to "committing

[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

[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=17125362#comment-17125362 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/4/20, 2:50 PM:

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

[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

[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

[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

[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

[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=results Merging...

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

[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

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

[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

[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

[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

[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

[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

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

<    1   2   3   4   5   6   7   >