[jira] [Updated] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18056: Component/s: Connectors / Hive > Hive file sink throws exception when the target in-progress file exists.

[jira] [Updated] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18056: Description: Currently after failover or restart, the Hive file sink will try to overwrite the data

[jira] [Updated] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18056: - Priority: Blocker (was: Major) > Hive file sink throws exception when the target in-progress

[jira] [Created] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

Yun Gao created FLINK-18056: --- Summary: Hive file sink throws exception when the target in-progress file exists. Key: FLINK-18056 URL: https://issues.apache.org/jira/browse/FLINK-18056 Project: Flink

[jira] [Assigned] (FLINK-18055) Catalog does not exist in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-18055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18055: Assignee: godfrey he > Catalog does not exist in SQL Client >

[jira] [Updated] (FLINK-18055) Catalog does not exist in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-18055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18055: - Priority: Blocker (was: Major) > Catalog does not exist in SQL Client >

[GitHub] [flink] flinkbot edited a comment on pull request #12426: [FLINK-18048] Fix --host option for standalone application cluster

flinkbot edited a comment on pull request #12426: URL: https://github.com/apache/flink/pull/12426#issuecomment-636791297 ## CI report: * 55800ba7a29a835c0aa956fe5469d191a0e27b5c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

flinkbot edited a comment on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637225112 ## CI report: * a89e768be2ee7a6952f74a96a2e9551dad785e9c Azure:

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

Jiayi-Liao commented on a change in pull request #11176: URL: https://github.com/apache/flink/pull/11176#discussion_r433629963 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -566,6 +562,22 @@ private ClusterSpecification

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

Jiayi-Liao commented on a change in pull request #11176: URL: https://github.com/apache/flink/pull/11176#discussion_r433629963 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -566,6 +562,22 @@ private ClusterSpecification

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

Jiayi-Liao commented on a change in pull request #11176: URL: https://github.com/apache/flink/pull/11176#discussion_r433629963 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -566,6 +562,22 @@ private ClusterSpecification

[GitHub] [flink] flinkbot edited a comment on pull request #11664: [FLINK-16101][docs-zh] Translate "Hive Functions" page of "Hive Integration" into Chinese

flinkbot edited a comment on pull request #11664: URL: https://github.com/apache/flink/pull/11664#issuecomment-610721731 ## CI report: * f81472fca76eb1edf85758da22860bb92564875b UNKNOWN * 4a4f5f227b7464683d74242f3b2f5a082f5ab8b7 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

flinkbot edited a comment on pull request #12386: URL: https://github.com/apache/flink/pull/12386#issuecomment-635398532 ## CI report: * 590be0e43b1f9e656fea887e8ef15c3aae07c55e Azure:

[GitHub] [flink] klion26 commented on a change in pull request #12311: [FLINK-17269][docs] Translate new Training Overview to Chinese

klion26 commented on a change in pull request #12311: URL: https://github.com/apache/flink/pull/12311#discussion_r433600360 ## File path: docs/training/index.zh.md ## @@ -29,158 +29,90 @@ under the License. * This will be replaced by the TOC {:toc} -## Goals and Scope of

[GitHub] [flink-web] zjffdu opened a new pull request #344: [blog] flink on zeppelin - part2

zjffdu opened a new pull request #344: URL: https://github.com/apache/flink-web/pull/344 This is part2 of flink on zeppelin blog. This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-18055) Catalog does not exist in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-18055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18055: --- Fix Version/s: 1.11.0 > Catalog does not exist in SQL Client >

[GitHub] [flink] flinkbot edited a comment on pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

flinkbot edited a comment on pull request #12386: URL: https://github.com/apache/flink/pull/12386#issuecomment-635398532 ## CI report: * 590be0e43b1f9e656fea887e8ef15c3aae07c55e Azure:

[jira] [Updated] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Table

