[GitHub] [flink] flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into…

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into… URL: https://github.com/apache/flink/pull/11540#issuecomment-604804466 ## CI report: * 07b38deaa1461a92bbc537c40a66915875aee98f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11559: [FLINK-16858][table] Expose partitioned by grammar

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11559: [FLINK-16858][table] Expose partitioned by grammar URL: https://github.com/apache/flink/pull/11559#issuecomment-605804330 ## CI report: * 648bfa7907e6d9b4a2640c577ba181b3f212da74 Travis:

[jira] [Commented] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071479#comment-17071479 ] Xintong Song commented on FLINK-16874: -- Thanks for reporting this issue, [~karmagyz]. I would not

[jira] [Updated] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16874: --- Priority: Critical (was: Blocker) > Respect the dynamic options when calculating memory options in

[jira] [Updated] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16874: - Priority: Major (was: Critical) > Respect the dynamic options when calculating memory options

[jira] [Updated] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16874: --- Issue Type: Improvement (was: Bug) > Respect the dynamic options when calculating memory options

[jira] [Commented] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071475#comment-17071475 ] Yangze Guo commented on FLINK-16874: I'd like to work on it. Could someone assign this to me? >

[GitHub] [flink] flinkbot edited a comment on issue #11559: [FLINK-16858][table] Expose partitioned by grammar

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11559: [FLINK-16858][table] Expose partitioned by grammar URL: https://github.com/apache/flink/pull/11559#issuecomment-605804330 ## CI report: * 648bfa7907e6d9b4a2640c577ba181b3f212da74 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 7cebc64ea4a49f0f1d246889cb71b730b4a170eb Travis:

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-03-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071473#comment-17071473 ] Jark Wu commented on FLINK-16876: - +1 to do this. This can also expose the state TTL ability to the

[GitHub] [flink] flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571#issuecomment-606377768 ## CI report: * 91507d011419afe848d1a90ae0027cd2511817e5 UNKNOWN *

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400645765 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 7cebc64ea4a49f0f1d246889cb71b730b4a170eb Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into…

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into… URL: https://github.com/apache/flink/pull/11540#issuecomment-604804466 ## CI report: * 07b38deaa1461a92bbc537c40a66915875aee98f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571#issuecomment-606377768 ## CI report: * 91507d011419afe848d1a90ae0027cd2511817e5 UNKNOWN *

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400643335 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400642380 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400637920 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400641076 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 2a005b9c7d287b338a5a4c0795816d61e8f09312 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400639370 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400638771 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400637920 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400636648 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink

2020-03-30 Thread GitBox
JingsongLi commented on a change in pull request #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink URL: https://github.com/apache/flink/pull/11474#discussion_r400632781 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink

2020-03-30 Thread GitBox
JingsongLi commented on a change in pull request #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink URL: https://github.com/apache/flink/pull/11474#discussion_r400634673 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink

2020-03-30 Thread GitBox
JingsongLi commented on a change in pull request #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink URL: https://github.com/apache/flink/pull/11474#discussion_r400635006 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task.

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 0542c5dc966c56853433d487858711cbba1d9eb3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into…

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into… URL: https://github.com/apache/flink/pull/11540#issuecomment-604804466 ## CI report: * 31c00a13b2bb7f15b4fa594b5c9148f971769e86 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571#issuecomment-606377768 ## CI report: * 91507d011419afe848d1a90ae0027cd2511817e5 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 2a005b9c7d287b338a5a4c0795816d61e8f09312 Travis:

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

2020-03-30 Thread jinhai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071449#comment-17071449 ] jinhai commented on FLINK-16793: [~chesnay]  Modify the log4j property files and pass in the additional

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071450#comment-17071450 ] Yun Tang commented on FLINK-16876: -- [~azagrebin], what do you think of this? Please assign to me if you

[GitHub] [flink] docete commented on a change in pull request #11493: [FLINK-16160][table-common] Support computed column, proctime and watermark in Schema descriptor

2020-03-30 Thread GitBox
docete commented on a change in pull request #11493: [FLINK-16160][table-common] Support computed column, proctime and watermark in Schema descriptor URL: https://github.com/apache/flink/pull/11493#discussion_r400634261 ## File path:

[jira] [Created] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-03-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-16876: Summary: Make TtlTimeProvider configurable when creating keyed state backend Key: FLINK-16876 URL: https://issues.apache.org/jira/browse/FLINK-16876 Project: Flink

