[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=17125952#comment-17125952 ] YufeiLiu commented on FLINK-18070: -- [~libenchao] process time have already been materialized at

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

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

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

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

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

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

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

[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

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

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

[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

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

[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

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

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

[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

[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

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

[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

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

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

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

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

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

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

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

[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

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

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

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

[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] [Commented] (FLINK-17961) Create an Elasticsearch source

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

[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=17125945#comment-17125945 ] Etienne Chauchot commented on FLINK-16713: -- I just commented in the existing design discussion

[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

[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

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

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

[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] flinkbot commented on pull request #12491: [hotfix][docs] Remove HADOOP_CONF_DIR from docs

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

[GitHub] [flink] flinkbot commented on pull request #12492: [FLINK-10740][docs] Add documentation for FLIP-27 sources

flinkbot commented on pull request #12492: URL: https://github.com/apache/flink/pull/12492#issuecomment-639064750 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] krasinski edited a comment on pull request #12462: [FLINK-18045] Fix Kerberos credentials checking

krasinski edited a comment on pull request #12462: URL: https://github.com/apache/flink/pull/12462#issuecomment-638494158 thank you for the review @walterddr, I've addressed all the comments and added some more unit tests I've also introduced a small change in

[GitHub] [flink] zentol commented on pull request #12392: [FLINK-17765] Trim stack traces

zentol commented on pull request #12392: URL: https://github.com/apache/flink/pull/12392#issuecomment-639095073 > I think the PR goes a bit in a different direction than I intended it to go initially. Yes that is true, but I feel like this approach is more universal. It pretty much

[jira] [Updated] (FLINK-10740) FLIP-27: Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10740: --- Labels: pull-request-available usability (was: usability) > FLIP-27: Refactor Source

[GitHub] [flink] rmetzger opened a new pull request #12491: [hotfix][docs] Remove HADOOP_CONF_DIR

rmetzger opened a new pull request #12491: URL: https://github.com/apache/flink/pull/12491 The Hadoop configuration page was quite confusing because it suggested that the user has to set the HADOOP_CONF_DIR as well. All jars and configs can and should be passed through

[GitHub] [flink] StephanEwen opened a new pull request #12492: [FLINK-10740][docs] Add documentation for FLIP-27 sources

StephanEwen opened a new pull request #12492: URL: https://github.com/apache/flink/pull/12492 Documentation for the FLIP-27 sources. This contains placeholders for two sections so far. This is an automated message

[GitHub] [flink] flinkbot commented on pull request #12492: [FLINK-10740][docs] Add documentation for FLIP-27 sources

flinkbot commented on pull request #12492: URL: https://github.com/apache/flink/pull/12492#issuecomment-639069379 ## CI report: * cddeb832d918a8c795e68de5e829c820d6c9ce2b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #12490: URL: https://github.com/apache/flink/pull/12490#issuecomment-639060534 ## CI report: * 7660076d9143396ffdd4cf376874e06e6d67e8de Azure:

  1   2   3   4   5   6   7   >