[GitHub] [flink] wsry commented on pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-25 Thread GitBox
wsry commented on pull request #13595: URL: https://github.com/apache/flink/pull/13595#issuecomment-716321736 @StephanEwen @zhijiangW @gaoyunhaii Thanks for the review and comments, I have updated the PR according to the review comments.

[jira] [Updated] (FLINK-17372) SlotManager should expose total required resources

2020-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17372: - Fix Version/s: (was: 1.12.0) 1.13.0 > SlotManager should expose total

[jira] [Updated] (FLINK-13554) ResourceManager should have a timeout on starting new TaskExecutors.

2020-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13554: - Fix Version/s: (was: 1.12.0) 1.13.0 > ResourceManager should have a

[jira] [Updated] (FLINK-18229) Pending worker requests should be properly cleared

2020-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18229: - Fix Version/s: (was: 1.12.0) 1.13.0 > Pending worker requests should be

[GitHub] [flink] flinkbot edited a comment on pull request #13767: [FLINK-19787][table-runtime] Migrate Filesystem connector to new table source sink interface

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13767: URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450 ## CI report: * 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN * c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13771: [FLINK-19789][hive] Migrate Hive connector to new table source sink interface

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13771: URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930 ## CI report: * e5442954ffac19a92ba1f9a4620584e61acb601a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13677: Single task scheduler

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13677: URL: https://github.com/apache/flink/pull/13677#issuecomment-711161777 ## CI report: * b74b5ddf6a01dcb080cf5cf2e6773d919a6ecdec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-710017891 ## CI report: * 9be74ce0ce0d57bbda859ca9f5ec7d226df277b1 Azure:

[GitHub] [flink] Shawn-Hx commented on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-10-25 Thread GitBox
Shawn-Hx commented on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-716314480 Hi, @klion26 I have made some changes according to your advice. Also leave some comments about the last advice. Please take a look. Thanks.

[GitHub] [flink] zhuzhurk commented on a change in pull request #13730: [FLINK-19552][coordination] Consider only available input location preferences for slot profile in pipelined region scheduling

2020-10-25 Thread GitBox
zhuzhurk commented on a change in pull request #13730: URL: https://github.com/apache/flink/pull/13730#discussion_r511720650 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java ## @@ -212,20 +214,24 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13789: URL: https://github.com/apache/flink/pull/13789#issuecomment-716299701 ## CI report: * 6329930d7acc5d2d4d84e777561e79bd25ac9367 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13771: [FLINK-19789][hive] Migrate Hive connector to new table source sink interface

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13771: URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930 ## CI report: * e5442954ffac19a92ba1f9a4620584e61acb601a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13766: [FLINK-19703][runtime] Untrack a result partition if its producer task failed in TaskManager

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13766: URL: https://github.com/apache/flink/pull/13766#issuecomment-715255564 ## CI report: * 42f066384d04bcfe67ccbb5766f09ab5dde9e19c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * 4d7e601658c0dacc100c572f4fe8878c058e035f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13677: Single task scheduler

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13677: URL: https://github.com/apache/flink/pull/13677#issuecomment-711161777 ## CI report: * b74b5ddf6a01dcb080cf5cf2e6773d919a6ecdec Azure:

[GitHub] [flink] Shawn-Hx commented on a change in pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-10-25 Thread GitBox
Shawn-Hx commented on a change in pull request #13664: URL: https://github.com/apache/flink/pull/13664#discussion_r511723364 ## File path: docs/ops/deployment/cluster_setup.zh.md ## @@ -100,52 +105,60 @@ configuration files (which need to be accessible at the same path on all

[GitHub] [flink] klion26 commented on a change in pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-10-25 Thread GitBox
klion26 commented on a change in pull request #13664: URL: https://github.com/apache/flink/pull/13664#discussion_r511322491 ## File path: docs/ops/deployment/cluster_setup.zh.md ## @@ -22,65 +22,70 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] flinkbot commented on pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
flinkbot commented on pull request #13789: URL: https://github.com/apache/flink/pull/13789#issuecomment-716299701 ## CI report: * 6329930d7acc5d2d4d84e777561e79bd25ac9367 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13788: [FLINK-19252] Create the working dir for Jaas conf proactively.

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13788: URL: https://github.com/apache/flink/pull/13788#issuecomment-716292584 ## CI report: * 0f484654476d9ab49f6ce4a82475fe665e88fe5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13771: [FLINK-19789][hive] Migrate Hive connector to new table source sink interface

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13771: URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930 ## CI report: * e5442954ffac19a92ba1f9a4620584e61acb601a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13767: [FLINK-19787][table-runtime] Migrate Filesystem connector to new table source sink interface

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13767: URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450 ## CI report: * 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN * c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13766: [FLINK-19703][runtime] Untrack a result partition if its producer task failed in TaskManager

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13766: URL: https://github.com/apache/flink/pull/13766#issuecomment-715255564 ## CI report: * 42f066384d04bcfe67ccbb5766f09ab5dde9e19c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * 4d7e601658c0dacc100c572f4fe8878c058e035f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13759: [FLINK-19412][python] Re-layer Python Operation Make it Possible to Provide only Python implementation

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13759: URL: https://github.com/apache/flink/pull/13759#issuecomment-715027223 ## CI report: * 2e62d962b92ff2c18567a80dcae46fdcfe61d10d Azure:

