[jira] [Updated] (FLINK-22788) Code of equals method grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-22788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22788: - Fix Version/s: (was: 1.12.6) 1.12.5 > Code of equals method grows beyond

[jira] [Updated] (FLINK-22757) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22757: - Fix Version/s: (was: 1.12.6) 1.12.5 > Update GCS documentation >

[GitHub] [flink] flinkbot edited a comment on pull request #16330: [FLINK-23187][Documentation]Update PubSubSink examples with topicName in documentation

flinkbot edited a comment on pull request #16330: URL: https://github.com/apache/flink/pull/16330#issuecomment-870978293 ## CI report: * a82472f8ef36e1431ed31ca8a76bc58d09f88933 Azure:

[jira] [Created] (FLINK-23190) Make task-slot allocation much more evenly

loyi created FLINK-23190: Summary: Make task-slot allocation much more evenly Key: FLINK-23190 URL: https://issues.apache.org/jira/browse/FLINK-23190 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23189) Count and fail the task when the disk is error on JobManager

zlzhang0122 created FLINK-23189: --- Summary: Count and fail the task when the disk is error on JobManager Key: FLINK-23189 URL: https://issues.apache.org/jira/browse/FLINK-23189 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16321: [FLINK-23017][sql-client] HELP in sql-client still shows the removed SOURCE functionality

flinkbot edited a comment on pull request #16321: URL: https://github.com/apache/flink/pull/16321#issuecomment-870544339 ## CI report: * 634c352538350045201f5ec2a605948ee9a4d28f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16318: [FLINK-22945][runtime] Avoid StackOverflowException when a large scale job is canceling or failing

flinkbot edited a comment on pull request #16318: URL: https://github.com/apache/flink/pull/16318#issuecomment-870361119 ## CI report: * 5324a4d41a67e234e044df0d515b1962c4fbec87 Azure:

[jira] [Commented] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

