[jira] [Closed] (FLINK-23148) flink-mesos does not build with scala 2.12

2021-06-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23148. Fix Version/s: (was: 1.14.0) Resolution: Won't Fix > flink-mesos does not build

[jira] [Closed] (FLINK-23118) Drop Mesos support

2021-06-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23118. Resolution: Fixed master: e8b7f3dc73ff8acfc3f4a3a7757798bcc8b80f63 > Drop Mesos support >

[GitHub] [flink] zentol merged pull request #16249: [FLINK-23118] Drop Mesos support

2021-06-24 Thread GitBox
zentol merged pull request #16249: URL: https://github.com/apache/flink/pull/16249 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot commented on pull request #16287: [FLINK-23066] Introduce TableEnvironment#from(TableDescriptor)

2021-06-24 Thread GitBox
flinkbot commented on pull request #16287: URL: https://github.com/apache/flink/pull/16287#issuecomment-868270704 ## CI report: * 850b58ee58b7c1ed9906e2397da59d779a10e83a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

2021-06-24 Thread GitBox
flinkbot commented on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

2021-06-24 Thread GitBox
SteNicholas commented on a change in pull request #16286: URL: https://github.com/apache/flink/pull/16286#discussion_r658517140 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramRetrieverImpl.java ## @@ -0,0 +1,203 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #16285: [FLINK-23070][table-api-java] Introduce TableEnvironment#createTable

2021-06-24 Thread GitBox
flinkbot edited a comment on pull request #16285: URL: https://github.com/apache/flink/pull/16285#issuecomment-868253867 ## CI report: * c3f475e4c4fcd8bbf0a7695c75630e444308eee1 Azure: [PENDING](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-24 Thread GitBox
flinkbot edited a comment on pull request #16283: URL: https://github.com/apache/flink/pull/16283#issuecomment-868177111 ## CI report: * e4990b25ca06e124e3d84da5b2dd77580340975c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16281: [FLINK-23129][docs] Document ApplicationMode limitations

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

[GitHub] [flink] flinkbot edited a comment on pull request #16229: [FLINK-22464][tests] Fix OperatorCoordinator test which is stalling with AdaptiveScheduler

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

[GitHub] [flink] SteNicholas closed pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

2021-06-24 Thread GitBox
SteNicholas closed pull request #15020: URL: https://github.com/apache/flink/pull/15020 -- 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. For queries about this service, pl

[GitHub] [flink] rmetzger commented on pull request #16261: [FLINK-23045][tests] Harden RunnablesTest by not relying on timeout

2021-06-24 Thread GitBox
rmetzger commented on pull request #16261: URL: https://github.com/apache/flink/pull/16261#issuecomment-868266209 nit: The variable name in `testExecutorService_uncaughtExceptionHandler` here seems to be a copy-paste error: `ExecutorService scheduledExecutorService = Executors.newSingleThr

[GitHub] [flink] rmetzger commented on a change in pull request #16261: [FLINK-23045][tests] Harden RunnablesTest by not relying on timeout

2021-06-24 Thread GitBox
rmetzger commented on a change in pull request #16261: URL: https://github.com/apache/flink/pull/16261#discussion_r658512952 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/RunnablesTest.java ## @@ -53,9 +55,9 @@ public void testExecutorService_uncaught

[jira] [Closed] (FLINK-23153) Benchmark not compiling

2021-06-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-23153. Resolution: Fixed Fixed in b21b5ba92a88fef5bb4d96bb7ae78fafd9a0a590 > Benchmark not compi

[GitHub] [flink-benchmarks] dawidwys merged pull request #18: [FLINK-23153] Fix the reference of FutureUtils in RecordSource

2021-06-24 Thread GitBox
dawidwys merged pull request #18: URL: https://github.com/apache/flink-benchmarks/pull/18 -- 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. For queries about this service,

[jira] [Created] (FLINK-23155) Streaming File Sink s3 end-to-end test fail on azure

2021-06-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-23155: Summary: Streaming File Sink s3 end-to-end test fail on azure Key: FLINK-23155 URL: https://issues.apache.org/jira/browse/FLINK-23155 Project: Flink Issue Ty

[GitHub] [flink-benchmarks] dawidwys commented on pull request #18: [FLINK-23153] Fix the reference of FutureUtils in RecordSource

2021-06-24 Thread GitBox
dawidwys commented on pull request #18: URL: https://github.com/apache/flink-benchmarks/pull/18#issuecomment-868263354 LGTM, 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 specific

[GitHub] [flink] dawidwys commented on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