[GitHub] [flink] shouweikun commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
shouweikun commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r511716192 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13631: [FLINK-19639][table sql/planner]Support SupportsNestedProjectionPushD…

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13631: URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709 ## CI report: * 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN * a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:

[GitHub] [flink] shouweikun commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
shouweikun commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r511713970 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala ## @@

[GitHub] [flink] shouweikun commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
shouweikun commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r511713970 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala ## @@

[GitHub] [flink] shouweikun commented on pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
shouweikun commented on pull request #13789: URL: https://github.com/apache/flink/pull/13789#issuecomment-716296334 @JingsongLi I push the pr, still some questions should be well discussed. I have left some comments.

[GitHub] [flink] shouweikun commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
shouweikun commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r511713970 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala ## @@

[GitHub] [flink] flinkbot commented on pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
flinkbot commented on pull request #13789: URL: https://github.com/apache/flink/pull/13789#issuecomment-716295445 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] [Updated] (FLINK-19727) Implement ParallelismProvider for sink in blink planner

2020-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19727: --- Labels: pull-request-available (was: ) > Implement ParallelismProvider for sink in blink

[GitHub] [flink] shouweikun opened a new pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-25 Thread GitBox
shouweikun opened a new pull request #13789: URL: https://github.com/apache/flink/pull/13789 …n blink planner ## What is the purpose of the change - Implement `ParallelismProvider` for sink in blink planner - `SinkFunctionProvider` and `OutputFormatProvider` work with

[GitHub] [flink] flinkbot commented on pull request #13788: [FLINK-19252] Create the working dir for Jaas conf proactively.

2020-10-25 Thread GitBox
flinkbot commented on pull request #13788: URL: https://github.com/apache/flink/pull/13788#issuecomment-716292584 ## CI report: * 0f484654476d9ab49f6ce4a82475fe665e88fe5e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13787: [FLINK-19522][jdbc] Fix NPE when accessing array using postgres

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13787: URL: https://github.com/apache/flink/pull/13787#issuecomment-716285196 ## CI report: * 93ee445aac08ecae0dd55add35411b67a0ec0b01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13759: [FLINK-19412][python] Re-layer Python Operation Make it Possible to Provide only Python implementation

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13759: URL: https://github.com/apache/flink/pull/13759#issuecomment-715027223 ## CI report: * 2e62d962b92ff2c18567a80dcae46fdcfe61d10d Azure:

[GitHub] [flink] HuangXingBo commented on pull request #13759: [FLINK-19412][python] Re-layer Python Operation Make it Possible to Provide only Python implementation

2020-10-25 Thread GitBox
HuangXingBo commented on pull request #13759: URL: https://github.com/apache/flink/pull/13759#issuecomment-716291287 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-19068) Filter verbose pod events for KubernetesResourceManagerDriver

2020-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19068. Resolution: Fixed Fixed via * master: 4b6d0e62cba16e4f43866e68f72bcc3a54337d85 > Filter verbose

[GitHub] [flink] xintongsong closed pull request #13765: [FLINK-19068][k8s] Improve log readability against duplicated pod termination events.

2020-10-25 Thread GitBox
xintongsong closed pull request #13765: URL: https://github.com/apache/flink/pull/13765 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Closed] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

2020-10-25 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-19750. Release Note: Patch merged. master: 200be714ff7476f66b7f56cd9b266670b752afe0 release-1.11:

[GitHub] [flink] wuchong commented on a change in pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-25 Thread GitBox
wuchong commented on a change in pull request #13721: URL: https://github.com/apache/flink/pull/13721#discussion_r511709209 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/SemiAntiJoinTest.xml ## @@