[jira] [Created] (FLINK-16875) Tracking replace QueryConfig and TableConfig implementation with ConfigOption

2020-03-30 Thread jinhai (Jira)
jinhai created FLINK-16875: -- Summary: Tracking replace QueryConfig and TableConfig implementation with ConfigOption Key: FLINK-16875 URL: https://issues.apache.org/jira/browse/FLINK-16875 Project: Flink

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400632538 ## File path:

[GitHub] [flink] docete commented on a change in pull request #11493: [FLINK-16160][table-common] Support computed column, proctime and watermark in Schema descriptor

2020-03-30 Thread GitBox
docete commented on a change in pull request #11493: [FLINK-16160][table-common] Support computed column, proctime and watermark in Schema descriptor URL: https://github.com/apache/flink/pull/11493#discussion_r400632587 ## File path:

[jira] [Resolved] (FLINK-16857) Support partition prune by getPartitions of source

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16857. -- Resolution: Fixed master: e789bb7165d32b2501f87a071f0f17022d82ac95 > Support partition prune

[GitHub] [flink] JingsongLi commented on issue #11560: [FLINK-16857][table-planner-blink] Support partition prune by getPartitions of source

2020-03-30 Thread GitBox
JingsongLi commented on issue #11560: [FLINK-16857][table-planner-blink] Support partition prune by getPartitions of source URL: https://github.com/apache/flink/pull/11560#issuecomment-606384898 Merged #11560 to Master. Thanks @leonardBang for the review.

[GitHub] [flink] JingsongLi merged pull request #11560: [FLINK-16857][table-planner-blink] Support partition prune by getPartitions of source

2020-03-30 Thread GitBox
JingsongLi merged pull request #11560: [FLINK-16857][table-planner-blink] Support partition prune by getPartitions of source URL: https://github.com/apache/flink/pull/11560 This is an automated message from the Apache Git

[GitHub] [flink] docete commented on a change in pull request #11493: [FLINK-16160][table-common] Support computed column, proctime and watermark in Schema descriptor

2020-03-30 Thread GitBox
docete commented on a change in pull request #11493: [FLINK-16160][table-common] Support computed column, proctime and watermark in Schema descriptor URL: https://github.com/apache/flink/pull/11493#discussion_r400628945 ## File path:

[jira] [Assigned] (FLINK-14257) Integrate csv to FileSystemTableFactory

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14257: Assignee: Leonard Xu > Integrate csv to FileSystemTableFactory >

[jira] [Assigned] (FLINK-14267) Introduce Row Csv Encoder

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14267: Assignee: Leonard Xu > Introduce Row Csv Encoder > - > >

[jira] [Updated] (FLINK-14267) Introduce Row Csv Encoder

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14267: - Fix Version/s: 1.11.0 > Introduce Row Csv Encoder > - > >

[jira] [Updated] (FLINK-14257) Integrate csv to FileSystemTableFactory

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14257: - Fix Version/s: 1.11.0 > Integrate csv to FileSystemTableFactory >

[jira] [Assigned] (FLINK-14267) Introduce Row Csv Encoder

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14267: Assignee: (was: Jingsong Lee) > Introduce Row Csv Encoder >

[GitHub] [flink] JingsongLi commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

2020-03-30 Thread GitBox
JingsongLi commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-606383941 Hi @twalthr , do you have other concerns? This is

[jira] [Commented] (FLINK-16791) Could not deploy Yarn job cluster when using flink-s3-fs-hadoop-1.10.0.jar

2020-03-30 Thread yanxiaobin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071439#comment-17071439 ] yanxiaobin commented on FLINK-16791: ok, thanks. > Could not deploy Yarn job cluster when using

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task.

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 0542c5dc966c56853433d487858711cbba1d9eb3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into…

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11540: [FLINK-16099][docs-zh] Translate "HiveCatalog" page of "Hive Integration" into… URL: https://github.com/apache/flink/pull/11540#issuecomment-604804466 ## CI report: * 31c00a13b2bb7f15b4fa594b5c9148f971769e86 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571#issuecomment-606377768 ## CI report: * 91507d011419afe848d1a90ae0027cd2511817e5 UNKNOWN *

[GitHub] [flink] zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400625877 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11481: [FLINK-13691][Table]Remove deprecated query config

2020-03-30 Thread GitBox
JingsongLi commented on a change in pull request #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#discussion_r400624159 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11481: [FLINK-13691][Table]Remove deprecated query config

2020-03-30 Thread GitBox
JingsongLi commented on a change in pull request #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#discussion_r400624268 ## File path:

