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

2021-06-28 Thread Flink Jira Bot (Jira)
[ 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-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

2021-06-28 Thread Flink Jira Bot (Jira)
[ 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: auto-deprioritized-criti

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

2021-06-28 Thread Flink Jira Bot (Jira)
[ 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 pull-reque

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

2021-06-28 Thread Flink Jira Bot (Jira)
[ 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) P

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

2021-06-28 Thread Flink Jira Bot (Jira)
[ 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: auto-deprioritized-cr

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16312: URL: https://github.com/apache/flink/pull/16312#issuecomment-869768855 ## CI report: * 36ac6d55a68b55df0f1f1dbfb8ef669e6f93508d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread GitBox
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: issues-unsubscr

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

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

[jira] [Closed] (FLINK-23166) ZipUtils doesn't handle properly for softlinks inside the zip file

2021-06-28 Thread Dian Fu (Jira)
[ 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 1ffdc082

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

2021-06-28 Thread GitBox
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.

[GitHub] [flink] leonardBang commented on pull request #16230: [hotfix][docs] Updated description of HOP and CUMULATE parameters

2021-06-28 Thread GitBox
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, pl

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

2021-06-28 Thread GitBox
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: issues-unsub

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

2021-06-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370976#comment-17370976 ] Xintong Song commented on FLINK-20928: -- https://dev.azure.com/apache-flink/apache-f

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

2021-06-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370979#comment-17370979 ] Xintong Song commented on FLINK-22387: -- https://dev.azure.com/apache-flink/apache-f

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

2021-06-28 Thread Xintong Song (Jira)
[ 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

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

2021-06-28 Thread GitBox
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 specif

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

2021-06-28 Thread GitBox
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: issues-unsubs

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

2021-06-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370983#comment-17370983 ] Jingsong Lee commented on FLINK-22781: -- Although it is an Experimental API, we alre

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

2021-06-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370984#comment-17370984 ] Xintong Song commented on FLINK-22085: -- https://dev.azure.com/apache-flink/apache-f

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

2021-06-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370985#comment-17370985 ] Xintong Song commented on FLINK-22085: -- [~gaoyunhaii], New instance found. Please

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

2021-06-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370986#comment-17370986 ] Xintong Song commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

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

2021-06-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370988#comment-17370988 ] luoyuxia commented on FLINK-23171: -- [~JasonLee] Hi, maybe you need to build the whole

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

2021-06-28 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370989#comment-17370989 ] xiaogang zhou commented on FLINK-22059: --- Sorry I forgot it, will submit a PR soon

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

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

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

2021-06-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370999#comment-17370999 ] Jingsong Lee commented on FLINK-22897: -- I think we need let sink chain from sort op

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

2021-06-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371000#comment-17371000 ] Jingsong Lee commented on FLINK-22898: -- Yes. > HiveParallelismInference limit retu

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

2021-06-28 Thread Yun Tang (Jira)
[ 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

2021-06-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371001#comment-17371001 ] Yun Tang commented on FLINK-22059: -- [~zhoujira86] Okay, re-assign this ticket to you.

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

2021-06-28 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371002#comment-17371002 ] JasonLee commented on FLINK-23171: -- hi luoyuxia Thank you for your reply. In fact, I u

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

2021-06-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371010#comment-17371010 ] Yun Tang commented on FLINK-18335: -- I think the failed case on March did not include th

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

2021-06-28 Thread Yun Tang (Jira)
[ 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 > ---

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

2021-06-28 Thread GitBox
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: issues-unsub

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

2021-06-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319853#comment-17319853 ] godfrey he edited comment on FLINK-22157 at 6/29/21, 3:06 AM:

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

2021-06-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319853#comment-17319853 ] godfrey he edited comment on FLINK-22157 at 6/29/21, 3:06 AM:

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

2021-06-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371011#comment-17371011 ] godfrey he commented on FLINK-23135: Fixed in 1.12.5: d1b8c5fd54e1d104387ef6acb94b9a

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

2021-06-28 Thread godfrey he (Jira)
[ 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 > ArrayIndexOutOfB

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

2021-06-28 Thread godfrey he (Jira)
[ 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] [Commented] (FLINK-15031) Automatically calculate required network memory for fine-grained jobs

2021-06-28 Thread Jin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371012#comment-17371012 ] Jin Xing commented on FLINK-15031: -- Some details for network memory allocation algorith

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

2021-06-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371013#comment-17371013 ] Xintong Song commented on FLINK-22457: -- https://dev.azure.com/apache-flink/apache-f

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

2021-06-28 Thread GitBox
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 abo

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

2021-06-28 Thread Zhilong Hong (Jira)
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 Iss

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16283: URL: https://github.com/apache/flink/pull/16283#issuecomment-868177111 ## CI report: * f60176579d7b4518ba7f10124456258a58fec05e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371019#comment-17371019 ] Yangze Guo commented on FLINK-15031: Thanks for the input, [~zhuzh]. +1 for introduc

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

2021-06-28 Thread Xintong Song (Jira)
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 V

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

2021-06-28 Thread GitBox
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` fo

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

2021-06-28 Thread GitBox
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 `KafkaSerializationSch

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

2021-06-28 Thread Bo Cui (Jira)
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

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

2021-06-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371029#comment-17371029 ] godfrey he commented on FLINK-22954: [~wenlong.lwl] I think we should also make sure

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

2021-06-28 Thread GitBox
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 +2

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-859341888 ## CI report: * 42e12926d6185a514cce554e825394aad318a12d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread GitBox
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 ca

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16239: URL: https://github.com/apache/flink/pull/16239#issuecomment-865833767 ## CI report: * c3fda52ffdf8160ce4beca256feb14023c77373c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16283: URL: https://github.com/apache/flink/pull/16283#issuecomment-868177111 ## CI report: * f60176579d7b4518ba7f10124456258a58fec05e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23005) Optimize the deployment of tasks

2021-06-28 Thread ASF GitHub Bot (Jira)
[ 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 commented on pull request #16314: [FLINK-23005][runtime] Optimize the deployment of tasks

2021-06-28 Thread GitBox
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 pro

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-859341888 ## CI report: * 42e12926d6185a514cce554e825394aad318a12d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16239: URL: https://github.com/apache/flink/pull/16239#issuecomment-865833767 ## CI report: * c3fda52ffdf8160ce4beca256feb14023c77373c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread GitBox
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 r

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

2021-06-28 Thread GitBox
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 on

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

2021-06-28 Thread ASF GitHub Bot (Jira)
[ 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] flinkbot commented on pull request #16315: FLINK-23174 Log improvement in Task throws Error

2021-06-28 Thread GitBox
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 pro

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16314: URL: https://github.com/apache/flink/pull/16314#issuecomment-870223774 ## CI report: * 3b6ca11ca5480b5a74751b80bc3fed147bf2b2e9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2021-06-28 Thread GitBox
godfreyhe commented on a change in pull request #16025: URL: https://github.com/apache/flink/pull/16025#discussion_r660269928 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/SimplifyWindowTableFunctionRule.jav

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

2021-06-28 Thread GitBox
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 r

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

2021-06-28 Thread GitBox
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 https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/tabl

[jira] [Updated] (FLINK-16090) Translate "Table API" page of "Table API & SQL" into Chinese

2021-06-28 Thread ASF GitHub Bot (Jira)
[ 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 AP

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

2021-06-28 Thread GitBox
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 pro

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16315: URL: https://github.com/apache/flink/pull/16315#issuecomment-870249808 ## CI report: * eafd3f43b41725f250ba8b6c704581b283bb23cc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread GitBox
flinkbot commented on pull request #16316: URL: https://github.com/apache/flink/pull/16316#issuecomment-870264093 ## CI report: * f5c243f32536d33b8aad5b89381e3305725adb3f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rmetzger commented on a change in pull request #16283: [FLINK-23149][table-code-splitter] Introduce the new Java code splitter module

2021-06-28 Thread GitBox
rmetzger commented on a change in pull request #16283: URL: https://github.com/apache/flink/pull/16283#discussion_r660308177 ## File path: flink-table/flink-table-code-splitter/pom.xml ## @@ -0,0 +1,91 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.

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

2021-06-28 Thread GitBox
AHeise commented on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-870270384 > @AHeise , thanks for detailed rephrase and I hold a different point of view: > > 1. The `defaultTopicId` could be null in the constructor of `KafkaSerializationSchem

[jira] [Created] (FLINK-23175) Write data to hive table in batch mode throws FileNotFoundException.

2021-06-28 Thread chrismartin (Jira)
chrismartin created FLINK-23175: --- Summary: Write data to hive table in batch mode throws FileNotFoundException. Key: FLINK-23175 URL: https://issues.apache.org/jira/browse/FLINK-23175 Project: Flink

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

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16316: URL: https://github.com/apache/flink/pull/16316#issuecomment-870264093 ## CI report: * f5c243f32536d33b8aad5b89381e3305725adb3f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-06-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371153#comment-17371153 ] luoyuxia commented on FLINK-23171: -- [~JasonLee] Hi, the method `createSqlExprToRexConv

[GitHub] [flink] PatrickRen commented on pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

2021-06-28 Thread GitBox
PatrickRen commented on pull request #16115: URL: https://github.com/apache/flink/pull/16115#issuecomment-870277421 Thanks @becketqin for reviewing~ I split the patch into two commits: 2b460b5 for adding test util class `MetricListener` 43036001425b for offset and KafkaConsumer metrics

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

2021-06-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371153#comment-17371153 ] luoyuxia edited comment on FLINK-23171 at 6/29/21, 6:30 AM:

[jira] [Commented] (FLINK-23175) Write data to hive table in batch mode throws FileNotFoundException.

2021-06-28 Thread will (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371154#comment-17371154 ] will commented on FLINK-23175: -- we have the same problem.  > Write data to hive table in b

[GitHub] [flink] beyond1920 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 WindowJo

2021-06-28 Thread GitBox
beyond1920 commented on a change in pull request #16025: URL: https://github.com/apache/flink/pull/16025#discussion_r660318419 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/SimplifyWindowTableFunctionRule.ja

[GitHub] [flink] beyond1920 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 WindowJo

2021-06-28 Thread GitBox
beyond1920 commented on a change in pull request #16025: URL: https://github.com/apache/flink/pull/16025#discussion_r660324627 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/SimplifyWindowTableFunctionRule.ja

[jira] [Commented] (FLINK-23175) Write data to hive table in batch mode throws FileNotFoundException.

2021-06-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371161#comment-17371161 ] 鲁云龙 commented on FLINK-23175: - (*r)顶上去(*r) > Write data to hive table in batch mode throws

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

2021-06-28 Thread JohnSmith (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371164#comment-17371164 ] JohnSmith commented on FLINK-23171: --- [~luoyuxia] hi I got the same error, and fix the

[GitHub] [flink] flinkbot edited a comment on pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

2021-06-28 Thread GitBox
flinkbot edited a comment on pull request #16115: URL: https://github.com/apache/flink/pull/16115#issuecomment-857350673 ## CI report: * 4c653575cd66258b4cdd0e54b8cf7dfeca474f9b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-23176) my flink application has failed when i executed an savepoint

2021-06-28 Thread Carl (Jira)
Carl created FLINK-23176: Summary: my flink application has failed when i executed an savepoint Key: FLINK-23176 URL: https://issues.apache.org/jira/browse/FLINK-23176 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-23176) flink application has failed when i executed an savepoint

2021-06-28 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-23176: - Summary: flink application has failed when i executed an savepoint (was: my flink application has failed when i

[jira] [Updated] (FLINK-23176) flink application has failed when i executed an savepoint

2021-06-28 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-23176: - Attachment: image-2021-06-29-14-54-21-627.png > flink application has failed when i executed an savepoint >

[jira] [Updated] (FLINK-23176) flink application has failed when i executed an savepoint

2021-06-28 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-23176: - Description: *some exceptions it throws as follows*   !image-2021-06-29-14-44-18-005.png! !image-2021-06-29-1

[jira] [Updated] (FLINK-23176) flink application has failed when i executed an savepoint

2021-06-28 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-23176: - Description: *some exceptions it throws as follows*   !image-2021-06-29-14-44-18-005.png! !image-2021-06-29-1

[jira] [Updated] (FLINK-23176) flink application has failed when i executed an savepoint

2021-06-28 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-23176: - Priority: Blocker (was: Major) > flink application has failed when i executed an savepoint > --

[jira] [Created] (FLINK-23177) watermarks generated in dateStream can not flow into table

2021-06-28 Thread Spongebob (Jira)
Spongebob created FLINK-23177: - Summary: watermarks generated in dateStream can not flow into table Key: FLINK-23177 URL: https://issues.apache.org/jira/browse/FLINK-23177 Project: Flink Issue Ty

[jira] [Updated] (FLINK-23177) watermarks generated in dateStream can not flow into table

2021-06-28 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob updated FLINK-23177: -- Description: I have assigned watermark in dataStream and then use the `createTemporaryView` method to

<    1   2   3   4