[GitHub] [flink] becketqin merged pull request #13785: [FLINK-19750][Kafka] Fix bug of not opening DeserializationSchema when FlinkKafkaConsumerBase recovering from state

2020-10-25 Thread GitBox
becketqin merged pull request #13785: URL: https://github.com/apache/flink/pull/13785 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] wuchong commented on a change in pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-25 Thread GitBox
wuchong commented on a change in pull request #13721: URL: https://github.com/apache/flink/pull/13721#discussion_r511707227 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecTableSourceScanRule.scala

[GitHub] [flink] wuchong commented on a change in pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-25 Thread GitBox
wuchong commented on a change in pull request #13721: URL: https://github.com/apache/flink/pull/13721#discussion_r511707353 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnUniqueness.scala ## @@

[GitHub] [flink] wuchong commented on a change in pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-25 Thread GitBox
wuchong commented on a change in pull request #13721: URL: https://github.com/apache/flink/pull/13721#discussion_r511706661 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.xml ## @@ -87,6

[jira] [Assigned] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19795: --- Assignee: Jark Wu > Flink SQL throws exception when changelog source contains duplicate change >

[jira] [Updated] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19795: Parent: FLINK-18822 Issue Type: Sub-task (was: Bug) > Flink SQL throws exception when changelog

[GitHub] [flink] flinkbot commented on pull request #13788: [FLINK-19252] Create the working dir for Jaas conf proactively.

2020-10-25 Thread GitBox
flinkbot commented on pull request #13788: URL: https://github.com/apache/flink/pull/13788#issuecomment-716285137 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

[GitHub] [flink] flinkbot commented on pull request #13787: [FLINK-19522][jdbc] Fix NPE when accessing array using postgres

2020-10-25 Thread GitBox
flinkbot commented on pull request #13787: URL: https://github.com/apache/flink/pull/13787#issuecomment-716285196 ## CI report: * 93ee445aac08ecae0dd55add35411b67a0ec0b01 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-19252) Jaas file created under io.tmp.dirs - folder not created if not exists

2020-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19252: --- Labels: pull-request-available (was: ) > Jaas file created under io.tmp.dirs - folder not

[GitHub] [flink] flinkbot edited a comment on pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13595: URL: https://github.com/apache/flink/pull/13595#issuecomment-707168234 ## CI report: * 690ec79d32dbd8e2a9c62556c0548a56c6a52521 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13631: [FLINK-19639][table sql/planner]Support SupportsNestedProjectionPushD…

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13631: URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709 ## CI report: * 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN * a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:

[GitHub] [flink] KarmaGYZ opened a new pull request #13788: [FLINK-19252] Create the working dir for Jaas conf proactively.

2020-10-25 Thread GitBox
KarmaGYZ opened a new pull request #13788: URL: https://github.com/apache/flink/pull/13788 ## What is the purpose of the change Create the working dir for Jaas conf proactively. cc @zentol This is

[jira] [Updated] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19795: Fix Version/s: 1.12.0 > Flink SQL throws exception when changelog source contains duplicate change >

[jira] [Commented] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220462#comment-17220462 ] Jark Wu commented on FLINK-19795: - Regarding to this issue, I think this is very common, because usually

[jira] [Commented] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220461#comment-17220461 ] Jark Wu commented on FLINK-19795: - After offline discussion with [~shen_dijie], I helped to update the

[jira] [Updated] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19795: Description: We are using Canal to synchornize MySQL data into Kafka, the synchornization delivery is not