[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16622: Fix Version/s: (was: 1.11.0) 1.11.1 > Type ARRAY of table field 'id' does not

[GitHub] [flink] flinkbot edited a comment on pull request #11664: [FLINK-16101][docs-zh] Translate "Hive Functions" page of "Hive Integration" into Chinese

flinkbot edited a comment on pull request #11664: URL: https://github.com/apache/flink/pull/11664#issuecomment-610721731 ## CI report: * f81472fca76eb1edf85758da22860bb92564875b UNKNOWN * 4a4f5f227b7464683d74242f3b2f5a082f5ab8b7 Travis:

[jira] [Created] (FLINK-18055) Catalog does not exist in SQL Client

godfrey he created FLINK-18055: -- Summary: Catalog does not exist in SQL Client Key: FLINK-18055 URL: https://issues.apache.org/jira/browse/FLINK-18055 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #11664: [FLINK-16101][docs-zh] Translate "Hive Functions" page of "Hive Integration" into Chinese

flinkbot edited a comment on pull request #11664: URL: https://github.com/apache/flink/pull/11664#issuecomment-610721731 ## CI report: * f81472fca76eb1edf85758da22860bb92564875b UNKNOWN * d7260c2fd8c3e707e7bdc1ed7f748d6dace021f8 Travis:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #124: [FLINK-18016] [doc] Add documentation for UDS domain socket transport

tzulitai commented on a change in pull request #124: URL: https://github.com/apache/flink-statefun/pull/124#discussion_r433610353 ## File path: docs/sdk/java.md ## @@ -364,6 +364,47 @@ PersistedTable table = PersistedTable.of("my-table", String.cla PersistedAppendingBuffer

[GitHub] [flink] flinkbot edited a comment on pull request #12426: [FLINK-18048] Fix --host option for standalone application cluster

flinkbot edited a comment on pull request #12426: URL: https://github.com/apache/flink/pull/12426#issuecomment-636791297 ## CI report: * a092cda314fe1b3429370e72a2da99b9a4a5e0b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

flinkbot edited a comment on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637225112 ## CI report: * a89e768be2ee7a6952f74a96a2e9551dad785e9c Azure:

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17122333#comment-17122333 ] Yun Tang commented on FLINK-17800: -- [~liyu] Thanks for your suggestion. [~YordanPavlov], from my local

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-17800: - Priority: Critical (was: Blocker) > RocksDB optimizeForPointLookup results in missing time windows >

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

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #12370: [FLINK-17923][python] Allow Python worker to use off-heap memory

zhuzhurk commented on a change in pull request #12370: URL: https://github.com/apache/flink/pull/12370#discussion_r433609036 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala ## @@ -150,6 +152,64 @@ trait

[GitHub] [flink] wuchong commented on pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on pull request #12386: URL: https://github.com/apache/flink/pull/12386#issuecomment-637258814 Thanks for the reviewing @danny0405 , I have updated the PR. This is an automated message from the Apache Git

[GitHub] [flink] zhuzhurk commented on a change in pull request #12370: [FLINK-17923][python] Allow Python worker to use off-heap memory

zhuzhurk commented on a change in pull request #12370: URL: https://github.com/apache/flink/pull/12370#discussion_r433608507 ## File path: flink-python/src/main/java/org/apache/flink/python/PythonOptions.java ## @@ -148,4 +149,17 @@ "The priority is as

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433606653 ## File path: docs/dev/table/connectors/index.md ## @@ -0,0 +1,268 @@ +--- +title: "Table & SQL Connectors" +nav-id: sql-connectors +nav-parent_id:

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433606448 ## File path: docs/dev/table/connectors/index.md ## @@ -0,0 +1,268 @@ +--- +title: "Table & SQL Connectors" +nav-id: sql-connectors +nav-parent_id:

[jira] [Reopened] (FLINK-16397) flink metric graphite will format double metrics to "%2.2f"

[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla reopened FLINK-16397: --- There is a new feature to support custom floating point formatter in Graphite reporter, can flink

[GitHub] [flink] flinkbot edited a comment on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

flinkbot edited a comment on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637225112 ## CI report: * a89e768be2ee7a6952f74a96a2e9551dad785e9c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

flinkbot edited a comment on pull request #12430: URL: https://github.com/apache/flink/pull/12430#issuecomment-637244001 ## CI report: * 41eed27e209404ed33a02835331feb8115653891 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12426: [FLINK-18048] Fix --host option for standalone application cluster

flinkbot edited a comment on pull request #12426: URL: https://github.com/apache/flink/pull/12426#issuecomment-636791297 ## CI report: * a092cda314fe1b3429370e72a2da99b9a4a5e0b7 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433605237 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[GitHub] [flink] flinkbot edited a comment on pull request #11664: [FLINK-16101][docs-zh] Translate "Hive Functions" page of "Hive Integration" into Chinese

flinkbot edited a comment on pull request #11664: URL: https://github.com/apache/flink/pull/11664#issuecomment-610721731 ## CI report: * f81472fca76eb1edf85758da22860bb92564875b UNKNOWN * d7260c2fd8c3e707e7bdc1ed7f748d6dace021f8 Travis:

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433604088 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433604088 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[jira] [Comment Edited] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121532#comment-17121532 ] Yu Li edited comment on FLINK-17918 at 6/2/20, 3:38 AM: Thanks [~jark], I was

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121532#comment-17121532 ] Yu Li commented on FLINK-17918: --- Thanks [~jark], I was about to add the same comments, that the observed

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433601763 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433601307 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433601187 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[jira] [Closed] (FLINK-17968) Hadoop Configuration is not properly serialized in HBaseRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-17968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17968. --- Resolution: Fixed Fixed in - master (1.12.0): 03b82f9aa81b828b06c61f7f30f92a331ec5120b - 1.11.0:

[GitHub] [flink] wuchong merged pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

wuchong merged pull request #12146: URL: https://github.com/apache/flink/pull/12146 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 #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

wuchong commented on pull request #12146: URL: https://github.com/apache/flink/pull/12146#issuecomment-637247709 Build is passed, merging... This is an automated message from the Apache Git Service. To respond to the

[jira] [Comment Edited] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121526#comment-17121526 ] Jark Wu edited comment on FLINK-17918 at 6/2/20, 3:23 AM: -- Thanks [~pnowojski]

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121526#comment-17121526 ] Jark Wu commented on FLINK-17918: - Thanks [~pnowojski] and [~AHeise] for the investigating. After

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121524#comment-17121524 ] Jiangjie Qin commented on FLINK-12030: -- [~rmetzger] Technically speaking this is caused by the same

[jira] [Assigned] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17918: --- Assignee: Jark Wu (was: Arvid Heise) > Blink Jobs are loosing data on recovery >

[jira] [Assigned] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17918: --- Assignee: (was: Jark Wu) > Blink Jobs are loosing data on recovery >

[GitHub] [flink] libenchao commented on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

libenchao commented on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637244509 @KurtYoung Thanks for addressing my comments, the changes LGTM now. This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

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

[jira] [Assigned] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17923: --- Assignee: Dian Fu > It will throw MemoryAllocationException if rocksdb statebackend and Python >

[GitHub] [flink] KurtYoung commented on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

KurtYoung commented on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637242185 @libenchao thanks for your review, I've addressed your comment. This is an automated message from the Apache

[GitHub] [flink] libenchao commented on a change in pull request #12428: [FLINK-18049] the AvroRowDeserializationSchema can not read the avro …

libenchao commented on a change in pull request #12428: URL: https://github.com/apache/flink/pull/12428#discussion_r433593166 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java ## @@ -157,13 +150,13 @@ public

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121514#comment-17121514 ] Zhu Zhu commented on FLINK-17726: - [~nicholasjiang] What I mean is that not all kinds of directly

[GitHub] [flink] KurtYoung commented on a change in pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

KurtYoung commented on a change in pull request #12429: URL: https://github.com/apache/flink/pull/12429#discussion_r433593470 ## File path: docs/dev/table/common.md ## @@ -32,12 +32,11 @@ Main Differences Between the Two Planners 1. Blink treats batch jobs as a special case

[jira] [Updated] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17182: - Priority: Major (was: Critical) > RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail

[GitHub] [flink] flinkbot edited a comment on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

flinkbot edited a comment on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637225112 ## CI report: * a89e768be2ee7a6952f74a96a2e9551dad785e9c Azure:

[GitHub] [flink] flinkbot commented on pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

flinkbot commented on pull request #12430: URL: https://github.com/apache/flink/pull/12430#issuecomment-637238327 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] zhijiangW commented on pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

zhijiangW commented on pull request #12430: URL: https://github.com/apache/flink/pull/12430#issuecomment-637237923 Cherry-pick from release-1.11 to master, the original PR #12261 was already reviewed and approved, merging when azure pass.

[jira] [Closed] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

[ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max closed FLINK-18000. --- Resolution: Not A Problem > Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet > 1.18.2 >

[GitHub] [flink] zhijiangW opened a new pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

zhijiangW opened a new pull request #12430: URL: https://github.com/apache/flink/pull/12430 ## What is the purpose of the change RemoteInputChannel#releaseAllResources might be called by canceler thread. Meanwhile, the task thread can also call RemoteInputChannel#getNextBuffer.

[jira] [Commented] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

[ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121509#comment-17121509 ] Max commented on FLINK-18000: - Thanks for your quickly response. After read the document that you post. I

[GitHub] [flink] danny0405 commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

danny0405 commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433589932 ## File path: docs/dev/table/connectors/index.md ## @@ -0,0 +1,268 @@ +--- +title: "Table & SQL Connectors" +nav-id: sql-connectors +nav-parent_id:

[GitHub] [flink] libenchao commented on a change in pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

libenchao commented on a change in pull request #12429: URL: https://github.com/apache/flink/pull/12429#discussion_r433588491 ## File path: docs/dev/table/common.md ## @@ -32,12 +32,11 @@ Main Differences Between the Two Planners 1. Blink treats batch jobs as a special case

[jira] [Updated] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

[ https://issues.apache.org/jira/browse/FLINK-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18050: - Description: When task finishes, the `CheckpointBarrierUnaligner` will decline the current checkpoint,

[jira] [Commented] (FLINK-18054) Environment should provide API to resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121499#comment-17121499 ] Sergii Mikhtoniuk commented on FLINK-18054: --- I have also noticed some behavioral differences

[jira] [Created] (FLINK-18054) Environment should provide API to resume from savepoint

Sergii Mikhtoniuk created FLINK-18054: - Summary: Environment should provide API to resume from savepoint Key: FLINK-18054 URL: https://issues.apache.org/jira/browse/FLINK-18054 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

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

[jira] [Commented] (FLINK-18053) Savepoints do not preserve watermarks

[ https://issues.apache.org/jira/browse/FLINK-18053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121485#comment-17121485 ] Jiayi Liao commented on FLINK-18053: Yes. Flink doesn't save watermark in savepoint. Duplicate of

[GitHub] [flink-web] klion26 commented on pull request #342: [FLINK-17926] Fix the build problem of docker image

klion26 commented on pull request #342: URL: https://github.com/apache/flink-web/pull/342#issuecomment-637223581 @sjwiesman thanks for the replay, previously I prefer using Ubuntu image because that Ubuntu support LTS version, and Fedora doesn't. I'm fine to use Fedora image if we want to

[GitHub] [flink] danny0405 commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

danny0405 commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433575384 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id:

[GitHub] [flink] SteNicholas edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

SteNicholas edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-636436145 @zentol Sorry for disturbing your work, I would like to confirm with you whether the value of ```{{ site.baseurl }}``` doesn't start with ```https:```.

[GitHub] [flink] yangyichao-mango commented on pull request #12417: [hotfix][docs] Remove the redundant punctuation in dev/training/index.md

yangyichao-mango commented on pull request #12417: URL: https://github.com/apache/flink/pull/12417#issuecomment-637221586 Hi @alpinegizmo . Can you help to review this commit? This is an automated message from the Apache Git

[GitHub] [flink] yangyichao-mango commented on pull request #12418: [hotfix][docs] Fix the description of bounded-of-orderness in docs/de…

yangyichao-mango commented on pull request #12418: URL: https://github.com/apache/flink/pull/12418#issuecomment-637220967 Hi @aljoscha . Can you help to review this commit? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

flinkbot commented on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637221101 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-18053) Savepoints do not preserve watermarks

[ https://issues.apache.org/jira/browse/FLINK-18053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergii Mikhtoniuk updated FLINK-18053: -- Description: Flink produces invalid result when streaming SQL aggregation is stopped 

[jira] [Updated] (FLINK-17340) Update docs which related to default planner changes

[ https://issues.apache.org/jira/browse/FLINK-17340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17340: --- Labels: pull-request-available (was: ) > Update docs which related to default planner

[GitHub] [flink] KurtYoung opened a new pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

KurtYoung opened a new pull request #12429: URL: https://github.com/apache/flink/pull/12429 ## What is the purpose of the change Update the documents. This is an automated message from the Apache Git

[jira] [Created] (FLINK-18053) Savepoints do not preserve watermarks

Sergii Mikhtoniuk created FLINK-18053: - Summary: Savepoints do not preserve watermarks Key: FLINK-18053 URL: https://issues.apache.org/jira/browse/FLINK-18053 Project: Flink Issue Type:

[GitHub] [flink] SteNicholas removed a comment on pull request #12419: [FLINK-17996][table-planner-blink] NPE in CatalogTableStatisticsConverter.convertToColumnStats method

SteNicholas removed a comment on pull request #12419: URL: https://github.com/apache/flink/pull/12419#issuecomment-636850914 @JingsongLi @wuchong Would you please help to merge? This is an automated message from the Apache

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121477#comment-17121477 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]I agree with that directly CANCELED tasks

[GitHub] [flink-statefun] sjwiesman commented on pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

sjwiesman commented on pull request #123: URL: https://github.com/apache/flink-statefun/pull/123#issuecomment-637185185 One suggestion, otherwise +1 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17194. Resolution: Fixed Re-occurrence was likely due to FLINK-18035. > TPC-DS end-to-end test

[GitHub] [flink] carp84 commented on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

carp84 commented on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-637059489 @liuyongvs Thanks for updating the PR. Let me review first and see whether any change requested. This is an

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121282#comment-17121282 ] Erwan Loisant commented on FLINK-13414: --- Any news on that front? Scala 2.13 has been released for

[jira] [Commented] (FLINK-12005) [State TTL] Event time support

[ https://issues.apache.org/jira/browse/FLINK-12005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121272#comment-17121272 ] Yu Li commented on FLINK-12005: --- Hi [~lyee], sorry but I'm not actively working on this issue at the

[jira] [Updated] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement

[ https://issues.apache.org/jira/browse/FLINK-17851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17851: --- Priority: Critical (was: Major) >

[jira] [Commented] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement

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

[GitHub] [flink] austince commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

austince commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-637047348 I think it might have something to do with FLINK-18051 This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-12428) Translate the "Event Time" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-12428: - Assignee: Yubin Li (was: jack) It seems [~lyy900111] is not actively working on this, I'm reassigning

[jira] [Reopened] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-17194: This test failure occurred after the fix has been merged:

[jira] [Updated] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement

[ https://issues.apache.org/jira/browse/FLINK-17851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17851: --- Fix Version/s: 1.11.0 > FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord

[jira] [Updated] (FLINK-18052) Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE

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

[jira] [Commented] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement

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

[jira] [Updated] (FLINK-18052) Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE

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

  1   2   3   >