[jira] [Updated] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16874: --- Issue Type: Bug (was: Improvement) > Respect the dynamic options when calculating memory options

[jira] [Updated] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16874: --- Description: Since FLINK-9821, the taskmanager.sh will pass user-defined dynamic options to the

[jira] [Created] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-30 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16874: -- Summary: Respect the dynamic options when calculating memory options in taskmanager.sh Key: FLINK-16874 URL: https://issues.apache.org/jira/browse/FLINK-16874 Project:

[GitHub] [flink] zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400623300 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400623114 ## File path:

[jira] [Commented] (FLINK-13691) Remove deprecated query config

2020-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071425#comment-17071425 ] Jingsong Lee commented on FLINK-13691: -- [~csbliss] See FLINK-16835. We can create an issue for

[GitHub] [flink] flinkbot commented on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
flinkbot commented on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571#issuecomment-606377768 ## CI report: * 91507d011419afe848d1a90ae0027cd2511817e5 UNKNOWN Bot commands The

[jira] [Created] (FLINK-16873) Document the suggested memory size for statefun docker machine

2020-03-30 Thread Yu Li (Jira)
Yu Li created FLINK-16873: - Summary: Document the suggested memory size for statefun docker machine Key: FLINK-16873 URL: https://issues.apache.org/jira/browse/FLINK-16873 Project: Flink Issue

[GitHub] [flink] zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400619759 ## File path:

[GitHub] [flink] flinkbot commented on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
flinkbot commented on issue #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571#issuecomment-606374448 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-16710) Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16710: --- Labels: pull-request-available (was: ) > Log Upload blocks Main Thread in TaskExecutor >

[GitHub] [flink] jrthe42 opened a new pull request #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor

2020-03-30 Thread GitBox
jrthe42 opened a new pull request #11571: [FLINK-16710][runtime] Log Upload blocks Main Thread in TaskExecutor URL: https://github.com/apache/flink/pull/11571 ## What is the purpose of the change TaskExecutors upload logs to BlobServer in main thread, which may cause main thread

[GitHub] [flink] zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400614992 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-30 Thread GitBox
zhijiangW commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400614992 ## File path:

[jira] [Commented] (FLINK-16865) 【Flink Kafka Connector】Restore from Savepoint,if add new Kafka topic,Flink will consume the new topic from earlist,it may cause duplicate data sink

2020-03-30 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071418#comment-17071418 ] zhisheng commented on FLINK-16865: -- hi, [~wind_ljy] [~kangzai] This is how I solve the problem for the

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task.

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 623248594914ebf2dab46965390f72ba7f3c1346 Travis:

[jira] [Closed] (FLINK-16673) Support Counter, Gauge, Meter, Distribution metric type for Python UDTF

2020-03-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16673. --- Resolution: Resolved Merged to master via ee1e83ceb176cd5700b07f7a26e23b082d8f38fd > Support Counter,

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task.

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11564: [FLINK-16864] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 623248594914ebf2dab46965390f72ba7f3c1346 Travis:

[GitHub] [flink] dianfu merged pull request #11566: [FLINK-16673][python] Support metrics for Python UDTF

2020-03-30 Thread GitBox
dianfu merged pull request #11566: [FLINK-16673][python] Support metrics for Python UDTF URL: https://github.com/apache/flink/pull/11566 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16796. --- Resolution: Fixed > Fix The Bug of Python UDTF in SQL Query >

[jira] [Commented] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071408#comment-17071408 ] Hequn Cheng commented on FLINK-16796: - Fixed in 1.11.0 via 52315e79b439eda4f6cd7836051c1791382a4a7d

[GitHub] [flink] hequn8128 merged pull request #11521: [FLINK-16796][python] Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread GitBox
hequn8128 merged pull request #11521: [FLINK-16796][python] Fix The Bug of Python UDTF in SQL Query URL: https://github.com/apache/flink/pull/11521 This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16796: --- Assignee: Huang Xingbo > Fix The Bug of Python UDTF in SQL Query >

[jira] [Updated] (FLINK-15064) Remove XmlOutput util class in blink planner

2020-03-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15064: Fix Version/s: 1.11.0 > Remove XmlOutput util class in blink planner >

[jira] [Updated] (FLINK-15064) Remove XmlOutput util class in blink planner

2020-03-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15064: Parent: (was: FLINK-14338) Issue Type: Task (was: Sub-task) > Remove XmlOutput util class in

