[jira] [Updated] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Description: Hi, I meet an unexpected problem that the taskmanager can't apply resources when use c

[jira] [Created] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
xiaozilong created FLINK-20451: -- Summary: Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:` Key: FLINK-20451 URL: https://issues.apache.org/jira/browse/FLINK-20451

[GitHub] [flink] gyfora opened a new pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora opened a new pull request #14289: URL: https://github.com/apache/flink/pull/14289 Backport of the fix merged to master This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot commented on pull request #14288: [backport] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot commented on pull request #14288: URL: https://github.com/apache/flink/pull/14288#issuecomment-737196282 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] gyfora opened a new pull request #14288: [backport] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora opened a new pull request #14288: URL: https://github.com/apache/flink/pull/14288 Backport of the fix merged to master This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-12-02 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242301#comment-17242301 ] Gyula Fora commented on FLINK-20221: master: 02f16958346483d91cd59cb902e0cce63fa5875

[GitHub] [flink] asfgit closed pull request #14174: [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
asfgit closed pull request #14174: URL: https://github.com/apache/flink/pull/14174 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 t

[GitHub] [flink] twalthr commented on a change in pull request #14174: [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
twalthr commented on a change in pull request #14174: URL: https://github.com/apache/flink/pull/14174#discussion_r534117838 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java ## @@ -300,14 +300,14 @@ protected void setFieldsGeneric

[GitHub] [flink] flinkbot commented on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
flinkbot commented on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737189475 ## CI report: * 7f5b5358aa8ee98d70ae3dfe2a14442fe8ec2ad3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
flinkbot commented on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737183789 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] [Updated] (FLINK-20352) Rework command line interface documentation page

2020-12-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20352: --- Labels: pull-request-available (was: ) > Rework command line interface documentation page >

[GitHub] [flink] XComp opened a new pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
XComp opened a new pull request #14287: URL: https://github.com/apache/flink/pull/14287 ## What is the purpose of the change The CLI documentation was updated in the context of the efforts around FLINK-20341. This

[GitHub] [flink-statefun] klion26 commented on a change in pull request #176: [FLINK-18968] Translate README.md to Chinese

2020-12-02 Thread GitBox
klion26 commented on a change in pull request #176: URL: https://github.com/apache/flink-statefun/pull/176#discussion_r534106515 ## File path: README.zh.md ## @@ -0,0 +1,214 @@ + + +Stateful Functions（简称 StateFun）是一个 [Apache Flink](https://flink.apache.org/) 库， __可简化构建分布式有状态应用

[GitHub] [flink] gyfora commented on a change in pull request #14174: [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora commented on a change in pull request #14174: URL: https://github.com/apache/flink/pull/14174#discussion_r534106479 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java ## @@ -300,14 +300,14 @@ protected void setFieldsGeneric(

[GitHub] [flink] gyfora commented on a change in pull request #14174: [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora commented on a change in pull request #14174: URL: https://github.com/apache/flink/pull/14174#discussion_r534105103 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java ## @@ -300,14 +300,14 @@ protected void setFieldsGeneric(

[GitHub] [flink] flinkbot edited a comment on pull request #14177: [FLINK-16443][checkpointing] Make sure that CheckpointException are also serialized in DeclineCheckpoint.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14177: URL: https://github.com/apache/flink/pull/14177#issuecomment-732207895 ## CI report: * e7fcff5c36ef33398a10e786fdae848ed72664b4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] klion26 commented on pull request #176: [FLINK-18968] Translate README.md to Chinese

2020-12-02 Thread GitBox
klion26 commented on pull request #176: URL: https://github.com/apache/flink-statefun/pull/176#issuecomment-737177437 @carp84 thanks for the remainder, will have a look now. This is an automated message from the Apache Git Se

[GitHub] [flink] flinkbot edited a comment on pull request #14286: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14286: URL: https://github.com/apache/flink/pull/14286#issuecomment-737159858 ## CI report: * 94d3621221214543eea1126571a2c6de6b657962 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-20385) Allow to read metadata for Canal-json format

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20385: --- Assignee: Nicholas Jiang > Allow to read metadata for Canal-json format > -

[GitHub] [flink] flinkbot commented on pull request #14286: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-12-02 Thread GitBox
flinkbot commented on pull request #14286: URL: https://github.com/apache/flink/pull/14286#issuecomment-737159858 ## CI report: * 94d3621221214543eea1126571a2c6de6b657962 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Assigned] (FLINK-20353) Rework logging documentation page

2020-12-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-20353: Assignee: Chesnay Schepler > Rework logging documentation page >

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-12-02 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242238#comment-17242238 ] Etienne Chauchot commented on FLINK-18685: -- Thanks [~rmetzger] for the assignme

[GitHub] [flink] flinkbot edited a comment on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-728662796 ## CI report: * 5d5887a25ba32defda46147992330711f41c878d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * fe1562c5cda8ecb15f6af1afdf7b6217e6c20c42 UNKNOWN * e7941f905ec697ad09a3f1010f90a2a69a51

[GitHub] [flink] flinkbot commented on pull request #14286: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-12-02 Thread GitBox
flinkbot commented on pull request #14286: URL: https://github.com/apache/flink/pull/14286#issuecomment-737146394 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] gaoyunhaii opened a new pull request #14286: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-12-02 Thread GitBox
gaoyunhaii opened a new pull request #14286: URL: https://github.com/apache/flink/pull/14286 **This PR picks the https://github.com/apache/flink/pull/14094 onto release-1.11** ## What is the purpose of the change This PR tries to fix the package access problem when creating hi

[jira] [Commented] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242230#comment-17242230 ] Till Rohrmann commented on FLINK-20441: --- Thanks for merging this PR [~rmetzger].

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

2020-12-02 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242228#comment-17242228 ] Nicholas Jiang commented on FLINK-20385: [~Leonard Xu], I could work for this is

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

2020-12-02 Thread lingyajia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242226#comment-17242226 ] lingyajia commented on FLINK-12130: --- ok, i will build FLINK-12130-DEV branch ,try i

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * fe1562c5cda8ecb15f6af1afdf7b6217e6c20c42 UNKNOWN * e7941f905ec697ad09a3f1010f90a2a69a51

[GitHub] [flink] twalthr commented on a change in pull request #14174: [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
twalthr commented on a change in pull request #14174: URL: https://github.com/apache/flink/pull/14174#discussion_r534049299 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java ## @@ -300,14 +300,14 @@ protected void setFieldsGeneric

[GitHub] [flink] AHeise commented on a change in pull request #13885: [FLINK-19911] add read buffer for input stream

2020-12-02 Thread GitBox
AHeise commented on a change in pull request #13885: URL: https://github.com/apache/flink/pull/13885#discussion_r534009700 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/FSDataBufferedInputStream.java ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink] flinkbot edited a comment on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-728662796 ## CI report: * f14b52c30b09d46b9fa03f840d0642f764122e8f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

2020-12-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242203#comment-17242203 ] Dawid Wysakowicz edited comment on FLINK-20297 at 12/2/20, 9:36 AM: --

[jira] [Commented] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

2020-12-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242203#comment-17242203 ] Dawid Wysakowicz commented on FLINK-20297: -- Can you elaborate why it is not pos

[jira] [Closed] (FLINK-20450) Missing usage information on "run-application" in Flink CLI

2020-12-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20450. Fix Version/s: (was: 1.13.0) Resolution: Duplicate > Missing usage information

[GitHub] [flink] flinkbot edited a comment on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-728662796 ## CI report: * f14b52c30b09d46b9fa03f840d0642f764122e8f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20450) Missing usage information on "run-application" in Flink CLI

2020-12-02 Thread Matthias (Jira)
Matthias created FLINK-20450: Summary: Missing usage information on "run-application" in Flink CLI Key: FLINK-20450 URL: https://issues.apache.org/jira/browse/FLINK-20450 Project: Flink Issue Ty

[GitHub] [flink] HuangXingBo commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
HuangXingBo commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r534002962 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the Licen

[GitHub] [flink] HuangXingBo commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
HuangXingBo commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r534000335 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the Licen

[jira] [Closed] (FLINK-20315) Optimize the compaction section for the document of table filesystem sink.

2020-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20315. Resolution: Fixed master (1.13): 14b72d5d9284dffeb79d91b9ad948cf5f51af7c6 release-1.12: cbb71c583

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533988778 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the Licen

[GitHub] [flink] JingsongLi merged pull request #14285: [FLINK-20315][doc] Optimize the compaction document to warn users about backpressure

2020-12-02 Thread GitBox
JingsongLi merged pull request #14285: URL: https://github.com/apache/flink/pull/14285 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot commented on pull request #14285: [FLINK-20315][doc] Optimize the compaction document to warn users about backpressure

2020-12-02 Thread GitBox
flinkbot commented on pull request #14285: URL: https://github.com/apache/flink/pull/14285#issuecomment-737082318 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] [Updated] (FLINK-20315) Optimize the compaction section for the document of table filesystem sink.

2020-12-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20315: --- Labels: pull-request-available (was: ) > Optimize the compaction section for the document o

[GitHub] [flink] JingsongLi opened a new pull request #14285: [FLINK-20315][doc] Optimize the compaction document to warn users about backpressure

2020-12-02 Thread GitBox
JingsongLi opened a new pull request #14285: URL: https://github.com/apache/flink/pull/14285 Since if the files are big and the compaction use too much time, it will backpressure the job and also extend the time period of checkpoint, we might explicitly warns users about the possibility of

[GitHub] [flink] caozhen1937 commented on a change in pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-02 Thread GitBox
caozhen1937 commented on a change in pull request #14088: URL: https://github.com/apache/flink/pull/14088#discussion_r533984155 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -24,229 +24,109 @@ specific language governing permissions and limitations under the Licen

[jira] [Updated] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

2020-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20054: - Fix Version/s: 1.13.0 > 3 Level List is not supported in ParquetInputFormat > --

[jira] [Closed] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

2020-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20054. Resolution: Fixed master (1.13): c77e6f9e987f344f1bad2deac4793d78d472ac30 > 3 Level List is not s

[GitHub] [flink] JingsongLi closed pull request #13994: [FLINK-20054][formats] Fix ParquetInputFormat 3 level List handling

2020-12-02 Thread GitBox
JingsongLi closed pull request #13994: URL: https://github.com/apache/flink/pull/13994 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

[jira] [Assigned] (FLINK-19066) InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to

2020-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19066: Assignee: (was: Jingsong Lee) > InnerJoinITCase.testBigForSpill failed with "java.lan

[jira] [Closed] (FLINK-20213) Partition commit is delayed when records keep coming

2020-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20213. Resolution: Fixed > Partition commit is delayed when records keep coming > ---

[jira] [Updated] (FLINK-20213) Partition commit is delayed when records keep coming

2020-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20213: - Fix Version/s: (was: 1.11.3) > Partition commit is delayed when records keep coming > --

[GitHub] [flink] JingsongLi commented on a change in pull request #13994: [FLINK-20054][formats] Fix ParquetInputFormat 3 level List handling

2020-12-02 Thread GitBox
JingsongLi commented on a change in pull request #13994: URL: https://github.com/apache/flink/pull/13994#discussion_r533976670 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java ## @@ -374,17 +375,33 @@ pr

[GitHub] [flink] JingsongLi commented on a change in pull request #13994: [FLINK-20054][formats] Fix ParquetInputFormat 3 level List handling

2020-12-02 Thread GitBox
JingsongLi commented on a change in pull request #13994: URL: https://github.com/apache/flink/pull/13994#discussion_r532314905 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java ## @@ -374,17 +375,33 @@ pr

<    1   2   3