2021-06-24 Thread GitBox
dawidwys commented on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-868262596 Regarding the 3 modifications, I agree with 1. and 3., the second one should be implemented already imo. -- This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] RocMarshal commented on pull request #16070: [FLINK-23028][docs] Improve documentation for pages of SQL.

2021-06-24 Thread GitBox
RocMarshal commented on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-868259581 Hi, @alpinegizmo @wuchong ,Could you help me to confirm and merge the PR ? Thank you so much for your help. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] Myasuka commented on pull request #16177: [FLINK-22528][docs] Document latency tracking metrics for state accesses

2021-06-24 Thread GitBox
Myasuka commented on pull request #16177: URL: https://github.com/apache/flink/pull/16177#issuecomment-868258295 @rkhachatryan , would you please take a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-23153) Benchmark not compiling

2021-06-24 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369262#comment-17369262 ] Zhu Zhu commented on FLINK-23153: - Thanks for reporting this issue [~Thesharing]. I have

[jira] [Assigned] (FLINK-23153) Benchmark not compiling

2021-06-24 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-23153: --- Assignee: Zhilong Hong > Benchmark not compiling > --- > > Key:

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

2021-06-24 Thread GitBox
flinkbot commented on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868257439 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 commented on pull request #16287: [FLINK-23066] Introduce TableEnvironment#from(TableDescriptor)

2021-06-24 Thread GitBox
flinkbot commented on pull request #16287: URL: https://github.com/apache/flink/pull/16287#issuecomment-868257423 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] JingsongLi commented on a change in pull request #16283: [FLINK-23149][table-code-splitter] Introduce the new Java code splitter module

2021-06-24 Thread GitBox
JingsongLi commented on a change in pull request #16283: URL: https://github.com/apache/flink/pull/16283#discussion_r658442269 ## 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://ww

[jira] [Created] (FLINK-23154) Fix Python PackagedProgramRetrieverImplTest implementations

2021-06-24 Thread Matthias (Jira)
Matthias created FLINK-23154: Summary: Fix Python PackagedProgramRetrieverImplTest implementations Key: FLINK-23154 URL: https://issues.apache.org/jira/browse/FLINK-23154 Project: Flink Issue Ty

[jira] [Commented] (FLINK-22818) IgnoreInFlightDataITCase fails on azure

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

[jira] [Updated] (FLINK-23066) Implement TableEnvironment#from

2021-06-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23066: --- Labels: pull-request-available (was: ) > Implement TableEnvironment#from >

[GitHub] [flink] Airblader opened a new pull request #16287: [FLINK-23066] Introduce TableEnvironment#from(TableDescriptor)

2021-06-24 Thread GitBox
Airblader opened a new pull request #16287: URL: https://github.com/apache/flink/pull/16287 ## What is the purpose of the change This introduces `TableEnvironment#from(TableDescriptor)` as part of FLIP-129. Under the hood it is essentially a shortcut of registering a temporary

[GitHub] [flink] gaoyunhaii commented on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

2021-06-24 Thread GitBox
gaoyunhaii commented on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-868255975 Hi @dawidwys very thanks for the effective review! The current modification in the `CheckpointBarrierHandler` is indeed for tracking the pending barriers and received barrier

[GitHub] [flink] XComp opened a new pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

2021-06-24 Thread GitBox
XComp opened a new pull request #16286: URL: https://github.com/apache/flink/pull/16286 ## 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 e

[GitHub] [flink] rmetzger commented on pull request #16281: [FLINK-23129][docs] Document ApplicationMode limitations

2021-06-24 Thread GitBox
rmetzger commented on pull request #16281: URL: https://github.com/apache/flink/pull/16281#issuecomment-868255611 Thanks a lot for your review. I addressed all your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink-benchmarks] Thesharing edited a comment on pull request #18: [FLINK-23153] Fix the reference of FutureUtils in RecordSource

2021-06-24 Thread GitBox
Thesharing edited a comment on pull request #18: URL: https://github.com/apache/flink-benchmarks/pull/18#issuecomment-868255057 I had an offline discussion with @zhuzhurk. We both agree that the reference of FutureUtils here could be removed by replacing `FutureUtils.completedVoidFuture()`

[GitHub] [flink-benchmarks] Thesharing edited a comment on pull request #18: [FLINK-23153] Fix the reference of FutureUtils in RecordSource

2021-06-24 Thread GitBox
Thesharing edited a comment on pull request #18: URL: https://github.com/apache/flink-benchmarks/pull/18#issuecomment-868255057 I had an offline discussion with @zhuzhurk. We both agree that the reference of FutureUtils here could be removed by replace `FutureUtils.completedVoidFuture()` w

