[jira] [Commented] (FLINK-17878) Transient watermark attribute should be initial at runtime in streaming file operators

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114499#comment-17114499 ] xiaogang zhou commented on FLINK-17878: --- [~lzljs3620320] Hi Jingsong, thx for the advice, I have

[jira] [Created] (FLINK-17894) RowGenerator in datagen connector should be serializable

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17894: Summary: RowGenerator in datagen connector should be serializable Key: FLINK-17894 URL: https://issues.apache.org/jira/browse/FLINK-17894 Project: Flink

[jira] [Updated] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17889: - Priority: Blocker (was: Major) > flink-connector-hive jar contains wrong class in its SPI

[jira] [Updated] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17889: - Fix Version/s: 1.11.0 > flink-connector-hive jar contains wrong class in its SPI config file >

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * a1304a3c20a9ba848ddc3308d6da9ecab8a85a5b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12299: URL: https://github.com/apache/flink/pull/12299#issuecomment-632977800 ## CI report: * 6c0db10514575ddaeb66689ff7b3e2ee2975bdfe Azure:

[jira] [Commented] (FLINK-17893) SQL-CLI no exception stack

2020-05-22 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114515#comment-17114515 ] godfrey he commented on FLINK-17893: sql client should support {{-verbose}} option > SQL-CLI no

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

2020-05-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114549#comment-17114549 ] Nicholas Jiang commented on FLINK-17883: [~dian.fu][~lzljs3620320][~jark]As you discuss, do you

[GitHub] [flink] zhougit86 closed pull request #12298: Feature/watermark

2020-05-22 Thread GitBox
zhougit86 closed pull request #12298: URL: https://github.com/apache/flink/pull/12298 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 #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
flinkbot commented on pull request #12299: URL: https://github.com/apache/flink/pull/12299#issuecomment-632975818 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Created] (FLINK-17895) Default value of rows-per-second in datagen should be limited

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17895: Summary: Default value of rows-per-second in datagen should be limited Key: FLINK-17895 URL: https://issues.apache.org/jira/browse/FLINK-17895 Project: Flink

[GitHub] [flink] Myasuka commented on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-22 Thread GitBox
Myasuka commented on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632978514 My azure CI pipeline has run successfully twice: [my-build-1](https://myasuka.visualstudio.com/flink/_build/results?buildId=77) and

[jira] [Created] (FLINK-17893) SQL-CLI no exception stack

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17893: Summary: SQL-CLI no exception stack Key: FLINK-17893 URL: https://issues.apache.org/jira/browse/FLINK-17893 Project: Flink Issue Type: Bug

[GitHub] [flink] klion26 commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-05-22 Thread GitBox
klion26 commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r429510266 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -26,66 +26,65 @@ under the License. * This will be replaced by the TOC {:toc}

[jira] [Created] (FLINK-17896) HiveCatalog can work with new table factory because of is_generic

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17896: Summary: HiveCatalog can work with new table factory because of is_generic Key: FLINK-17896 URL: https://issues.apache.org/jira/browse/FLINK-17896 Project: Flink

[jira] [Comment Edited] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114547#comment-17114547 ] hailong wang edited comment on FLINK-17892 at 5/23/20, 5:34 AM: Hi

[GitHub] [flink] flinkbot edited a comment on pull request #12293: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12293: URL: https://github.com/apache/flink/pull/12293#issuecomment-632624268 ## CI report: * 10d13796e80f7c566995155edabb38996bda Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * 52b0395a9fc4d3fa99def97fe79b42edef32bcf6 Azure:

[GitHub] [flink] zhougit86 opened a new pull request #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
zhougit86 opened a new pull request #12299: URL: https://github.com/apache/flink/pull/12299 ## Verifying this change This change is a trivial rework ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-22 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114503#comment-17114503 ] Yun Tang commented on FLINK-16572: -- Another instance:

[jira] [Commented] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114547#comment-17114547 ] hailong wang commented on FLINK-17892: -- Hi [~lzljs3620320], No, kafka source will not be reused.

[jira] [Commented] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

2020-05-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113790#comment-17113790 ] Robert Metzger commented on FLINK-17194: Another case in the Hadoop 3.1.3 profile:

[GitHub] [flink-web] chaojianok commented on pull request #247: [FLINK-13683] Translate "Code Style - Component Guide" page into Chinese

2020-05-22 Thread GitBox
chaojianok commented on pull request #247: URL: https://github.com/apache/flink-web/pull/247#issuecomment-632518734 @klion26 Thanks a lot for your review, I've optimized it according to your comments, please help me review again.

[jira] [Created] (FLINK-17876) Add documents for the Python UDF SQL DDL.

2020-05-22 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17876: - Summary: Add documents for the Python UDF SQL DDL. Key: FLINK-17876 URL: https://issues.apache.org/jira/browse/FLINK-17876 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Summary: Add documents for Python UDF SQL DDL (was: Add documents for Python UDF SQL DDL.) > Add

[GitHub] [flink] flinkbot commented on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

2020-05-22 Thread GitBox
flinkbot commented on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632559443 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Created] (FLINK-17881) Add documentation for PyFlink's Windows support

