[jira] [Resolved] (FLINK-15668) Remove AlsoRunWithLegacyScheduler

[ https://issues.apache.org/jira/browse/FLINK-15668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15668. --- Resolution: Fixed Fixed via 3262f8d22e37c650506c49d2b30b6d97f1b677f4

[GitHub] [flink] tillrohrmann commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

tillrohrmann commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r426152374 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/externalresource/ExternalResourceUtilsTest.java ## @@ -0,0 +1,247 @@ +/* + *

[GitHub] [flink] tillrohrmann commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

tillrohrmann commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r426152091 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/ResourceInformationReflectorTest.java ## @@ -0,0 +1,173 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

flinkbot edited a comment on pull request #12189: URL: https://github.com/apache/flink/pull/12189#issuecomment-629635252 ## CI report: * 256cc76fe3de06691a8e895633e4a958aebaea4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

flinkbot edited a comment on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629283346 ## CI report: * 963b94b236ed3760422a16e466f66bfc615e9312 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 499722944af576d13757da75f4ad0d08c4538782 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * d8b233f483d45b8901cc28770be9da71a39929ef Azure:

[GitHub] [flink] tillrohrmann commented on pull request #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler

tillrohrmann commented on pull request #10899: URL: https://github.com/apache/flink/pull/10899#issuecomment-629642398 Failing e2e test case is unrelated. Merging this PR now. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * e85225100da7e5d3f06934fa331c1712a0ed4354 Azure:

[GitHub] [flink] zhijiangW commented on pull request #12163: [FLINK-17719][task][checkpointing] Provide ChannelStateReader#hasStates for hints of reading channel states

zhijiangW commented on pull request #12163: URL: https://github.com/apache/flink/pull/12163#issuecomment-629642188 Thanks for review and merging @pnowojski This is an automated message from the Apache Git Service. To

[jira] [Resolved] (FLINK-15836) Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15836. --- Resolution: Fixed Fixed via 1.11.0: 4c65864a9f0185308029761716b28d58a559d423 1.10.2:

[jira] [Commented] (FLINK-17269) Translate new Training Overview

[ https://issues.apache.org/jira/browse/FLINK-17269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109052#comment-17109052 ] Yichao Yang commented on FLINK-17269: - Hi [~alpinegizmo], I'd like to contribute to this issue,

[jira] [Commented] (FLINK-17504) Update translation of Getting Started / Overview

[ https://issues.apache.org/jira/browse/FLINK-17504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109047#comment-17109047 ] David Anderson commented on FLINK-17504: [~yangyichao] It's all yours. Thanks! > Update

[jira] [Assigned] (FLINK-17504) Update translation of Getting Started / Overview

[ https://issues.apache.org/jira/browse/FLINK-17504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-17504: -- Assignee: Yichao Yang (was: wangyichao) > Update translation of Getting Started /

[jira] [Assigned] (FLINK-17504) Update translation of Getting Started / Overview

[ https://issues.apache.org/jira/browse/FLINK-17504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-17504: -- Assignee: wangyichao > Update translation of Getting Started / Overview >

[jira] [Commented] (FLINK-17353) Broken links in Flink docs master

[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109044#comment-17109044 ] Yichao Yang commented on FLINK-17353: - Hi [~sjwiesman], I'd like to contribute to this issue, could

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * fba63e0698c8c60a04efb10a8914ea548bacc653 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

flinkbot edited a comment on pull request #12168: URL: https://github.com/apache/flink/pull/12168#issuecomment-629179735 ## CI report: * ae89a7cc9ff688be1025d5526f2f698fe46dde5f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

flinkbot edited a comment on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629283346 ## CI report: * 5634098665a7f8ed379d7c48a36146145fa58067 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

flinkbot edited a comment on pull request #12189: URL: https://github.com/apache/flink/pull/12189#issuecomment-629635252 ## CI report: * 256cc76fe3de06691a8e895633e4a958aebaea4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * 73043891f8468782029ce5abe63a3d1ed29ea09e Azure:

[GitHub] [flink] danny0405 commented on a change in pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

danny0405 commented on a change in pull request #12188: URL: https://github.com/apache/flink/pull/12188#discussion_r426150425 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/utils/ParserUtils.java ## @@ -0,0 +1,52 @@ +/* + * Licensed

[GitHub] [flink] danny0405 commented on a change in pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

danny0405 commented on a change in pull request #12188: URL: https://github.com/apache/flink/pull/12188#discussion_r426150317 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -34,29 +58,131 @@ private

[GitHub] [flink] danny0405 commented on a change in pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

danny0405 commented on a change in pull request #12188: URL: https://github.com/apache/flink/pull/12188#discussion_r426150335 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -34,29 +58,131 @@ private

[GitHub] [flink] tillrohrmann closed pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

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

[GitHub] [flink] danny0405 commented on a change in pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

danny0405 commented on a change in pull request #12188: URL: https://github.com/apache/flink/pull/12188#discussion_r426150259 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -34,29 +58,131 @@ private

[GitHub] [flink] tillrohrmann commented on pull request #12180: [FLINK-17163][docker] Remove flink-contrib/docker-flink

tillrohrmann commented on pull request #12180: URL: https://github.com/apache/flink/pull/12180#issuecomment-629639754 Just a note: The `Kubernetes test` e2e test failed in the latest build of this PR. I assume this is related to the PR #12172.

[GitHub] [flink] tillrohrmann commented on pull request #12180: [FLINK-17163][docker] Remove flink-contrib/docker-flink

tillrohrmann commented on pull request #12180: URL: https://github.com/apache/flink/pull/12180#issuecomment-629639447 Great, thanks @azagrebin. This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-15836) Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15836: -- Affects Version/s: 1.10.0 > Throw fatal error in KubernetesResourceManager when the pods

[jira] [Updated] (FLINK-15836) Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15836: -- Fix Version/s: 1.10.2 > Throw fatal error in KubernetesResourceManager when the pods watcher

[jira] [Resolved] (FLINK-17248) Make the thread nums of io executor of ClusterEntrypoint and MiniCluster configurable

[ https://issues.apache.org/jira/browse/FLINK-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17248. --- Fix Version/s: 1.10.2 1.11.0 Resolution: Fixed Fixed via

[GitHub] [flink] tillrohrmann commented on pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

tillrohrmann commented on pull request #11010: URL: https://github.com/apache/flink/pull/11010#issuecomment-629639184 Failing test case seems to be unrelated. Merging this PR now. This is an automated message from the Apache

[GitHub] [flink] tillrohrmann closed pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster

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

[jira] [Updated] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17754: --- Priority: Blocker (was: Major) > Walkthrough Table Java nightly end-to-end test failed to

[jira] [Comment Edited] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109036#comment-17109036 ] Piotr Nowojski edited comment on FLINK-17754 at 5/16/20, 12:25 PM: ---

[jira] [Commented] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109036#comment-17109036 ] Piotr Nowojski commented on FLINK-17754: All masters builds are failing in this e2e test. In

[GitHub] [flink] guoweiM commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

guoweiM commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629637583 1. Yes. It is `BucketWriter` not `BulkWriter`. 2. I got what do you mean. I would follow your suggestion. But I would want to explain why I want to name it `PartFileFactory`

[GitHub] [flink] tillrohrmann commented on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster

tillrohrmann commented on pull request #11957: URL: https://github.com/apache/flink/pull/11957#issuecomment-629637596 Test failure is unrelated. Merging this PR now. This is an automated message from the Apache Git Service.

[jira] [Assigned] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17756: -- Assignee: (was: Kurt Young) > Drop table/view shouldn't take effect on each other >

[jira] [Updated] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17756: --- Summary: Drop table/view shouldn't take effect on each other (was: Drop table/view shouldn't take

[GitHub] [flink] JingsongLi commented on a change in pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

JingsongLi commented on a change in pull request #12108: URL: https://github.com/apache/flink/pull/12108#discussion_r426141533 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -328,6 +329,17 @@ public

[jira] [Created] (FLINK-17756) Drop table/view shouldn't take affect on each other

Kurt Young created FLINK-17756: -- Summary: Drop table/view shouldn't take affect on each other Key: FLINK-17756 URL: https://issues.apache.org/jira/browse/FLINK-17756 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17504) Update translation of Getting Started / Overview

[ https://issues.apache.org/jira/browse/FLINK-17504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109026#comment-17109026 ] Yichao Yang commented on FLINK-17504: - Hi [~alpinegizmo] , I'd like to contribute to this issue,

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

flinkbot edited a comment on pull request #12120: URL: https://github.com/apache/flink/pull/12120#issuecomment-628150581 ## CI report: * a60972a16e43987b8fda57c83171a4ca639492cf Azure:

[GitHub] [flink] flinkbot commented on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

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

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * 73043891f8468782029ce5abe63a3d1ed29ea09e Azure:

[GitHub] [flink] wuchong commented on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

wuchong commented on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629634627 Added validate() and tests This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 700825f14b6128048bf2aec22947f30eaef40100 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 93f46cc0d8572f70b238640b6dbfe0b207f8c1aa Azure:

[GitHub] [flink] lirui-apache commented on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

lirui-apache commented on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-629632721 The `test_ci tests` failure shouldn't be related because it has passed in my personal build: https://dev.azure.com/lirui-apache/flink/_build/results?buildId=61=results

[GitHub] [flink] flinkbot commented on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

flinkbot commented on pull request #12189: URL: https://github.com/apache/flink/pull/12189#issuecomment-629632638 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-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109012#comment-17109012 ] Manish Ghildiyal commented on FLINK-17376: -- Closed older PR, created new:  

[GitHub] [flink] StephanEwen commented on a change in pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

StephanEwen commented on a change in pull request #12137: URL: https://github.com/apache/flink/pull/12137#discussion_r426146031 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -468,6 +468,7 @@ public

[jira] [Updated] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17376: --- Labels: pull-request-available starter (was: starter) > Remove deprecated state access

[GitHub] [flink] mghildiy opened a new pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

mghildiy opened a new pull request #12189: URL: https://github.com/apache/flink/pull/12189 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] StephanEwen commented on a change in pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

StephanEwen commented on a change in pull request #12137: URL: https://github.com/apache/flink/pull/12137#discussion_r426145923 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -487,6 +488,15 @@

[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-629631846 Thanks! Merging this now... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] lirui-apache commented on a change in pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

lirui-apache commented on a change in pull request #12108: URL: https://github.com/apache/flink/pull/12108#discussion_r426145775 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -484,18 +512,24 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 93f46cc0d8572f70b238640b6dbfe0b207f8c1aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12171: [FLINK-17715][sql client] Supports function DDLs in SQL-CLI

flinkbot edited a comment on pull request #12171: URL: https://github.com/apache/flink/pull/12171#issuecomment-629218919 ## CI report: * 2d508f776da68adffc61555a5bea2fe6a1b4d3e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * 73043891f8468782029ce5abe63a3d1ed29ea09e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * 553e00e2aec0d9e515c8baa137ff7143d3ab114a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * abf3481dcb850de081a045ae96d27c335e96e157 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

AHeise commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426144371 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -262,7 +262,9 @@ public void

[jira] [Closed] (FLINK-16075) Translate "The Broadcast State Pattern" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-16075. - Resolution: Done Merged into master via f967bcb4335a8a75b3ae19b5a351de24d0dc1cac > Translate "The Broadcast

[GitHub] [flink] carp84 merged pull request #12112: [FLINK-16075][docs-zh] Translate "The Broadcast State Pattern" page into Chinese

carp84 merged pull request #12112: URL: https://github.com/apache/flink/pull/12112 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] [Commented] (FLINK-16999) Data structure should cover all conversions declared in logical types

[ https://issues.apache.org/jira/browse/FLINK-16999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108996#comment-17108996 ] Timo Walther commented on FLINK-16999: -- Fixed in 1.11.0: 8bc744285531bd0b650c799be0a591c3492124f2

[GitHub] [flink] StephanEwen commented on pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

StephanEwen commented on pull request #11722: URL: https://github.com/apache/flink/pull/11722#issuecomment-629628166 Thank you for taking a look. I will merge both PRs together then... This is an automated message from the

[GitHub] [flink] StephanEwen commented on pull request #12187: [FLINK-5763][state backends] (follow-up) Make savepoints self-contained and relocatable

StephanEwen commented on pull request #12187: URL: https://github.com/apache/flink/pull/12187#issuecomment-629628123 Thanks for reviewing this. I will add a test for the entropy injection bug and then merge both PRs together.

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r426143357 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java ##

[GitHub] [flink] senegalo commented on pull request #12185: [FLINK-7267][connectors/rabbitmq] Allow overriding RMQ connection setup

senegalo commented on pull request #12185: URL: https://github.com/apache/flink/pull/12185#issuecomment-629628101 @austince i feel much better :) thanks for asking and i like the change instead of having to override the whole open you just override this tiny small method.

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r426143294 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java ##

[GitHub] [flink] twalthr closed pull request #12135: [FLINK-16999][table-runtime-blink] Add converters for all data types and classes

twalthr closed pull request #12135: URL: https://github.com/apache/flink/pull/12135 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] [Commented] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108995#comment-17108995 ] Dawid Wysakowicz commented on FLINK-17754: -- This might have been fixed by:

[jira] [Comment Edited] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108995#comment-17108995 ] Dawid Wysakowicz edited comment on FLINK-17754 at 5/16/20, 10:58 AM: -

[GitHub] [flink] StephanEwen commented on a change in pull request #12187: [FLINK-5763][state backends] (follow-up) Make savepoints self-contained and relocatable

StephanEwen commented on a change in pull request #12187: URL: https://github.com/apache/flink/pull/12187#discussion_r426143213 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/EntropyInjector.java ## @@ -89,6 +89,10 @@ public static Path

[GitHub] [flink] flinkbot edited a comment on pull request #12171: [FLINK-17715][sql client] Supports function DDLs in SQL-CLI

flinkbot edited a comment on pull request #12171: URL: https://github.com/apache/flink/pull/12171#issuecomment-629218919 ## CI report: * 2d508f776da68adffc61555a5bea2fe6a1b4d3e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 93f46cc0d8572f70b238640b6dbfe0b207f8c1aa Azure:

[jira] [Updated] (FLINK-17755) Expiring states should be given as side output

[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roey Shem Tov updated FLINK-17755: -- Description: When we set a StateTTLConfig to StateDescriptor, then when a record has been

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 700825f14b6128048bf2aec22947f30eaef40100 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * 553e00e2aec0d9e515c8baa137ff7143d3ab114a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12169: [FLINK-17495][metrics][prometheus]Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey

flinkbot edited a comment on pull request #12169: URL: https://github.com/apache/flink/pull/12169#issuecomment-629195529 ## CI report: * 9e55eae7a9819ab59c05e4c27d3d4992246b75f4 Azure:

[jira] [Updated] (FLINK-17755) Support side-output of expiring states with TTL.

[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roey Shem Tov updated FLINK-17755: -- Summary: Support side-output of expiring states with TTL. (was: Expiring states should be

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * 0ea67ded38cbd339a5f67656b50b874625a911b9 Azure:

[jira] [Created] (FLINK-17755) Expiring states should be given as side output

Roey Shem Tov created FLINK-17755: - Summary: Expiring states should be given as side output Key: FLINK-17755 URL: https://issues.apache.org/jira/browse/FLINK-17755 Project: Flink Issue Type:

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

senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-629626940 Please Mr @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] kl0u commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

kl0u commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629626868 Hi @guoweiM , I am proposing to name the factory `BucketWriter`, not `BulkWriter` :) (I also get confused). The reason for this is because it does not only create

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r426142494 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java ## @@

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

senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-629626611 Okay i pushed some new changes and let me explain my endeavors for the last 3 hours ! ### The Goal * combine body / correlation id parsing one go * conform with

[jira] [Updated] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17754: --- Labels: test-stability (was: ) > Walkthrough Table Java nightly end-to-end test failed to

[jira] [Created] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

Piotr Nowojski created FLINK-17754: -- Summary: Walkthrough Table Java nightly end-to-end test failed to compile Key: FLINK-17754 URL: https://issues.apache.org/jira/browse/FLINK-17754 Project: Flink

[jira] [Updated] (FLINK-17526) Support AVRO serialization and deseriazation schema for RowData type

[ https://issues.apache.org/jira/browse/FLINK-17526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17526: - Fix Version/s: 1.11.0 > Support AVRO serialization and deseriazation schema for RowData type >

[jira] [Closed] (FLINK-17526) Support AVRO serialization and deseriazation schema for RowData type

[ https://issues.apache.org/jira/browse/FLINK-17526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17526. Resolution: Implemented master: 6bc61db4eccec92f01031ad4c6d26b70ccfef1a1 > Support AVRO

[jira] [Closed] (FLINK-17718) Integrate avro to file system connector

[ https://issues.apache.org/jira/browse/FLINK-17718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17718. Resolution: Implemented master: 85bfb006c7740719bff602f3aabac8df4205a451 > Integrate avro to

[GitHub] [flink] danny0405 commented on a change in pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

danny0405 commented on a change in pull request #12178: URL: https://github.com/apache/flink/pull/12178#discussion_r426141506 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/HBaseDynamicTableFactory.java ## @@ -0,0 +1,173 @@

[GitHub] [flink] JingsongLi closed pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

JingsongLi closed pull request #12133: URL: https://github.com/apache/flink/pull/12133 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] JingsongLi closed pull request #12162: [FLINK-17718][avro] Integrate avro to file system connector

JingsongLi closed pull request #12162: URL: https://github.com/apache/flink/pull/12162 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] godfreyhe commented on a change in pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

godfreyhe commented on a change in pull request #12188: URL: https://github.com/apache/flink/pull/12188#discussion_r426141169 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -34,29 +58,131 @@ private

<    1   2   3   4   5   6   >