[jira] [Updated] (FLINK-19795) Flink SQL throws exception when changelog source contains duplicate change events

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19795: Summary: Flink SQL throws exception when changelog source contains duplicate change events (was: When

[jira] [Updated] (FLINK-19795) When TOPN handles duplicate data, it will throw an exception

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19795: Description: We are using Canal to synchornize MySQL data into Kafka, the synchornization delivery is not

[GitHub] [flink] flinkbot edited a comment on pull request #13767: [FLINK-19787][table-runtime] Migrate Filesystem connector to new table source sink interface

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13767: URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450 ## CI report: * 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN * c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:

[GitHub] [flink] flinkbot commented on pull request #13787: [FLINK-19522][jdbc] Fix NPE when accessing array using postgres

2020-10-25 Thread GitBox
flinkbot commented on pull request #13787: URL: https://github.com/apache/flink/pull/13787#issuecomment-716280232 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

[GitHub] [flink] flinkbot edited a comment on pull request #13631: [FLINK-19639][table sql/planner]Support SupportsNestedProjectionPushD…

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13631: URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709 ## CI report: * 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN * a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:

[GitHub] [flink] dforciea commented on pull request #13787: [FLINK-19522][jdbc] Fix NPE when accessing array using postgres

2020-10-25 Thread GitBox
dforciea commented on pull request #13787: URL: https://github.com/apache/flink/pull/13787#issuecomment-716280150 The second commit gets rid of the PostgresRowConverterTest that I had originally added. Let me know if you think this is useful, and I can bring it back. Otherwise, I'll just

[GitHub] [flink] flinkbot edited a comment on pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13595: URL: https://github.com/apache/flink/pull/13595#issuecomment-707168234 ## CI report: * 690ec79d32dbd8e2a9c62556c0548a56c6a52521 Azure:

[jira] [Commented] (FLINK-19797) NPE when we use decimal array as input of UDAF

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220457#comment-17220457 ] Jark Wu commented on FLINK-19797: - Which version are you using? > NPE when we use decimal array as

[GitHub] [flink] dforciea opened a new pull request #13787: Flink 19771

2020-10-25 Thread GitBox
dforciea opened a new pull request #13787: URL: https://github.com/apache/flink/pull/13787 ## What is the purpose of the change Fixes an issue where null arrays in postgres cause a NullPointerException when retrieving data ## Brief change log - Update

[GitHub] [flink] TsReaper commented on a change in pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-25 Thread GitBox
TsReaper commented on a change in pull request #13742: URL: https://github.com/apache/flink/pull/13742#discussion_r511700500 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java ##

[GitHub] [flink] TsReaper commented on a change in pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-25 Thread GitBox
TsReaper commented on a change in pull request #13742: URL: https://github.com/apache/flink/pull/13742#discussion_r511700192 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java ##

[jira] [Commented] (FLINK-11220) Can not Select row time field in JOIN query

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220455#comment-17220455 ] Jark Wu commented on FLINK-11220: - Hi [~twalthr], I think they are different issue. IIUC, FLINK-10211

[GitHub] [flink] TsReaper commented on a change in pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-25 Thread GitBox
TsReaper commented on a change in pull request #13742: URL: https://github.com/apache/flink/pull/13742#discussion_r511699119 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java ##

[GitHub] [flink] TsReaper commented on a change in pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-25 Thread GitBox
TsReaper commented on a change in pull request #13742: URL: https://github.com/apache/flink/pull/13742#discussion_r511699281 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java ##

[jira] [Commented] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

2020-10-25 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220454#comment-17220454 ] Leonard Xu commented on FLINK-19771: [~dforciea]  Your branch makes sense to me, I think you can

[jira] [Assigned] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

2020-10-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19771: --- Assignee: Dylan Forciea > NullPointerException when accessing null array from postgres in JDBC

[GitHub] [flink] flinkbot edited a comment on pull request #13786: [FLINK-19764] Add More Metrics to TaskManager in Web UI

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13786: URL: https://github.com/apache/flink/pull/13786#issuecomment-716269806 ## CI report: * f6bedbd6f4cc29777a888be558030b56ba803a54 Azure:

[GitHub] [flink] wsry commented on pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-25 Thread GitBox
wsry commented on pull request #13595: URL: https://github.com/apache/flink/pull/13595#issuecomment-716275114 > Thanks a lot, the code looks generally good to me. > > I think the current configuration works also as a feature flag, which is nice. If I read it correctly, sort-shuffle

[jira] [Commented] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster

2020-10-25 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220452#comment-17220452 ] Xuannan Su commented on FLINK-19761: You are right that not returning all the information it needs

[jira] [Commented] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

2020-10-25 Thread Dylan Forciea (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220450#comment-17220450 ] Dylan Forciea commented on FLINK-19771: --- [~Leonard Xu] Thank you for the pointer on where there

[GitHub] [flink] flinkbot edited a comment on pull request #13631: [FLINK-19639][table sql/planner]Support SupportsNestedProjectionPushD…

2020-10-25 Thread GitBox
flinkbot edited a comment on pull request #13631: URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709 ## CI report: * 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN * 46f99482ad7bea8e467130fe5dd92b61b7d3d444 Azure:

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-10-25 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Fix Version/s: (was: 1.12.0) 1.13.0 > Reduce the default number of

[jira] [Updated] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

2020-10-25 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16641: Fix Version/s: (was: 1.12.0) 1.13.0 > Announce sender's backlog to solve

[jira] [Updated] (FLINK-18762) Make network buffers per incoming/outgoing channel can be configured separately

2020-10-25 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-18762: Fix Version/s: (was: 1.12.0) 1.13.0 > Make network buffers per

[jira] [Updated] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

2020-10-25 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-17572: Fix Version/s: (was: 1.12.0) 1.13.0 > Remove checkpoint alignment buffered

[jira] [Updated] (FLINK-16428) Fine-grained network buffer management for backpressure

2020-10-25 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16428: Fix Version/s: (was: 1.12.0) 1.13.0 > Fine-grained network buffer

[GitHub] [flink] flinkbot commented on pull request #13786: [FLINK-19764] Add More Metrics to TaskManager in Web UI

2020-10-25 Thread GitBox
flinkbot commented on pull request #13786: URL: https://github.com/apache/flink/pull/13786#issuecomment-716269806 ## CI report: * f6bedbd6f4cc29777a888be558030b56ba803a54 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-19727) Implement ParallelismProvider for sink in blink planner

2020-10-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19727: Assignee: Lsw_aka_laplace > Implement ParallelismProvider for sink in blink planner >

[jira] [Commented] (FLINK-19727) Implement ParallelismProvider for sink in blink planner

2020-10-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220447#comment-17220447 ] Jingsong Lee commented on FLINK-19727: -- Assigned to you. [~neighborhood] It should be noted that

[jira] [Commented] (FLINK-19777) Fix NullPointException for WindowOperator.close()

2020-10-25 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220443#comment-17220443 ] hailong wang commented on FLINK-19777: -- You are right. More correctly, the dispose method is called

[jira] [Updated] (FLINK-19796) Error results when use constant decimal array

2020-10-25 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-19796: --- Affects Version/s: 1.11.2 > Error results when use constant decimal array >

[jira] [Commented] (FLINK-19796) Error results when use constant decimal array

2020-10-25 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220440#comment-17220440 ] Benchao Li commented on FLINK-19796: [~FrankZou] assigned to you~ > Error results when use constant

[jira] [Assigned] (FLINK-19796) Error results when use constant decimal array

2020-10-25 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-19796: -- Assignee: Zou > Error results when use constant decimal array >

[jira] [Commented] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

2020-10-25 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220439#comment-17220439 ] Leonard Xu commented on FLINK-19771: Thanks [~dforciea] for reporting, I think we should override

[GitHub] [flink] flinkbot commented on pull request #13786: [FLINK-19764] Add More Metrics to TaskManager in Web UI

2020-10-25 Thread GitBox
flinkbot commented on pull request #13786: URL: https://github.com/apache/flink/pull/13786#issuecomment-716265458 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] [Updated] (FLINK-19764) Add More Metrics to TaskManager in Web UI

2020-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19764: --- Labels: pull-request-available (was: ) > Add More Metrics to TaskManager in Web UI >

[GitHub] [flink] vthinkxie opened a new pull request #13786: [FLINK-19764] Add More Metrics to TaskManager in Web UI

2020-10-25 Thread GitBox
vthinkxie opened a new pull request #13786: URL: https://github.com/apache/flink/pull/13786 ## What is the purpose of the change ref https://issues.apache.org/jira/browse/FLINK-19764 ## Brief change log Add More Metrics to TaskManager in Web UI ## Verifying

[jira] [Commented] (FLINK-19796) Error results when use constant decimal array

2020-10-25 Thread Zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220437#comment-17220437 ] Zou commented on FLINK-19796: - [~libenchao] Yes, I'd like to. > Error results when use constant decimal

[jira] [Updated] (FLINK-19796) Error results when use constant decimal array

2020-10-25 Thread Zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zou updated FLINK-19796: Description: The result is wrong when use constant decimal array with different precisions. Here is an example:

[jira] [Assigned] (FLINK-11220) Can not Select row time field in JOIN query

2020-10-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-11220: --- Assignee: (was: Dian Fu) > Can not Select row time field in JOIN query >

[jira] [Commented] (FLINK-19791) PartitionRequestClientFactoryTest.testInterruptsNotCached fails with NullPointerException

2020-10-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220435#comment-17220435 ] Dian Fu commented on FLINK-19791: -

[jira] [Commented] (FLINK-19793) KafkaTableITCase.testKafkaSourceSinkWithMetadata fails on AZP

2020-10-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220434#comment-17220434 ] Dian Fu commented on FLINK-19793: -

[jira] [Commented] (FLINK-19201) PyFlink e2e tests is instable and failed with "Connection broken: OSError"

2020-10-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220433#comment-17220433 ] Dian Fu commented on FLINK-19201: -

  1   2   3   >