[jira] [Closed] (FLINK-16847) Support timestamp types in vectorized Python UDF

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16847. --- Resolution: Resolved > Support timestamp types in vectorized Python UDF >

[jira] [Commented] (FLINK-16847) Support timestamp types in vectorized Python UDF

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071406#comment-17071406 ] Hequn Cheng commented on FLINK-16847: - Resolved in 1.11.0 via 

[jira] [Closed] (FLINK-15210) Move java files in flink-sql-parser module package org.apache.calcite.sql to org.apache.flink.sql.parser.type

2020-03-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15210. --- Fix Version/s: 1.11.0 Resolution: Fixed This has been fixed in FLINK-14338. > Move java files in

[jira] [Closed] (FLINK-15282) Remove ParameterScope in blink planner

2020-03-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15282. --- Fix Version/s: 1.11.0 Resolution: Fixed This has been fixed in FLINK-14338. > Remove ParameterScope

[jira] [Resolved] (FLINK-14338) Upgrade Calcite version to 1.22 for Flink SQL

2020-03-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14338. - Fix Version/s: 1.11.0 Assignee: Danny Chen Resolution: Fixed

[GitHub] [flink] wuchong closed pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-30 Thread GitBox
wuchong closed pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wuchong commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-30 Thread GitBox
wuchong commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-606354511 Thanks @danny0405 for the great effort, and thanks all for the reviewing. I will merge this.

[GitHub] [flink] PatrickRen commented on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation

2020-03-30 Thread GitBox
PatrickRen commented on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation URL: https://github.com/apache/flink/pull/11425#issuecomment-606352442 Hi Becket @becketqin and Jark @wuchong , can you help to review the code? I think it's in good shape

[GitHub] [flink] zhengcanbin commented on issue #11569: [FLINK-16737][k8s] Remove KubernetesUtils#getContentFromFile

2020-03-30 Thread GitBox
zhengcanbin commented on issue #11569: [FLINK-16737][k8s] Remove KubernetesUtils#getContentFromFile URL: https://github.com/apache/flink/pull/11569#issuecomment-606350461 @flinkbot run azure This is an automated message from

[GitHub] [flink] hequn8128 merged pull request #11556: [FLINK-16847][python] Support timestamp types in vectorized Python UDF

2020-03-30 Thread GitBox
hequn8128 merged pull request #11556: [FLINK-16847][python] Support timestamp types in vectorized Python UDF URL: https://github.com/apache/flink/pull/11556 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-16870) OrcTableSource throws NullPointerException

2020-03-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071371#comment-17071371 ] Kurt Young commented on FLINK-16870: I think this is the same with FLINK-16646, could you check

[jira] [Commented] (FLINK-16728) Taskmanager dies after job got stuck and canceling fails

2020-03-30 Thread Leonid Ilyevsky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071367#comment-17071367 ] Leonid Ilyevsky commented on FLINK-16728: - Hi [~zhuzh], thanks for the explanation. Of course,

[GitHub] [flink] faaronzheng commented on a change in pull request #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

2020-03-30 Thread GitBox
faaronzheng commented on a change in pull request #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#discussion_r399729007 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992 ## CI report: * 22e12ad32ac71e45f7c40fd08ad0cc4498664613 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata URL: https://github.com/apache/flink/pull/11491#issuecomment-602805203 ## CI report: * b752ebcec0c6cfba091790353b76ed71597ed335 UNKNOWN *

[GitHub] [flink] zentol commented on issue #11303: [FLINK-16245] Decoupling user classloader from context classloader.

2020-03-30 Thread GitBox
zentol commented on issue #11303: [FLINK-16245] Decoupling user classloader from context classloader. URL: https://github.com/apache/flink/pull/11303#issuecomment-606292140 @flinkbot run azure This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992 ## CI report: * 22e12ad32ac71e45f7c40fd08ad0cc4498664613 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11518: [FLINK-16555] Block Enum as key type

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11518: [FLINK-16555] Block Enum as key type URL: https://github.com/apache/flink/pull/11518#issuecomment-604351209 ## CI report: * 53d3a2d0b005747e588c7ad552bb1d29ff2eee24 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992 ## CI report: * 22e12ad32ac71e45f7c40fd08ad0cc4498664613 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata

2020-03-30 Thread GitBox
flinkbot edited a comment on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata URL: https://github.com/apache/flink/pull/11491#issuecomment-602805203 ## CI report: * b7eb8c4e86489fb9d9f8c455b21d7e3adb3d49f2 Travis:

  1   2   3   4   5   6   >