2020-05-22 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17881: - Summary: Add documentation for PyFlink's Windows support Key: FLINK-17881 URL: https://issues.apache.org/jira/browse/FLINK-17881 Project: Flink Issue Type:

[jira] [Updated] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

2020-05-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17657: --- Labels: pull-request-available (was: ) > jdbc not support read BIGINT UNSIGNED field >

[jira] [Closed] (FLINK-16605) Add max limitation to the total number of slots

2020-05-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-16605. -- Release Note: With FLINK-16605, user could define the maximum number of slots through

[GitHub] [flink] flinkbot commented on pull request #12291: [FLINK-17881][python][docs] Add documentation for PyFlink's Windows support.

2020-05-22 Thread GitBox
flinkbot commented on pull request #12291: URL: https://github.com/apache/flink/pull/12291#issuecomment-632568815 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Comment Edited] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

2020-05-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113842#comment-17113842 ] Yuan Mei edited comment on FLINK-17873 at 5/22/20, 8:34 AM: Looks like the

[jira] [Commented] (FLINK-17879) Update Python row serializer

2020-05-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113859#comment-17113859 ] Nicholas Jiang commented on FLINK-17879: [~twalthr], [~hequn8128] could decide this point, who

[jira] [Comment Edited] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

2020-05-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113880#comment-17113880 ] Nicholas Jiang edited comment on FLINK-17883 at 5/22/20, 9:22 AM: --

[jira] [Commented] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113883#comment-17113883 ] xiaogang zhou commented on FLINK-17878: --- [~gaoyunhaii] corrected, may i submit a PR for this? >

[jira] [Updated] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-17878: -- Component/s: (was: API / DataStream) Table SQL / API >

[jira] [Commented] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

2020-05-22 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113890#comment-17113890 ] Roman Khachatryan commented on FLINK-16057: --- Got unexpected results on actual files: newer

[jira] [Comment Edited] (FLINK-17805) InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly

2020-05-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113472#comment-17113472 ] Piotr Nowojski edited comment on FLINK-17805 at 5/22/20, 6:16 AM: --

[jira] [Updated] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

2020-05-22 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17869: - Description: On ChannelStateWriter side, the lifecycle of checkpoint should be as follows: start -> in

[GitHub] [flink] flinkbot edited a comment on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632492310 ## CI report: * cda1c81b986bf87f0fd95abfdc60638813a43c0b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/167718532) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 81a8f34c3108c7efc0ed350a50b59c2829a99eff Azure:

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17876: -- Summary: Add documents for Python UDF SQL DDL. (was: Add documents for the Python UDF SQL DDL.) >

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 81a8f34c3108c7efc0ed350a50b59c2829a99eff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12288: URL: https://github.com/apache/flink/pull/12288#issuecomment-632456377 ## CI report: * 08bc3bf4a17f2e6a99ce5ff3af91ae1341254391 Azure:

[jira] [Commented] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113823#comment-17113823 ] xiaogang zhou commented on FLINK-17878: --- [~lzljs3620320] please help review this comment >

[GitHub] [flink] flinkbot edited a comment on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12035: URL: https://github.com/apache/flink/pull/12035#issuecomment-625870674 ## CI report: * d07a0d67629303d83b2998ff1b43aa698c59c116 Azure:

[GitHub] [flink] wxplovecc commented on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-05-22 Thread GitBox
wxplovecc commented on pull request #12035: URL: https://github.com/apache/flink/pull/12035#issuecomment-632550443 @StephanEwen added some viewfilesystem test by HDFS minicluster, after test I found last commit was not work because of #11815 has mentioned and the `truncate` method also

[jira] [Commented] (FLINK-16605) Add max limitation to the total number of slots

2020-05-22 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113840#comment-17113840 ] Gary Yao commented on FLINK-16605: -- [~karmagyz] Only in exceptional cases we add release notes for new

[jira] [Reopened] (FLINK-16605) Add max limitation to the total number of slots

2020-05-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reopened FLINK-16605: > Add max limitation to the total number of slots > --- >

[GitHub] [flink] flinkbot commented on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

2020-05-22 Thread GitBox
flinkbot commented on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330 ## CI report: * ae9e1b8939fd8a1c5727dbdb2b7711545e1a97c3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17879) Update Python row serializer