[ https://issues.apache.org/jira/browse/FLINK-23156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371808#comment-17371808 ] zoucao commented on FLINK-23156: hi [~jark], i do some fix in

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22621: - Labels: test-stability (was: ) > HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22621: - Affects Version/s: (was: 1.13.0) 1.14.0 1.13.1

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22621: - Fix Version/s: 1.13.2 1.14.0 >

[jira] [Commented] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371806#comment-17371806 ] Xintong Song commented on FLINK-22621: --

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371805#comment-17371805 ] Xintong Song commented on FLINK-22971: --

[GitHub] [flink] flinkbot edited a comment on pull request #16321: [FLINK-23017][sql-client] HELP in sql-client still shows the removed SOURCE functionality

flinkbot edited a comment on pull request #16321: URL: https://github.com/apache/flink/pull/16321#issuecomment-870544339 ## CI report: * 634c352538350045201f5ec2a605948ee9a4d28f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16331: [1.12][FLINK-23052][ci] Improve stability of maven snapshot deployment

flinkbot edited a comment on pull request #16331: URL: https://github.com/apache/flink/pull/16331#issuecomment-871082289 ## CI report: * 11076dca9ce600886f16365fad15dbca8936ad4a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16318: [FLINK-22945][runtime] Avoid StackOverflowException when a large scale job is canceling or failing

flinkbot edited a comment on pull request #16318: URL: https://github.com/apache/flink/pull/16318#issuecomment-870361119 ## CI report: * 5324a4d41a67e234e044df0d515b1962c4fbec87 Azure:

[GitHub] [flink] flinkbot commented on pull request #16331: [1.12][FLINK-23052][ci] Improve stability of maven snapshot deployment

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

[jira] [Comment Edited] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink

[ https://issues.apache.org/jira/browse/FLINK-23165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371793#comment-17371793 ] Nicholas Jiang edited comment on FLINK-23165 at 6/30/21, 4:11 AM: --

[jira] [Comment Edited] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink

[ https://issues.apache.org/jira/browse/FLINK-23165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371793#comment-17371793 ] Nicholas Jiang edited comment on FLINK-23165 at 6/30/21, 4:09 AM: --

[jira] [Commented] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink

[ https://issues.apache.org/jira/browse/FLINK-23165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371793#comment-17371793 ] Nicholas Jiang commented on FLINK-23165: [~karmagyz], I have already completed to work for this

[GitHub] [flink] tisonkun closed pull request #10601: [FLINK-14867][api] Move TextInputFormat & TextOutputFormat to flink-core

tisonkun closed pull request #10601: URL: https://github.com/apache/flink/pull/10601 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] tisonkun closed pull request #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

tisonkun closed pull request #9878: URL: https://github.com/apache/flink/pull/9878 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] godfreyhe commented on a change in pull request #16219: [FLINK-22781][table-planner-blink] Fix bug in emit behavior of GroupWindowAggregate to skip emit window result if input stream

godfreyhe commented on a change in pull request #16219: URL: https://github.com/apache/flink/pull/16219#discussion_r66525 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/AggregateWindowOperator.java ## @@

[GitHub] [flink] SteNicholas commented on a change in pull request #16307: [FLINK-21925][api] Support configuring fine grained resource requirements via DataStream API

SteNicholas commented on a change in pull request #16307: URL: https://github.com/apache/flink/pull/16307#discussion_r661108805 ## File path: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala ## @@ -106,6 +107,21 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16318: [FLINK-22945][runtime] Avoid StackOverflowException when a large scale job is canceling or failing

flinkbot edited a comment on pull request #16318: URL: https://github.com/apache/flink/pull/16318#issuecomment-870361119 ## CI report: * 5324a4d41a67e234e044df0d515b1962c4fbec87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16312: [FLINK-23089] Add flink-rpc-akka-module

flinkbot edited a comment on pull request #16312: URL: https://github.com/apache/flink/pull/16312#issuecomment-869768855 ## CI report: * 887d37d4c5e812effd37795358f9fd4bbd50f6c3 Azure:

[GitHub] [flink] flinkbot commented on pull request #16331: [FLINK-23052][ci] Improve stability of maven snapshot deployment

flinkbot commented on pull request #16331: URL: https://github.com/apache/flink/pull/16331#issuecomment-871070232 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-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371785#comment-17371785 ] Xintong Song commented on FLINK-22387: --

[GitHub] [flink] xintongsong opened a new pull request #16331: [FLINK-23052][ci] Improve stability of maven snapshot deployment

xintongsong opened a new pull request #16331: URL: https://github.com/apache/flink/pull/16331 Port #16293 to release-1.12 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Reopened] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-23052: -- Reopen to port to 1.12. Instance on 1.12:

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371783#comment-17371783 ] Xintong Song commented on FLINK-22971: --

[jira] [Updated] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22480: - Affects Version/s: 1.14.0 > KafkaChangelogTableITCase hangs on Azure >

[jira] [Updated] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22480: - Fix Version/s: 1.13.2 1.14.0 > KafkaChangelogTableITCase hangs on Azure >

[GitHub] [flink] lirui-apache commented on pull request #16310: [FLINK-22898][Connectors/Hive] return default-parallelism in HiveParallelismInference when there is no source infer

lirui-apache commented on pull request #16310: URL: https://github.com/apache/flink/pull/16310#issuecomment-871066230 @luoyuxia Please also add a test case where `TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM` is not set and the default value (-1) is returned. To make sure returning -1 really

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371782#comment-17371782 ] Xintong Song commented on FLINK-22480: --

[GitHub] [flink] flinkbot edited a comment on pull request #16318: [FLINK-22945][runtime] Avoid StackOverflowException when a large scale job is canceling or failing

flinkbot edited a comment on pull request #16318: URL: https://github.com/apache/flink/pull/16318#issuecomment-870361119 ## CI report: * 5324a4d41a67e234e044df0d515b1962c4fbec87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16310: [FLINK-22898][Connectors/Hive] return default-parallelism in HiveParallelismInference when there is no source infer

flinkbot edited a comment on pull request #16310: URL: https://github.com/apache/flink/pull/16310#issuecomment-869691722 ## CI report: * 579880224cc2639d760d83f2ef7cb9af7fd77374 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16142: [FLINK-22748][connector-kafka] Allow dynamic target topic selection in SQL Kafka sinks

flinkbot edited a comment on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-859341888 ## CI report: * 3c6b0b37d9dce76563870adce5e421a94d0100c2 Azure:

[jira] [Updated] (FLINK-23172) Links of restart strategy in configuration page is broken

[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-23172: Priority: Major (was: Minor) > Links of restart strategy in configuration page is broken >

[jira] [Updated] (FLINK-23172) Links of restart strategy in configuration page is broken

[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-23172: Issue Type: Bug (was: Technical Debt) > Links of restart strategy in configuration page is broken >

[GitHub] [flink] zhuzhurk commented on pull request #16318: [FLINK-22945][runtime] Avoid StackOverflowException when a large scale job is canceling or failing

zhuzhurk commented on pull request #16318: URL: https://github.com/apache/flink/pull/16318#issuecomment-871059249 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] beyond1920 commented on pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

beyond1920 commented on pull request #16215: URL: https://github.com/apache/flink/pull/16215#issuecomment-871056359 @godfreyhe Thanks for advice, I would add some comments here. At the same time, I create a [FLINK-23055](https://issues.apache.org/jira/browse/FLINK-23055) to add user

[GitHub] [flink] beyond1920 commented on a change in pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

beyond1920 commented on a change in pull request #16215: URL: https://github.com/apache/flink/pull/16215#discussion_r661091381 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowAggregateITCase.scala ##

[GitHub] [flink] zjuwangg commented on a change in pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin

zjuwangg commented on a change in pull request #16025: URL: https://github.com/apache/flink/pull/16025#discussion_r661090847 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWindowTableFunction.java

[GitHub] [flink] dianfu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

dianfu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-871054326 @YikSanChan Regarding to tests, you could take a look ZipUtilsTests which is added recently for reference. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-playgrounds] qilingzhao commented on pull request #25: [hotfix] Remove the suffix of url to make it correct

qilingzhao commented on pull request #25: URL: https://github.com/apache/flink-playgrounds/pull/25#issuecomment-871054120 this problem merged at #22 , Removing ".html" suffix and removing "/docs" are working -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #16310: [FLINK-22898][Connectors/Hive] return default-parallelism in HiveParallelismInference when there is no source infer

flinkbot edited a comment on pull request #16310: URL: https://github.com/apache/flink/pull/16310#issuecomment-869691722 ## CI report: * 579880224cc2639d760d83f2ef7cb9af7fd77374 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16142: [FLINK-22748][connector-kafka] Allow dynamic target topic selection in SQL Kafka sinks

flinkbot edited a comment on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-859341888 ## CI report: * 3c6b0b37d9dce76563870adce5e421a94d0100c2 Azure:

[GitHub] [flink-playgrounds] qilingzhao opened a new pull request #25: [hotfix] Remove the suffix of url to make it correct

qilingzhao opened a new pull request #25: URL: https://github.com/apache/flink-playgrounds/pull/25 In README.md file, the links of "Flink Operations Playground" and "Real Time Reporting with the Table API" got "404.html". I fixed it. -- This is an automated message from the Apache

[jira] [Created] (FLINK-23188) Unsupported function definition: IFNULL. Only user defined functions are supported as inline functions

xiaojin.wy created FLINK-23188: -- Summary: Unsupported function definition: IFNULL. Only user defined functions are supported as inline functions Key: FLINK-23188 URL:

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Labels: pull-request-available (was: pull-request-available stale-assigned) > Reduce the default

[GitHub] [flink] flinkbot edited a comment on pull request #16330: [FLINK-23187][Documentation]Update PubSubSink examples with topicName in documentation

flinkbot edited a comment on pull request #16330: URL: https://github.com/apache/flink/pull/16330#issuecomment-870978293 ## CI report: * a82472f8ef36e1431ed31ca8a76bc58d09f88933 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16296: [FLINK-23088] Add flink-rpc-core module

flinkbot edited a comment on pull request #16296: URL: https://github.com/apache/flink/pull/16296#issuecomment-868781471 ## CI report: * d97f0e3918da20c3dcc7fc5b95d1b601078fc5ea Azure:

[GitHub] [flink] SteNicholas commented on pull request #16142: [FLINK-22748][connector-kafka] Allow dynamic target topic selection in SQL Kafka sinks

SteNicholas commented on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-871042478 > There are still some changes in FlinkKafkaProducer that you should revert. Please also squash the commits. Then I'd do a final pass. Yes, I have reverted the

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371772#comment-17371772 ] Jingsong Lee commented on FLINK-22073: -- Hi [~luoyuxia] The parallelism of FiniteTestSource must be

[GitHub] [flink] luoyuxia commented on pull request #16310: [FLINK-22898][Connectors/Hive] return default-parallelism in HiveParallelismInference when there is no source infer

luoyuxia commented on pull request #16310: URL: https://github.com/apache/flink/pull/16310#issuecomment-871037322 @lirui-apache I see HiveTableSourceITCase#testParallelismOnLimitPushDown cover the parallelism when infer-source-parallelism is false, should we just reuse this test or

[GitHub] [flink] StephanEwen commented on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

StephanEwen commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-871028756 @tweise - I am a bit late to this, but quickly wanted to check (since you tagged me here): Do you need another pair of eyes or help with some thoughts/discussions, or is

[GitHub] [flink] cuibo01 commented on pull request #16315: FLINK-23174 Log improvement in Task throws Error

cuibo01 commented on pull request #16315: URL: https://github.com/apache/flink/pull/16315#issuecomment-871018807 hi @zentol @dawidwys @pnowojski @rkhachatryan @zhuzhurk @tillrohrmann @rmetzger @becketqin can you review the PR, thx -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13954: [FLINK-19903][Table SQL / API] Metadata fields for filesystem csv format

flinkbot edited a comment on pull request #13954: URL: https://github.com/apache/flink/pull/13954#issuecomment-722706660 ## CI report: * 4e6541cdcfd108ed9c797426acb6e753c9894a53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13954: [FLINK-19903][Table SQL / API] Metadata fields for filesystem csv format

flinkbot edited a comment on pull request #13954: URL: https://github.com/apache/flink/pull/13954#issuecomment-722706660 ## CI report: * c964a81eabfb0b3fe92f65c3dc4359f52ae7f2ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16327: [FLINK-22964][connector/common] Exclude flink-core from connector-common dependencies. [1.12]

flinkbot edited a comment on pull request #16327: URL: https://github.com/apache/flink/pull/16327#issuecomment-870849819 ## CI report: * 32d8e15a3bdb4bcdb6dcbceb125ccfb5155a9fb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16330: [FLINK-23187][Documentation]Update PubSubSink examples with topicName in documentation

flinkbot edited a comment on pull request #16330: URL: https://github.com/apache/flink/pull/16330#issuecomment-870978293 ## CI report: * a82472f8ef36e1431ed31ca8a76bc58d09f88933 Azure:

[GitHub] [flink] flinkbot commented on pull request #16330: [FLINK-23187][Documentation]Update PubSubSink examples with topicName in documentation

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

[GitHub] [flink] flinkbot edited a comment on pull request #16325: [FLINK-20888][runtime] Close outputs in OperatorChain. [1.13]

flinkbot edited a comment on pull request #16325: URL: https://github.com/apache/flink/pull/16325#issuecomment-870828090 ## CI report: * f3510e68ce45e4fc29014f9690547b9a3e1a579a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16328: [FLINK-22462][tests] Fix JdbcExactlyOnceSinkE2eTest by pausing emission until checkpoint confirmed

flinkbot edited a comment on pull request #16328: URL: https://github.com/apache/flink/pull/16328#issuecomment-870863496 ## CI report: * dab46e1692c77c29d662133c0d516bd7b393b2aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16326: [FLINK-22964][connector/common] Exclude flink-core from connector-common dependencies. [1.13]

flinkbot edited a comment on pull request #16326: URL: https://github.com/apache/flink/pull/16326#issuecomment-870849694 ## CI report: * 2707347490f3ed0771381a61b6855f1597c48713 Azure:

[jira] [Updated] (FLINK-19571) Port Transformation translation logic to TransformationTranslator framework

[ https://issues.apache.org/jira/browse/FLINK-19571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19571: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13278: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

[ https://issues.apache.org/jira/browse/FLINK-22949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22949: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-12340) Cache frontend-maven-plugin npm artifacts

[ https://issues.apache.org/jira/browse/FLINK-12340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12340: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8093: -- Labels: auto-deprioritized-critical auto-unassigned stale-major usability (was:

[jira] [Updated] (FLINK-19524) Google Season of Docs - FLIP 60

[ https://issues.apache.org/jira/browse/FLINK-19524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19524: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-12754) alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned

[ https://issues.apache.org/jira/browse/FLINK-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12754: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22735: --- Labels: auto-deprioritized-blocker test-stability (was: stale-blocker test-stability)

[jira] [Updated] (FLINK-13301) Some PlannerExpression resultType is not consistent with Calcite Type inference

[ https://issues.apache.org/jira/browse/FLINK-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13301: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17808: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21431: --- Labels: auto-unassigned pull-request-available stale-critical test-stability (was:

[jira] [Updated] (FLINK-19303) Disable WAL in RocksDB recovery

[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19303: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-14116) Translate changes on Getting Started Overview to Chinese

[ https://issues.apache.org/jira/browse/FLINK-14116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14116: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-13503) Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null

[ https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13503: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17274: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-13861) No new checkpoint will be trigged when canceling an expired checkpoint failed

[ https://issues.apache.org/jira/browse/FLINK-13861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13861: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-13218) '*.count not supported in TableApi query

[ https://issues.apache.org/jira/browse/FLINK-13218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13218: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-13437) Add Hive SQL E2E test

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13437: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22755) SequenceStreamingFileSinkITCase.testWriteSequenceFile fail

[ https://issues.apache.org/jira/browse/FLINK-22755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22755: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-22754) Finished job not always archived properly

[ https://issues.apache.org/jira/browse/FLINK-22754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22754: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-13213) MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig will be removed after call toAppendStream/toRetractStream without QueryConfig parameters

[ https://issues.apache.org/jira/browse/FLINK-13213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13213: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16012: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19710: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14500: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Closed] (FLINK-20713) out/err file support rolling

[ https://issues.apache.org/jira/browse/FLINK-20713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-20713. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 days ago and has not received

[jira] [Updated] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22073: --- Labels: auto-deprioritized-major stale-assigned test-stability (was:

[GitHub] [flink] flinkbot edited a comment on pull request #16324: [FLINK-20888][runtime] Close outputs in OperatorChain. [1.12]

flinkbot edited a comment on pull request #16324: URL: https://github.com/apache/flink/pull/16324#issuecomment-870813386 ## CI report: * dfd52d03f8981b1d662a5503a8a48f49b3196600 Azure:

[GitHub] [flink] flinkbot commented on pull request #16330: [FLINK-23187][Documentation]Update PubSubSink examples with topicName in documentation

flinkbot commented on pull request #16330: URL: https://github.com/apache/flink/pull/16330#issuecomment-870961835 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-23187) [Documentation] PubSubSink should use "withTopicName" rather than "withSubscriptionName"

[ https://issues.apache.org/jira/browse/FLINK-23187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23187: --- Labels: pull-request-available (was: ) > [Documentation] PubSubSink should use

[GitHub] [flink] jaredbwasserman opened a new pull request #16330: [FLINK-23187][Documentation]Update PubSubSink examples with topicName in documentation

jaredbwasserman opened a new pull request #16330: URL: https://github.com/apache/flink/pull/16330 ## What is the purpose of the change There are two PubSubSink code examples in the documentation:

[jira] [Created] (FLINK-23187) [Documentation] PubSubSink should use "withTopicName" rather than "withSubscriptionName"

Jared Wasserman created FLINK-23187: --- Summary: [Documentation] PubSubSink should use "withTopicName" rather than "withSubscriptionName" Key: FLINK-23187 URL: https://issues.apache.org/jira/browse/FLINK-23187

[GitHub] [flink] flinkbot edited a comment on pull request #16329: [BP-1.13][FLINK-22462][tests] Fix JdbcExactlyOnceSinkE2eTest by pausing emission until checkpoint confirmed

flinkbot edited a comment on pull request #16329: URL: https://github.com/apache/flink/pull/16329#issuecomment-870936087 ## CI report: * 4686320496e20b7df66e529eb5dc8d71d4c455ee Azure:

[GitHub] [flink] flinkbot commented on pull request #16329: [BP-1.13][FLINK-22462][tests] Fix JdbcExactlyOnceSinkE2eTest by pausing emission until checkpoint confirmed

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

[GitHub] [flink] flinkbot edited a comment on pull request #16296: [FLINK-23088] Add flink-rpc-core module

flinkbot edited a comment on pull request #16296: URL: https://github.com/apache/flink/pull/16296#issuecomment-868781471 ## CI report: * 14ca1d37186c276e91b3a625a59e86f6e1f65618 Azure:

  1   2   3   4   5   >