[GitHub] [flink-benchmarks] Thesharing commented on pull request #18: [FLINK-23153] Fix the reference of FutureUtils in RecordSource

2021-06-24 Thread GitBox
Thesharing commented on pull request #18: URL: https://github.com/apache/flink-benchmarks/pull/18#issuecomment-868255057 After offline discussion with @zhuzhurk, we both agree that the reference of FutureUtils here could be removed by replace `FutureUtils.completedVoidFuture()` with `Comp

[jira] [Updated] (FLINK-23153) Benchmark not compiling

2021-06-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23153: --- Labels: pull-request-available (was: ) > Benchmark not compiling > ---

[GitHub] [flink] flinkbot commented on pull request #16285: [FLINK-23070][table-api-java] Introduce TableEnvironment#createTable

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

[GitHub] [flink] flinkbot edited a comment on pull request #16258: [FLINK-23120][python] Fix ByteArrayWrapperSerializer.serialize to use writeInt to serialize the length

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

[GitHub] [flink] KarmaGYZ commented on pull request #16173: [FLINK-15031][runtime] Calculate required shuffle memory before allocating slots if resources are specified

2021-06-24 Thread GitBox
KarmaGYZ commented on pull request #16173: URL: https://github.com/apache/flink/pull/16173#issuecomment-868253073 Thanks for the PR, @jinxing64 . Would you like to rebase on the lastest `master` and resolve the conflict? I think @zhuzhurk may help to review it. -- This is an automated me

[GitHub] [flink-benchmarks] Thesharing opened a new pull request #18: [FLINK-23153] Fix the reference of FutureUtils in RecordSource

2021-06-24 Thread GitBox
Thesharing opened a new pull request #18: URL: https://github.com/apache/flink-benchmarks/pull/18 In FLINK-23085, FutureUtils is moved from flink-runtime to flink-core. The reference in flink-benchmark should also be changed. The reference is located at: org/apache/flink/benchmark/operator

[jira] [Updated] (FLINK-23153) Benchmark not compiling

2021-06-24 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23153: - Description: In FLINK-23085, FutureUtils is moved from flink-runtime to flink-core. The referen

[jira] [Created] (FLINK-23153) Benchmark not compiling

2021-06-24 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-23153: Summary: Benchmark not compiling Key: FLINK-23153 URL: https://issues.apache.org/jira/browse/FLINK-23153 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-23152) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-06-24 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369252#comment-17369252 ] Matthias commented on FLINK-23152: -- Hi [~liu zhuang], thanks for sharing the logs (even