2020-05-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113847#comment-17113847 ] Nicholas Jiang commented on FLINK-17879: [~twalthr]In my opinion, I prefer use the new format

[jira] [Comment Edited] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-05-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113083#comment-17113083 ] Arvid Heise edited comment on FLINK-17322 at 5/22/20, 8:45 AM: --- _Removed

[GitHub] [flink] rmetzger closed pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-22 Thread GitBox
rmetzger closed pull request #12230: URL: https://github.com/apache/flink/pull/12230 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] rmetzger commented on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-22 Thread GitBox
rmetzger commented on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-632506180 @yangyichao-mango Thanks a lot for your contribution, and thank you for your review @klion26. Merging now ...

[GitHub] [flink] azagrebin commented on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-22 Thread GitBox
azagrebin commented on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-632510359 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

2020-05-22 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113825#comment-17113825 ] Yu Li commented on FLINK-17089: --- bq. The state size is actually small. The largest one is ~3KB. That is

[GitHub] [flink] klion26 edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-22 Thread GitBox
klion26 edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632548526 @SteNicholas thanks for your update, the latest change LGTM. This is an automated message from the

[GitHub] [flink] klion26 commented on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-22 Thread GitBox
klion26 commented on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632548526 The latest change LGTM. This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-17860) Recursively remove channel state directories

2020-05-22 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-17860: -- Description: With a high degree of parallelism, we end up with n*s number of files in

[GitHub] [flink] flinkbot edited a comment on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631541996 ## CI report: * f415b350558bea9b17e12638e70efc701f06c14d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12035: URL: https://github.com/apache/flink/pull/12035#issuecomment-625870674 ## CI report: * ee47a56f30023b1eb3d087b44fb2eed58ec7075b Azure:

[jira] [Commented] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113841#comment-17113841 ] xiaogang zhou commented on FLINK-17878: --- [~gaoyunhaii], No , if we use process time, the watermark

[jira] [Commented] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113857#comment-17113857 ] xiaogang zhou commented on FLINK-17878: --- [~gaoyunhaii] for my understanding, the operator is

[GitHub] [flink] flinkbot commented on pull request #12292: [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

2020-05-22 Thread GitBox
flinkbot commented on pull request #12292: URL: https://github.com/apache/flink/pull/12292#issuecomment-632585735 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

2020-05-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113880#comment-17113880 ] Nicholas Jiang commented on FLINK-17883: [~rmetzger], I don't agree with you any more. I

[jira] [Resolved] (FLINK-17504) Update translation of Getting Started / Overview

2020-05-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-17504. Fix Version/s: 1.12.0 Resolution: Fixed Resolved in

[jira] [Created] (FLINK-17877) Add support for Python 3.8

2020-05-22 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17877: -- Summary: Add support for Python 3.8 Key: FLINK-17877 URL: https://issues.apache.org/jira/browse/FLINK-17877 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-05-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17726: --- Assignee: Nicholas Jiang > Scheduler should take care of tasks directly canceled by TaskManager >

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-05-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113820#comment-17113820 ] Zhu Zhu commented on FLINK-17726: - I have assigned the ticket to you. [~nicholasjiang] But before

[jira] [Commented] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113839#comment-17113839 ] Yun Gao commented on FLINK-17878: - [~zhoujira86] Do you mean StreamingFileWriter#currentWatermark should

[jira] [Comment Edited] (FLINK-16605) Add max limitation to the total number of slots

2020-05-22 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113840#comment-17113840 ] Gary Yao edited comment on FLINK-16605 at 5/22/20, 8:16 AM: [~karmagyz] Only

[jira] [Commented] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

2020-05-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113842#comment-17113842 ] Yuan Mei commented on FLINK-17873: -- Looks like the issue has already been resolved by accident in

[jira] [Updated] (FLINK-17881) Add documentation for PyFlink's Windows support

2020-05-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17881: --- Labels: pull-request-available (was: ) > Add documentation for PyFlink's Windows support >

[GitHub] [flink] WeiZhong94 opened a new pull request #12291: [FLINK-17881][python][docs] Add documentation for PyFlink's Windows support.

2020-05-22 Thread GitBox
WeiZhong94 opened a new pull request #12291: URL: https://github.com/apache/flink/pull/12291 ## What is the purpose of the change *This pull request adds documentation for PyFlink's Windows support.* ## Brief change log - *Add documentation for PyFlink's Windows

[jira] [Comment Edited] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

2020-05-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113842#comment-17113842 ] Yuan Mei edited comment on FLINK-17873 at 5/22/20, 8:36 AM: Looks like the

[jira] [Comment Edited] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

2020-05-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113842#comment-17113842 ] Yuan Mei edited comment on FLINK-17873 at 5/22/20, 8:36 AM: Looks like the

[jira] [Created] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

