[GitHub] [flink] flinkbot commented on pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

flinkbot commented on pull request #16316: URL: https://github.com/apache/flink/pull/16316#issuecomment-870252751 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-16090) Translate "Table API" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16090: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Translate "Table

[GitHub] [flink] yljee opened a new pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

yljee opened a new pull request #16316: URL: https://github.com/apache/flink/pull/16316 ## What is the purpose of the change Translate "Table API" page of "Table API & SQL" into Chinese. The page url is

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

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

[GitHub] [flink] godfreyhe 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 WindowJoi

godfreyhe commented on a change in pull request #16025: URL: https://github.com/apache/flink/pull/16025#discussion_r660269928 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #16314: [FLINK-23005][coordination] Optimize the deployment of tasks

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

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

flinkbot commented on pull request #16315: URL: https://github.com/apache/flink/pull/16315#issuecomment-870238926 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-23174) Log improvement in Task throws Error

[ https://issues.apache.org/jira/browse/FLINK-23174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23174: --- Labels: pull-request-available (was: ) > Log improvement in Task throws Error >

[GitHub] [flink] cuibo01 opened a new pull request #16315: FLINK-23174 Log improvement in Task throws Error

cuibo01 opened a new pull request #16315: URL: https://github.com/apache/flink/pull/16315 ## 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] flinkbot commented on pull request #16314: [FLINK-23005][coordination] Optimize the deployment of tasks

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

[GitHub] [flink] flinkbot edited a comment on pull request #16239: [FLINK-23054][table] Correct upsert optimization by upsert keys

flinkbot edited a comment on pull request #16239: URL: https://github.com/apache/flink/pull/16239#issuecomment-865833767 ## CI report: * c3fda52ffdf8160ce4beca256feb14023c77373c 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: * 42e12926d6185a514cce554e825394aad318a12d Azure:

[GitHub] [flink] flinkbot commented on pull request #16314: [FLINK-23005][runtime] Optimize the deployment of tasks

flinkbot commented on pull request #16314: URL: https://github.com/apache/flink/pull/16314#issuecomment-870216503 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-23005) Optimize the deployment of tasks

[ https://issues.apache.org/jira/browse/FLINK-23005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23005: --- Labels: pull-request-available (was: ) > Optimize the deployment of tasks >

[GitHub] [flink] flinkbot edited a comment on pull request #16283: [FLINK-23149][table-code-splitter] Introduce the new Java code splitter module

flinkbot edited a comment on pull request #16283: URL: https://github.com/apache/flink/pull/16283#issuecomment-868177111 ## CI report: * f60176579d7b4518ba7f10124456258a58fec05e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16239: [FLINK-23054][table] Correct upsert optimization by upsert keys

flinkbot edited a comment on pull request #16239: URL: https://github.com/apache/flink/pull/16239#issuecomment-865833767 ## CI report: * c3fda52ffdf8160ce4beca256feb14023c77373c Azure:

[GitHub] [flink] Thesharing opened a new pull request #16314: [FLINK-23005] Optimize the deployment of tasks

Thesharing opened a new pull request #16314: URL: https://github.com/apache/flink/pull/16314 ## What is the purpose of the change *This pull request proposes to optimize the performance of task deployment. The main idea is to introduce a cache for the TaskDeploymentDescriptor. We

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

[GitHub] [flink] godfreyhe commented on a change in pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

godfreyhe commented on a change in pull request #16192: URL: https://github.com/apache/flink/pull/16192#discussion_r660263242 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/table/CorrelateTest.scala ## @@ -204,4

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371029#comment-17371029 ] godfrey he commented on FLINK-22954: [~wenlong.lwl] I think we should also make sure there is not

[jira] [Created] (FLINK-23174) Log improvement in Task throws Error

Bo Cui created FLINK-23174: -- Summary: Log improvement in Task throws Error Key: FLINK-23174 URL: https://issues.apache.org/jira/browse/FLINK-23174 Project: Flink Issue Type: Improvement

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

SteNicholas edited a comment on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-870208177 @AHeise , thanks for detailed rephrase and I hold a different point of view: 1. The `defaultTopicId` could be null in the constructor of

[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-870208177 @AHeise , thanks for detailed rephrase and I hold a different point of view: 1. The `defaultTopicId` could be null in the constructor of `KafkaSerializationSchema`

[jira] [Created] (FLINK-23173) Inconsistency detected by ld.so

Xintong Song created FLINK-23173: Summary: Inconsistency detected by ld.so Key: FLINK-23173 URL: https://issues.apache.org/jira/browse/FLINK-23173 Project: Flink Issue Type: Bug Affects

[jira] [Commented] (FLINK-15031) Automatically calculate required network memory for fine-grained jobs

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371019#comment-17371019 ] Yangze Guo commented on FLINK-15031: Thanks for the input, [~zhuzh]. +1 for introducing a fraction

[GitHub] [flink] flinkbot edited a comment on pull request #16283: [FLINK-23149][table-code-splitter] Introduce the new Java code splitter module

flinkbot edited a comment on pull request #16283: URL: https://github.com/apache/flink/pull/16283#issuecomment-868177111 ## CI report: * f60176579d7b4518ba7f10124456258a58fec05e Azure:

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

Zhilong Hong created FLINK-23172: Summary: Links of restart strategy in configuration page is broken Key: FLINK-23172 URL: https://issues.apache.org/jira/browse/FLINK-23172 Project: Flink

[GitHub] [flink] zjuwangg commented on 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 pull request #16025: URL: https://github.com/apache/flink/pull/16025#issuecomment-870197372 LGTM. cc @godfreyhe to have another review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

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

[jira] [Commented] (FLINK-15031) Automatically calculate required network memory for fine-grained jobs

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371012#comment-17371012 ] Jin Xing commented on FLINK-15031: -- Some details for network memory allocation algorithm: *For Input:*

[jira] [Closed] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-23135. -- Resolution: Fixed > Flink SQL Error while applying rule AggregateReduceGroupingRule >

[jira] [Updated] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22157: --- Fix Version/s: 1.12.5 > Join & Select a part of composite primary key will cause >

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371011#comment-17371011 ] godfrey he commented on FLINK-23135: Fixed in 1.12.5: d1b8c5fd54e1d104387ef6acb94b9a9698378ed3 >

[jira] [Comment Edited] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319853#comment-17319853 ] godfrey he edited comment on FLINK-22157 at 6/29/21, 3:06 AM: -- Fixed in

[jira] [Comment Edited] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319853#comment-17319853 ] godfrey he edited comment on FLINK-22157 at 6/29/21, 3:06 AM: -- Fixed in

[GitHub] [flink] godfreyhe closed pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

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

[jira] [Closed] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs

[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-18335. Resolution: Fixed > NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs >

[jira] [Commented] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs

[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371010#comment-17371010 ] Yun Tang commented on FLINK-18335: -- I think the failed case on March did not include the fix and I will

[jira] [Commented] (FLINK-23171) Can't execute SET table.sql-dialect=hive;

[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371002#comment-17371002 ] JasonLee commented on FLINK-23171: -- hi luoyuxia Thank you for your reply. In fact, I used the package

[jira] [Assigned] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-22059: Assignee: xiaogang zhou > add a new option is rocksdb statebackend to enable job threads setting

[jira] [Commented] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371001#comment-17371001 ] Yun Tang commented on FLINK-22059: -- [~zhoujira86] Okay, re-assign this ticket to you. > add a new

[jira] [Commented] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371000#comment-17371000 ] Jingsong Lee commented on FLINK-22898: -- Yes. > HiveParallelismInference limit return wrong

[jira] [Commented] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files

[ https://issues.apache.org/jira/browse/FLINK-22897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370999#comment-17370999 ] Jingsong Lee commented on FLINK-22897: -- I think we need let sink chain from sort operator. >

[jira] [Comment Edited] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370989#comment-17370989 ] xiaogang zhou edited comment on FLINK-22059 at 6/29/21, 2:28 AM: -

[jira] [Commented] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370989#comment-17370989 ] xiaogang zhou commented on FLINK-22059: --- Sorry I forgot it, will submit a PR soon this week. thx

[jira] [Commented] (FLINK-23171) Can't execute SET table.sql-dialect=hive;

[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370988#comment-17370988 ] luoyuxia commented on FLINK-23171: -- [~JasonLee] Hi, maybe you need to build the whole flink again ,

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

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

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370985#comment-17370985 ] Xintong Song commented on FLINK-22085: -- [~gaoyunhaii], New instance found. Please take another

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

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

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370983#comment-17370983 ] Jingsong Lee commented on FLINK-22781: -- Although it is an Experimental API, we already exposed it

[GitHub] [flink] tisonkun merged pull request #16300: [Hotfix][docs] Fixed typos.

tisonkun merged pull request #16300: URL: https://github.com/apache/flink/pull/16300 -- 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 commented on pull request #16300: [Hotfix][docs] Fixed typos.

tisonkun commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-870168255 Thank you! Merging... -- 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

[jira] [Updated] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

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

[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=17370979#comment-17370979 ] Xintong Song commented on FLINK-22387: --

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

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

[GitHub] [flink] godfreyhe merged pull request #16230: [hotfix][docs] Updated description of HOP and CUMULATE parameters

godfreyhe merged pull request #16230: URL: https://github.com/apache/flink/pull/16230 -- 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] leonardBang commented on pull request #16230: [hotfix][docs] Updated description of HOP and CUMULATE parameters

leonardBang commented on pull request #16230: URL: https://github.com/apache/flink/pull/16230#issuecomment-870157287 Thanks @mans2singh The build has passed, I‘ll find committer to help merge soon -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] SteNicholas commented on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

SteNicholas commented on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-870142926 LGTM. -- 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] [Closed] (FLINK-23166) ZipUtils doesn't handle properly for softlinks inside the zip file

[ https://issues.apache.org/jira/browse/FLINK-23166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23166. --- Resolution: Fixed Fixed in - master via c44dd62c3b75a1aba9b909fbeef15256043d5808 - release-1.13 via 

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[GitHub] [flink] dianfu merged pull request #16309: [FLINK-23166][python] Fix ZipUtils to handle properly for softlinks

dianfu merged pull request #16309: URL: https://github.com/apache/flink/pull/16309 -- 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] 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: * 36ac6d55a68b55df0f1f1dbfb8ef669e6f93508d Azure:

[jira] [Updated] (FLINK-11381) JOIN LATERAL with a table was not support

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

[jira] [Updated] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

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

[jira] [Updated] (FLINK-10911) Enable flink-scala-shell with Scala 2.12

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

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

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

[jira] [Updated] (FLINK-9667) Scala docs are only generated for flink-scala

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

[jira] [Updated] (FLINK-9896) Fix flink documentation error

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

[jira] [Updated] (FLINK-3805) BloomFilter initialized with no memory available

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

[jira] [Updated] (FLINK-11746) Add thrift format support in Flink

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

[jira] [Updated] (FLINK-12130) Apply command line options to configuration before installing security modules

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

[jira] [Updated] (FLINK-3431) Add retrying logic for RocksDB snapshots

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

[jira] [Updated] (FLINK-21223) Support to specify the input/output types of Python UDFs via string

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

[jira] [Updated] (FLINK-13698) Rework threading model of CheckpointCoordinator

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

[jira] [Updated] (FLINK-21341) Update state reader to return InputFormat

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

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

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

[jira] [Updated] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

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

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

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

[jira] [Updated] (FLINK-13773) Rework of the Expression Design

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

[jira] [Updated] (FLINK-12355) KafkaITCase.testTimestamps is unstable

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

[jira] [Updated] (FLINK-16306) Validate YARN session state before job submission

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

[jira] [Updated] (FLINK-15184) write guest post "How to connect Flink to Hive metastore on EMR" for AWS

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

[jira] [Updated] (FLINK-15730) Tables with checkpoint statistics do not scroll when window is too narrow

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

[jira] [Updated] (FLINK-14917) Add end to end performance testing framework

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

[jira] [Updated] (FLINK-14819) Replace internal usages of Time with Duration

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

[jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment

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

[jira] [Updated] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

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

[jira] [Updated] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

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

[jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables

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

[jira] [Updated] (FLINK-20219) Rethink the HA related ZNodes/ConfigMap clean up for session cluster

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

[jira] [Updated] (FLINK-17767) Add offset support for TUMBLE, HOP, SESSION group windows

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

[jira] [Updated] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

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

[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking

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

[jira] [Updated] (FLINK-22741) Hide Flink complexity from Stateful Functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #16204: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

flinkbot edited a comment on pull request #16204: URL: https://github.com/apache/flink/pull/16204#issuecomment-864077792 ## CI report: * 65828a4894a660865dcfbcbcd7699d7a13e233fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16203: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

flinkbot edited a comment on pull request #16203: URL: https://github.com/apache/flink/pull/16203#issuecomment-864077645 ## CI report: * c398e084c7ba541cca47f3f86c4a8fb8590675b5 Azure:

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370848#comment-17370848 ] Chesnay Schepler commented on FLINK-23147: -- To clarify, note that this entire discussion about

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

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370827#comment-17370827 ] Chesnay Schepler commented on FLINK-23147: -- > what happens if we really externalize connectors,

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

  1   2   3   4   >