[jira] [Updated] (FLINK-23152) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-06-24 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-23152: - Priority: Minor (was: Major) > Flink - {"errors":["Service temporarily unavailable due to an ongoing le

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

2021-06-24 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369251#comment-17369251 ] Arvid Heise commented on FLINK-23147: - Hi Chesnay, I'm lacking a bit of knowledge to

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

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

[GitHub] [flink] flinkbot commented on pull request #16285: [FLINK-23070][table-api-java] Introduce TableEnvironment#createTable

2021-06-24 Thread GitBox
flinkbot commented on pull request #16285: URL: https://github.com/apache/flink/pull/16285#issuecomment-868222480 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

[jira] [Comment Edited] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases

2021-06-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332843#comment-17332843 ] Dian Fu edited comment on FLINK-22470 at 6/25/21, 5:45 AM: --- Me

[jira] [Updated] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases

2021-06-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22470: Fix Version/s: 1.11.4 > The root cause of the exception encountered during compiling the job was not > ex

[GitHub] [flink] AHeise merged pull request #16277: [FLINK-22492][test] Use order-agnostic check in KinesisTableApiITCase.

2021-06-24 Thread GitBox
AHeise merged pull request #16277: URL: https://github.com/apache/flink/pull/16277 -- 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. For queries about this service, please

[GitHub] [flink] AHeise commented on pull request #16277: [FLINK-22492][test] Use order-agnostic check in KinesisTableApiITCase.

2021-06-24 Thread GitBox
AHeise commented on pull request #16277: URL: https://github.com/apache/flink/pull/16277#issuecomment-868220479 Failure unrelated (FLINK-22818) 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

[jira] [Updated] (FLINK-23070) Implement TableEnvironment#createTable

2021-06-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23070: --- Labels: pull-request-available (was: ) > Implement TableEnvironment#createTable > -

[GitHub] [flink] Airblader opened a new pull request #16285: [FLINK-23070][table-api-java] Introduce TableEnvironment#createTable

2021-06-24 Thread GitBox
Airblader opened a new pull request #16285: URL: https://github.com/apache/flink/pull/16285 ## What is the purpose of the change This implements `TableEnvironment#createTable(String, TableDescriptor)` as part of FLIP-129. It behaves the same as the previously introduced `#createTemp

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

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

[jira] [Resolved] (FLINK-22147) Refactor Partition Discovery Logic in KafkaSourceEnumerator

2021-06-24 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-22147. -- Fix Version/s: 1.14.0 Resolution: Implemented Merged to master.  1418a1ddd025adb3b502b8

[jira] [Assigned] (FLINK-22147) Refactor Partition Discovery Logic in KafkaSourceEnumerator

2021-06-24 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-22147: Assignee: Qingsheng Ren > Refactor Partition Discovery Logic in KafkaSourceEnumerator > -

[GitHub] [flink] becketqin commented on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

2021-06-24 Thread GitBox
becketqin commented on pull request #15531: URL: https://github.com/apache/flink/pull/15531#issuecomment-868210308 @PatrickRen Thanks for updating the patch. Merged to master. 1418a1ddd025adb3b502b8d7a89d0f338aa40c29 -- This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] becketqin merged pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

2021-06-24 Thread GitBox
becketqin merged pull request #15531: URL: https://github.com/apache/flink/pull/15531 -- 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. For queries about this service, plea

[GitHub] [flink] EronWright commented on pull request #15950: [FLINK-22700] [api] Propagate watermarks to sink API

2021-06-24 Thread GitBox
EronWright commented on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-868207493 Thanks @AHeise and @tzulitai for the review, I'll push an update tomorrow. -- This is an automated message from the Apache Git Service. To respond to the message, please l

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

2021-06-24 Thread GitBox
Airblader commented on a change in pull request #16283: URL: https://github.com/apache/flink/pull/16283#discussion_r658472428 ## File path: flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/CodeSplitUtil.java ## @@ -0,0 +1,51 @@ +/* + * Licen

[jira] [Assigned] (FLINK-23149) Introduce Java code splitter for code generation

2021-06-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-23149: - Assignee: Caizhi Weng > Introduce Java code splitter for code generation >

[jira] [Updated] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all classes

2021-06-24 Thread LIU Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-22610: - Description: The test-jar of old kafka connector (flink-connector-kafka-base and flink-connector-kafka-

[jira] [Updated] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all classes

2021-06-24 Thread LIU Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-22610: - Summary: The test-jar and test-source-jar of flink-connector-kafka should include all classes (was: The

[jira] [Updated] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all test classes

2021-06-24 Thread LIU Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-22610: - Summary: The test-jar and test-source-jar of flink-connector-kafka should include all test classes (was

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

2021-06-24 Thread GitBox
Airblader commented on pull request #16230: URL: https://github.com/apache/flink/pull/16230#issuecomment-868196261 I'm guessing the PR needs to be rebased so that CI can pass. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Created] (FLINK-23152) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-06-24 Thread liu zhuang (Jira)
liu zhuang created FLINK-23152: -- Summary: Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} Key: FLINK-23152 URL: https://issues.apache.org/jira/browse/FLINK-23

[GitHub] [flink] flinkbot edited a comment on pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

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

[GitHub] [flink] Tartarus0zm edited a comment on pull request #16275: [FLINK-20518][rest] Add decoding characters for MessageQueryParameter

2021-06-24 Thread GitBox
Tartarus0zm edited a comment on pull request #16275: URL: https://github.com/apache/flink/pull/16275#issuecomment-868191218 > > Do you think that special characters should be encoded on the UI side? Instead of decoding it on the server again? > > yes and yes. I did a manual check whe

[GitHub] [flink] Tartarus0zm commented on pull request #16275: [FLINK-20518][rest] Add decoding characters for MessageQueryParameter

2021-06-24 Thread GitBox
Tartarus0zm commented on pull request #16275: URL: https://github.com/apache/flink/pull/16275#issuecomment-868191218 > > Do you think that special characters should be encoded on the UI side? Instead of decoding it on the server again? > > yes and yes. I did a manual check when revie

[GitHub] [flink] wuchong commented on a change in pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-24 Thread GitBox
wuchong commented on a change in pull request #16245: URL: https://github.com/apache/flink/pull/16245#discussion_r658452346 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/SqlClientOptions.java ## @@ -53,4 +55,16 @@ private SqlClie

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

2021-06-24 Thread GitBox
beyond1920 commented on pull request #16219: URL: https://github.com/apache/flink/pull/16219#issuecomment-868185126 @cshuo Would you please have a look at the pull request, thanks a lot. cc @godfreyhe -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] lirui-apache closed pull request #16182: [FLINK-23010][hive] HivePartitionFetcherContextBase shouldn't list fo…

2021-06-24 Thread GitBox
lirui-apache closed pull request #16182: URL: https://github.com/apache/flink/pull/16182 -- 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. For queries about this service, p

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16284: [FLINK-23142][table] UpdatableTopNFunction output wrong order in the same unique key

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

[GitHub] [flink] flinkbot edited a comment on pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

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

[jira] [Commented] (FLINK-19754) Cannot have more than one execute() or executeAsync() call in a single environment.

2021-06-24 Thread roberto hashioka (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369225#comment-17369225 ] roberto hashioka commented on FLINK-19754: -- I'm also experiencing this issue. I

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

2021-06-24 Thread GitBox
beyond1920 edited a comment on pull request #16215: URL: https://github.com/apache/flink/pull/16215#issuecomment-868182128 @wenlong88 Window offset has no effect on watermark. Whether it would effect time attribute depends on each window operator. For window aggregate, time attribute is (w

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

2021-06-24 Thread GitBox
beyond1920 commented on pull request #16215: URL: https://github.com/apache/flink/pull/16215#issuecomment-868182128 @wenlong88 Window offset has no effect on watermark. Whether it would effect time attribute depends on each window operator. For window aggregate, time attribute is (window_e

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369223#comment-17369223 ] Xintong Song commented on FLINK-23009: -- [~iemre] [~dannycranmer] The test failure i

[GitHub] [flink] KarmaGYZ closed pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-24 Thread GitBox
KarmaGYZ closed pull request #16179: URL: https://github.com/apache/flink/pull/16179 -- 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. For queries about this service, pleas

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369219#comment-17369219 ] Xintong Song commented on FLINK-23009: -- reverted release 1.13: 7d71b0b0d771e456460b

[jira] [Closed] (FLINK-23151) KinesisTableApiITCase.testTableApiSourceAndSink fails on azure

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23151. Resolution: Fixed > KinesisTableApiITCase.testTableApiSourceAndSink fails on azure > -

[jira] [Commented] (FLINK-23151) KinesisTableApiITCase.testTableApiSourceAndSink fails on azure

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369218#comment-17369218 ] Xintong Song commented on FLINK-23151: -- The test case starts to constantly fail on

[GitHub] [flink] flinkbot commented on pull request #16284: [FLINK-23142][table] UpdatableTopNFunction output wrong order in the same unique key

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

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

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

[jira] [Commented] (FLINK-23151) KinesisTableApiITCase.testTableApiSourceAndSink fails on azure

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

[jira] [Created] (FLINK-23151) KinesisTableApiITCase.testTableApiSourceAndSink fails on azure

2021-06-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-23151: Summary: KinesisTableApiITCase.testTableApiSourceAndSink fails on azure Key: FLINK-23151 URL: https://issues.apache.org/jira/browse/FLINK-23151 Project: Flink

[jira] [Comment Edited] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

2021-06-24 Thread guxiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368981#comment-17368981 ] guxiang edited comment on FLINK-18464 at 6/25/21, 3:21 AM: --- Hi

[jira] [Updated] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Labels: auto-deprioritized-major test-stability (was: test-stability) > KinesisTableApiITCase.t

[jira] [Updated] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Priority: Minor (was: Major) > KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on A

[jira] [Issue Comment Deleted] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Comment: was deleted (was: https://dev.azure.com/apache-flink/apache-flink/_build/results?build

[jira] [Issue Comment Deleted] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Comment: was deleted (was: https://dev.azure.com/apache-flink/apache-flink/_build/results?build

[jira] [Issue Comment Deleted] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Comment: was deleted (was: https://dev.azure.com/apache-flink/apache-flink/_build/results?build

[jira] [Commented] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

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

[jira] [Commented] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

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

[jira] [Updated] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Labels: test-stability (was: auto-deprioritized-major test-stability) > KinesisTableApiITCase.t

[jira] [Updated] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

2021-06-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22110: - Priority: Major (was: Minor) > KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on A

[jira] [Commented] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

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

[GitHub] [flink] flinkbot edited a comment on pull request #16258: [FLINK-23120][python] Fix ByteArrayWrapperSerializer.serialize to use writeInt to serialize the length

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

2021-06-24 Thread GitBox
gaoyunhaii commented on a change in pull request #15055: URL: https://github.com/apache/flink/pull/15055#discussion_r658442395 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/TestInputChannel.java ## @@ -190,6 +190,9 @@ public v

  1   2   3   4   5   6   >