[GitHub] [flink] JingsongLi opened a new pull request #11572: [FLINK-16877][table-runtime] SingleDirectoryWriter should not produce file when no input record

2020-03-30 Thread GitBox
JingsongLi opened a new pull request #11572: [FLINK-16877][table-runtime] SingleDirectoryWriter should not produce file when no input record URL: https://github.com/apache/flink/pull/11572 ## What is the purpose of the change SingleDirectoryWriter should not produce file when no

[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: * c22dcf150bd567c611c764ab45b7e28542f42e6a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/f

[jira] [Created] (FLINK-16878) flink-table-planner contains unwanted dependency org.apiguardian.api

2020-03-30 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-16878: -- Summary: flink-table-planner contains unwanted dependency org.apiguardian.api Key: FLINK-16878 URL: https://issues.apache.org/jira/browse/FLINK-16878 Project: Fli

[jira] [Closed] (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:all-tabpanel ] Kurt Young closed FLINK-16870. -- Resolution: Duplicate > OrcTableSource throws NullPointerException > -

[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&focusedCommentId=17071496#comment-17071496 ] Kurt Young commented on FLINK-16870: [~nikobearrr] Not yet, but it will be included

[jira] [Created] (FLINK-16877) SingleDirectoryWriter should not produce file when no input record

2020-03-30 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16877: Summary: SingleDirectoryWriter should not produce file when no input record Key: FLINK-16877 URL: https://issues.apache.org/jira/browse/FLINK-16877 Project: Flink

[GitHub] [flink] AHeise commented on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-30 Thread GitBox
AHeise commented on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-606431452 @travis run azure This is an automated message

[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: * c22dcf150bd567c611c764ab45b7e28542f42e6a Travis: [PENDING](https://travis-ci.com/github/flink-ci/f

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

2020-03-30 Thread Nikola (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071485#comment-17071485 ] Nikola commented on FLINK-16870: Hi [~ykt836]. Yes, that looks a lot like my issue. Is t

[jira] [Commented] (FLINK-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

2020-03-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071484#comment-17071484 ] Yang Wang commented on FLINK-15816: --- [~felixzheng] Are you still working on this? I th

[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: [SUCCESS](https://tr

[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: [SUCCESS](https://travis-ci.com/github/flink-ci/f

[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&focusedCommentId=17071479#comment-17071479 ] Xintong Song commented on FLINK-16874: -- Thanks for reporting this issue, [~karmagyz

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

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

[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&focusedCommentId=17071475#comment-17071475 ] Yangze Guo commented on FLINK-16874: I'd like to work on it. Could someone assign th

[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: [SUCCESS](https://travis-ci.com/github/flink-ci/f

[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: [FAILURE](https://travis-ci.

[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&focusedCommentId=17071473#comment-17071473 ] Jark Wu commented on FLINK-16876: - +1 to do this. This can also expose the state TTL abi

[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 * fd838b6268e0233589afed81f4f

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[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: [PENDING](https://travis-ci.

[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: [PENDING](https://tr

[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 * fd838b6268e0233589afed81f4f

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/nett

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/part

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/part

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/part

[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: [FAILURE](https://travis-ci.

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/part

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/part

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[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: flink-formats/flink-orc-compress/src/main/java/org/apache/flink/formats/orc/vec

[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: flink-formats/flink-orc-compress/src/test/java/org/apache/flink/formats/orc/wri

[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: flink-formats/flink-orc-compress/src/main/java/org/apache/flink/formats/orc/wri

[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: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/bu

[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: [SUCCESS](https://tr

[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 * fd838b6268e0233589afed81f4f

[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: [FAILURE](https://travis-ci.

[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&focusedCommentId=17071449#comment-17071449 ] jinhai commented on FLINK-16793: [~chesnay]  Modify the log4j property files and pass in

[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&focusedCommentId=17071450#comment-17071450 ] Yun Tang commented on FLINK-16876: -- [~azagrebin], what do you think of this? Please ass

[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: flink-table/flink-table-common/src/main/java/or

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[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: flink-table/flink-table-common/src/main/java/or

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

[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: flink-table/flink-table-api-java/src/main/java/

[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] [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-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 a

[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&focusedCommentId=17071439#comment-17071439 ] yanxiaobin commented on FLINK-16791: ok, thanks. > Could not deploy Yarn job clust

[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: [PENDING](https://travis-ci.com/github/flink-ci/flink/bu

[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: [SUCCESS](https://tr

[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 * fd838b6268e0233589afed81f4f

[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: flink-streaming-java/src/main/java/org/apache/flink/s

[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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/PlannerConfig.ja

[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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java

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

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

[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: Fl

[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: flink-runtime/src/main/java/org/apache/flink/runtime/

[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: flink-runtime/src/main/java/org/apache/flink/runtime/

[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&focusedCommentId=17071425#comment-17071425 ] Jingsong Lee commented on FLINK-13691: -- [~csbliss] See FLINK-16835. We can create a

[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 @flink

[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 Type:

[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: flink-runtime/src/main/java/org/apache/flink/runtime/

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

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

[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: flink-runtime/src/main/java/org/apache/flink/runtime/

[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: flink-runtime/src/main/java/org/apache/flink/runtime/

[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&focusedCommentId=17071418#comment-17071418 ] zhisheng commented on FLINK-16865: -- hi, [~wind_ljy] [~kangzai] This is how I solve 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: [FAILURE](https://travis-ci.com/github/flink-ci/flink/bu

[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, Gauge

[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: [FAILURE](https://travis-ci.com/github/flink-ci/flink/bu

[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, pl

[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&focusedCommentId=17071408#comment-17071408 ] Hequn Cheng commented on FLINK-16796: - Fixed in 1.11.0 via 52315e79b439eda4f6cd78360

[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&focusedCommentId=17071406#comment-17071406 ] Hequn Cheng commented on FLINK-16847: - Resolved in 1.11.0 via 851a830536c7811df7f207

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

[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 [FLINK-14338][table-planner

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

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

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

  1   2   3   4   5   6   >