2020-05-22 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17883: -- Summary: Unable to configure write mode for FileSystem() connector in PyFlink Key: FLINK-17883 URL: https://issues.apache.org/jira/browse/FLINK-17883 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #12291: [FLINK-17881][python][docs] Add documentation for PyFlink's Windows support.

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12291: URL: https://github.com/apache/flink/pull/12291#issuecomment-632581551 ## CI report: * d140807a45bd0dc4d436b3e628d42da7f45b02f2 Azure:

[jira] [Created] (FLINK-17884) package the codegen directory to flink-sql-parser jar

2020-05-22 Thread zhanghang-dev (Jira)
zhanghang-dev created FLINK-17884: - Summary: package the codegen directory to flink-sql-parser jar Key: FLINK-17884 URL: https://issues.apache.org/jira/browse/FLINK-17884 Project: Flink

[jira] [Commented] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113788#comment-17113788 ] Robert Metzger commented on FLINK-17822: I don't think it is a good idea to introduce

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Component/s: Documentation > Add documents for Python UDF SQL DDL. >

[jira] [Assigned] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17876: --- Assignee: Wei Zhong > Add documents for Python UDF SQL DDL. >

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Issue Type: Task (was: Improvement) > Add documents for Python UDF SQL DDL. >

[jira] [Updated] (FLINK-17876) Add documentation on how to use Python UDF in SQL DDL

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Summary: Add documentation on how to use Python UDF in SQL DDL (was: Add documents for Python UDF SQL

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Fix Version/s: 1.11.0 > Add documents for Python UDF SQL DDL. > - > >

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Priority: Major (was: Minor) > Add documents for Python UDF SQL DDL. >

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Affects Version/s: 1.11.0 > Add documents for Python UDF SQL DDL. > -

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Issue Type: Improvement (was: Task) > Add documents for Python UDF SQL DDL. >

[jira] [Created] (FLINK-17879) Update Python row serializer

2020-05-22 Thread Timo Walther (Jira)
Timo Walther created FLINK-17879: Summary: Update Python row serializer Key: FLINK-17879 URL: https://issues.apache.org/jira/browse/FLINK-17879 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

2020-05-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17657: --- Component/s: (was: Table SQL / Client) > jdbc not support read BIGINT UNSIGNED field >

[jira] [Created] (FLINK-17880) Use new type inference for SQL table and scalar functions

2020-05-22 Thread Timo Walther (Jira)
Timo Walther created FLINK-17880: Summary: Use new type inference for SQL table and scalar functions Key: FLINK-17880 URL: https://issues.apache.org/jira/browse/FLINK-17880 Project: Flink

[jira] [Created] (FLINK-17882) Don't allow self referencing structured type

2020-05-22 Thread Timo Walther (Jira)
Timo Walther created FLINK-17882: Summary: Don't allow self referencing structured type Key: FLINK-17882 URL: https://issues.apache.org/jira/browse/FLINK-17882 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330 ## CI report: * ae9e1b8939fd8a1c5727dbdb2b7711545e1a97c3 Azure:

[GitHub] [flink] flinkbot commented on pull request #12291: [FLINK-17881][python][docs] Add documentation for PyFlink's Windows support.

2020-05-22 Thread GitBox
flinkbot commented on pull request #12291: URL: https://github.com/apache/flink/pull/12291#issuecomment-632581551 ## CI report: * d140807a45bd0dc4d436b3e628d42da7f45b02f2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113885#comment-17113885 ] Yun Gao commented on FLINK-17878: - [~zhoujira86] I think it is ok from my side, but I think it might be

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-05-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113809#comment-17113809 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]Could you please assign this to me? I would

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * 1142276931ccfd3ab42da2f44369e649c911aafc Azure:

[jira] [Created] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

2020-05-22 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-17878: - Summary: StreamingFileWriter watermark attribute is transient, this might be different with origin value Key: FLINK-17878 URL: https://issues.apache.org/jira/browse/FLINK-17878

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 55c8d2883eca542317e3cbfd3786d4c226f43305 Azure:

[GitHub] [flink] WeiZhong94 commented on pull request #12280: [FLINK-17866][python] Change the implementation of the LocalFileSystem#pathToFile to fix the test case failure of PyFlink when running on

2020-05-22 Thread GitBox
WeiZhong94 commented on pull request #12280: URL: https://github.com/apache/flink/pull/12280#issuecomment-632551754 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] leonardBang opened a new pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

2020-05-22 Thread GitBox
leonardBang opened a new pull request #12290: URL: https://github.com/apache/flink/pull/12290 ## What is the purpose of the change *This pull request support unsigned for DataType TINYINT, SMALLINT, INT, BIGINT.* ## Brief change log - *support unsigned for

  1   2   3   4   >