[GitHub] [flink] rmetzger opened a new pull request #14585: [FLINK-20632] Use Docker image published to apache/flink by default

2021-01-07 Thread GitBox
rmetzger opened a new pull request #14585: URL: https://github.com/apache/flink/pull/14585 ## What is the purpose of the change Add second docker image distribution channel to docs. Use `apache/flink` images by default in the docs and in the code (for K8s). ## Verifying th

[GitHub] [flink] flinkbot commented on pull request #14584: [FLINK-20580][runtime] Removing usage of CoLocationConstraints

2021-01-07 Thread GitBox
flinkbot commented on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-756609457 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] rmetzger commented on pull request #14583: [FLINK-20832][docs] Deliver bootstrap css and js ourselves

2021-01-07 Thread GitBox
rmetzger commented on pull request #14583: URL: https://github.com/apache/flink/pull/14583#issuecomment-756609137 Thanks for opening the PR. Have you checked the licenses of the font files? This is an automated message from t

[jira] [Updated] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

2021-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20580: --- Labels: pull-request-available starter (was: starter) > Missing null value handling for Ser

[GitHub] [flink] flinkbot commented on pull request #14583: [FLINK-20832][docs] Deliver bootstrap css and js ourselves

2021-01-07 Thread GitBox
flinkbot commented on pull request #14583: URL: https://github.com/apache/flink/pull/14583#issuecomment-756608804 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] XComp opened a new pull request #14584: [FLINK-20580][runtime] Removing usage of CoLocationConstraints

2021-01-07 Thread GitBox
XComp opened a new pull request #14584: URL: https://github.com/apache/flink/pull/14584 ## What is the purpose of the change The `CoLocationConstraint` class became obsolete when introducing [FLINK-18690](https://issues.apache.org/jira/browse/FLINK-18689). This PR depends on P

[jira] [Updated] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20832: --- Labels: pull-request-available (was: ) > flink.apache.org site Typography exception > -

[GitHub] [flink] wuchong opened a new pull request #14583: [FLINK-20832][docs] Deliver bootstrap css and js ourselves

2021-01-07 Thread GitBox
wuchong opened a new pull request #14583: URL: https://github.com/apache/flink/pull/14583 ## What is the purpose of the change Delivering the required files ourselves, instead of using a CDN to fix the unstable https://maxcdn.bootstrapcdn.com in China. ## Brief change

[jira] [Commented] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

2021-01-07 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261083#comment-17261083 ] jackwangcs commented on FLINK-20714: Hi [~trohrmann], could you take a look at this?

[GitHub] [flink] flinkbot edited a comment on pull request #14579: [FLINK-20619] Removed InputDependencyConstraint

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14579: URL: https://github.com/apache/flink/pull/14579#issuecomment-756130759 ## CI report: * 7b160f223f76e9592f74ce0e4649052f2c6367d4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] XComp commented on pull request #14579: [FLINK-20619] Removed InputDependencyConstraint

2021-01-07 Thread GitBox
XComp commented on pull request #14579: URL: https://github.com/apache/flink/pull/14579#issuecomment-756604087 Yeah, I realized it this morning that I had `*.java` set up as a filter in my Idea search dialog. 😇 I fixed it. But are we ok with just removing the public API as is? Or sho

[jira] [Updated] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

2021-01-07 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-20714: --- Issue Type: Improvement (was: Bug) > Hive delegation token is not obtained when using `kinit` to su

[jira] [Reopened] (FLINK-19922) Remove SlotProvider from SchedulerNG

2021-01-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-19922: - > Remove SlotProvider from SchedulerNG > > > Key: FLINK

[jira] [Closed] (FLINK-19922) Remove SlotProvider from SchedulerNG

2021-01-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19922. --- Resolution: Fixed > Remove SlotProvider from SchedulerNG > > >

[jira] [Closed] (FLINK-19922) Remove SlotProvider from SchedulerNG

2021-01-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19922. --- Resolution: Duplicate > Remove SlotProvider from SchedulerNG > > >

[jira] [Assigned] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20832: --- Assignee: Jark Wu > flink.apache.org site Typography exception > --

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 2242b5369d48f75ae126f3a9bbaf814bb12ac4ed Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2021-01-07 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261067#comment-17261067 ] Matthias commented on FLINK-16947: -- https://dev.azure.com/mapohl/flink/_build/results?b

[jira] [Comment Edited] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261065#comment-17261065 ] Jark Wu edited comment on FLINK-20832 at 1/8/21, 7:20 AM: -- Good

[jira] [Commented] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261065#comment-17261065 ] Jark Wu commented on FLINK-20832: - Good idea! We should deliver fontawesome ourselves. I

[GitHub] [flink] zhuzhurk edited a comment on pull request #14579: [FLINK-20619] Removed InputDependencyConstraint

2021-01-07 Thread GitBox
zhuzhurk edited a comment on pull request #14579: URL: https://github.com/apache/flink/pull/14579#issuecomment-756533725 Thanks for opening this PR! @XComp The change looks good to me except that a python test for InputDependencyConstraint was not removed and is causing test failure:

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2021-01-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20654: --- Release Note: Using UnalignedCheckpoints in Flink 1.12.0 combined with two/multiple inputs

[jira] [Commented] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

2021-01-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261061#comment-17261061 ] Yun Tang commented on FLINK-20886: -- Currently, Flink would abort checkpoints via networ

[jira] [Closed] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2021-01-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20654. -- Release Note: Using UnalignedCheckpoints in Flink 1.12.0 combined with two/multiple inputs ta

[GitHub] [flink] flinkbot edited a comment on pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14574: URL: https://github.com/apache/flink/pull/14574#issuecomment-755961123 ## CI report: * a8d0d6432e87bb1a75525cb8fe1153232cd9d823 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 2242b5369d48f75ae126f3a9bbaf814bb12ac4ed Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2021-01-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20654: --- Priority: Blocker (was: Critical) > Unaligned checkpoint recovery may lead to corrupted dat

[GitHub] [flink] wuchong commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
wuchong commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-756588550 I have rebased and squashed the commits to trigger the build again. This is an automated message from the Apach

[GitHub] [flink] pnowojski merged pull request #14582: (backport 1.12) [FLINK-20654][checkpointing] Decline checkpoint until input channel is recovered

2021-01-07 Thread GitBox
pnowojski merged pull request #14582: URL: https://github.com/apache/flink/pull/14582 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 t

[GitHub] [flink] pnowojski merged pull request #14581: [FLINK-20654][checkpointing] Decline checkpoint until input channel is recovered

2021-01-07 Thread GitBox
pnowojski merged pull request #14581: URL: https://github.com/apache/flink/pull/14581 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 t

[jira] [Commented] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261057#comment-17261057 ] Robert Metzger commented on FLINK-20832: Oh damn. Let's fix this asap. How abou

[jira] [Comment Edited] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260938#comment-17260938 ] xx chai edited comment on FLINK-20870 at 1/8/21, 6:59 AM: -- !16

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Attachment: 1610089153(1).png > FlinkKafkaSink > -- > > Key: FLINK-20870 >

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Attachment: (was: 1610072517(1).jpg) > FlinkKafkaSink > -- > > Key: FLINK-

[jira] [Commented] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261055#comment-17261055 ] Jark Wu commented on FLINK-20832: - The website and documentation have been broken for a

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261054#comment-17261054 ] wangfei commented on FLINK-20885: - This is just a temporary solution for my production e

[jira] [Updated] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20885: Attachment: image-2021-01-08-14-53-40-476.png > Exception when use 'canal-json.table.include' to filter Ca

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261052#comment-17261052 ] wangfei commented on FLINK-20885: - !image-2021-01-08-14-53-40-476.png! > Exception when

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261051#comment-17261051 ] wangfei commented on FLINK-20885: - !image-2021-01-08-14-52-53-443.png! > Exception when

[jira] [Updated] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20885: Attachment: image-2021-01-08-14-52-53-443.png > Exception when use 'canal-json.table.include' to filter Ca

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261050#comment-17261050 ] wangfei commented on FLINK-20885: - I have modified the code locally to fix this bug, and

[jira] [Updated] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20832: Description: The typesetting of the official website is abnormal. The typesetting seen by users in China

[jira] [Updated] (FLINK-20832) flink.apache.org site Typography exception

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20832: Attachment: screenshot-1.png > flink.apache.org site Typography exception > --

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 2242b5369d48f75ae126f3a9bbaf814bb12ac4ed UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 61ab76b08a6b4603d6f9dd554bddd742a8d6fde9 UNKNOWN * dc919c934588343a3a4cbfb55e75f0f7fe325a58 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Assigned] (FLINK-20883) Separate the implementation of BatchExecOverAggregate and StreamExecOverAggregate

2021-01-07 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20883: -- Assignee: godfrey he > Separate the implementation of BatchExecOverAggregate and > StreamExe

[GitHub] [flink] xintongsong commented on pull request #14576: [FLINK-20860][core][config] Separate managed memory consumer `DATAPROC` into `OPERATOR` and `STATE_BACKEND`

2021-01-07 Thread GitBox
xintongsong commented on pull request #14576: URL: https://github.com/apache/flink/pull/14576#issuecomment-756579227 cc @wuchong @KarmaGYZ This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] xuewang commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
xuewang commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-756578256 Done. @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Closed] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2021-01-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20488. -- Fix Version/s: 1.13.0 Resolution: Fixed merged commit 0abbee9 > Show checkpoint type i

[jira] [Assigned] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2021-01-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-20488: -- Assignee: Yuan Mei > Show checkpoint type in the UI (AC/UC) for each subtask > --

[GitHub] [flink] pnowojski merged pull request #14546: [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI…

2021-01-07 Thread GitBox
pnowojski merged pull request #14546: URL: https://github.com/apache/flink/pull/14546 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #14576: [FLINK-20860][core][config] Separate managed memory consumer `DATAPROC` into `OPERATOR` and `STATE_BACKEND`

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14576: URL: https://github.com/apache/flink/pull/14576#issuecomment-756025393 ## CI report: * 41aefdaf57426e046e2e08d89d31bfd6fa4a93d1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-754563038 ## CI report: * a4504bda6bf4e1b38aefb248bc8355bc7864f496 UNKNOWN * 428ee6ca325943b56fe944c455f0d67f2ce3f94b Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] wuchong commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
wuchong commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-756573959 Just return, this should be the same to `DebeziumJsonDeserializationSchema#deserialize`. This is an automated

[GitHub] [flink] xuewang edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
xuewang edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-756572321 > @xuewang Could you also fix `CanalJsonDeserializationSchema`? Sure! @wuchong, could you elaborate what should be the expected behavior of `CanalJsonDeserializatio

[GitHub] [flink] xuewang commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
xuewang commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-756572321 > @xuewang Could you also fix `CanalJsonDeserializationSchema`? Sure! Could you elaborate what should be the expected behavior of `CanalJsonDeserializationSchema` when des

[jira] [Issue Comment Deleted] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangfei updated FLINK-20885: Comment: was deleted (was: [~jark] I've modified and tested it, but don't know how to participate in the

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261031#comment-17261031 ] wangfei commented on FLINK-20885: - [~jark] I've modified and tested it, but don't know h

[GitHub] [flink] flinkbot edited a comment on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-754563038 ## CI report: * a4504bda6bf4e1b38aefb248bc8355bc7864f496 UNKNOWN * 428ee6ca325943b56fe944c455f0d67f2ce3f94b Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20791) Support local aggregate push down for Blink batch planner

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20791: Description: Aggregate operator of Flink SQL is currently fully done at Flink layer. With the developing

[GitHub] [flink] KarmaGYZ commented on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

2021-01-07 Thread GitBox
KarmaGYZ commented on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-756555948 PR updated. This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] xintongsong commented on a change in pull request #14560: [FLINK-20837] Refactor dynamic SlotID

2021-01-07 Thread GitBox
xintongsong commented on a change in pull request #14560: URL: https://github.com/apache/flink/pull/14560#discussion_r553743795 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImplTest.java ## @@ -115,11 +115,11 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14572: URL: https://github.com/apache/flink/pull/14572#issuecomment-755910110 ## CI report: * 5f2c9f1f5ae08d469519ceea65208fd30d113866 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260988#comment-17260988 ] wangfei commented on FLINK-20885: - [~jark] I'm using Flink Master based compilation, pro

[jira] [Assigned] (FLINK-20791) Support local aggregate push down for Blink batch planner

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20791: --- Assignee: Sebastian Liu > Support local aggregate push down for Blink batch planner > -

[GitHub] [flink] wuchong commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2021-01-07 Thread GitBox
wuchong commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-756538216 @xuewang Could you also fix `CanalJsonDeserializationSchema`? This is an automated message from the Apache Git S

[GitHub] [flink] flinkbot edited a comment on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14572: URL: https://github.com/apache/flink/pull/14572#issuecomment-755910110 ## CI report: * 5f2c9f1f5ae08d469519ceea65208fd30d113866 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260980#comment-17260980 ] Jark Wu commented on FLINK-20885: - [~wangfeiair2324] What Flink version are you using?

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260981#comment-17260981 ] Jark Wu commented on FLINK-20885: - Hi [~nicholasjiang] are you interested in this? > E

[jira] [Closed] (FLINK-20773) Support to parse unescaped control chars in string node

2021-01-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20773. --- Resolution: Fixed Fixed in master: 51ec88bd01f5157c154fe49163ec0920f0e44663 > Support to parse unescaped co

[GitHub] [flink] wuchong merged pull request #14508: [FLINK-20773][json] Support to parse unescaped control chars in string node

2021-01-07 Thread GitBox
wuchong merged pull request #14508: URL: https://github.com/apache/flink/pull/14508 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

2021-01-07 Thread GitBox
wuchong commented on pull request #14572: URL: https://github.com/apache/flink/pull/14572#issuecomment-756534506 Thanks for the review @JingsongLi . I have addressed the comments. This is an automated message from the Apache

[GitHub] [flink] zhuzhurk commented on pull request #14579: [FLINK-20619] Removed InputDependencyConstraint

2021-01-07 Thread GitBox
zhuzhurk commented on pull request #14579: URL: https://github.com/apache/flink/pull/14579#issuecomment-756533725 There is a test failure in python module. "FAILED pyflink/common/tests/test_execution_config.py::ExecutionConfigTests::test_get_set_default_input_dependency_constraint"

[GitHub] [flink] flinkbot edited a comment on pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14574: URL: https://github.com/apache/flink/pull/14574#issuecomment-755961123 ## CI report: * 0c081c035965120267e8f86570fa8e7b43ee234d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangyang0918 commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-07 Thread GitBox
wangyang0918 commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-756529695 I think maybe you have delete the old forked repository of this PR. Currently it is on an unknown repository. I am not sure whether you could fix it[1]. If not, let's move

[GitHub] [flink] flinkbot edited a comment on pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14574: URL: https://github.com/apache/flink/pull/14574#issuecomment-755961123 ## CI report: * 0c081c035965120267e8f86570fa8e7b43ee234d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] godfreyhe commented on a change in pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-07 Thread GitBox
godfreyhe commented on a change in pull request #14516: URL: https://github.com/apache/flink/pull/14516#discussion_r553721508 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashJoin.java ## @@ -0,

[GitHub] [flink] godfreyhe commented on a change in pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-07 Thread GitBox
godfreyhe commented on a change in pull request #14516: URL: https://github.com/apache/flink/pull/14516#discussion_r553721184 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortMergeJoin.java ## @

[GitHub] [flink] godfreyhe commented on a change in pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
godfreyhe commented on a change in pull request #14574: URL: https://github.com/apache/flink/pull/14574#discussion_r553719064 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashWindowAggregate.java ##

[GitHub] [flink] godfreyhe commented on a change in pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
godfreyhe commented on a change in pull request #14574: URL: https://github.com/apache/flink/pull/14574#discussion_r553719036 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashWindowAggregate.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14574: URL: https://github.com/apache/flink/pull/14574#issuecomment-755961123 ## CI report: * 0c081c035965120267e8f86570fa8e7b43ee234d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * b87220ccdee330380bc015427b9f4b445173e324 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2021-01-07 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260957#comment-17260957 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], could the [FLINK-20867

[GitHub] [flink] haydenzhourepo closed pull request #14554: [FLINK-20798] add kubernates config in ha doc

2021-01-07 Thread GitBox
haydenzhourepo closed pull request #14554: URL: https://github.com/apache/flink/pull/14554 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

[GitHub] [flink] haydenzhourepo commented on pull request #14554: [FLINK-20798] add kubernates config in ha doc

2021-01-07 Thread GitBox
haydenzhourepo commented on pull request #14554: URL: https://github.com/apache/flink/pull/14554#issuecomment-756514771 yes as described by Yang Wang this is a bug. I'll close this PR This is an automated message from the Apa

[GitHub] [flink] JingsongLi commented on a change in pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

2021-01-07 Thread GitBox
JingsongLi commented on a change in pull request #14572: URL: https://github.com/apache/flink/pull/14572#discussion_r553706628 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/BinaryRowDataSerializer.java ## @@ -197,6 +

[GitHub] [flink] flinkbot edited a comment on pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14574: URL: https://github.com/apache/flink/pull/14574#issuecomment-755961123 ## CI report: * 0c081c035965120267e8f86570fa8e7b43ee234d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * b87220ccdee330380bc015427b9f4b445173e324 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20893) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel test failed with "TestTimedOutException"

2021-01-07 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20893: Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel test failed with "TestTimedOutException" Key: FLINK-20893 URL: https://issues.apache.or

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-07 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260946#comment-17260946 ] wangfei commented on FLINK-20885: - [~jark] When is this expected to be fixed  > Excepti

[jira] [Commented] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

2021-01-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260944#comment-17260944 ] Huang Xingbo commented on FLINK-17441: -- another instance in 1.13 [https://dev.azur

[jira] [Closed] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-20872. Resolution: Won't Do > Job resume from history savepoint when failover if checkpoint is disabled > ---

[jira] [Updated] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

2021-01-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17441: - Affects Version/s: 1.13.0 > FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expe

[jira] [Commented] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260942#comment-17260942 ] Yun Tang commented on FLINK-20872: -- As we all know, savepoint/checkpoint is used for fa

[GitHub] [flink] wenlong88 commented on a change in pull request #14574: [FLINK-20857][table-planner-blink] Separate the implementation of batch window aggregate nodes

2021-01-07 Thread GitBox
wenlong88 commented on a change in pull request #14574: URL: https://github.com/apache/flink/pull/14574#discussion_r553703162 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashWindowAggregate.java ##

[jira] [Commented] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260939#comment-17260939 ] xx chai commented on FLINK-20870: - this is my program > FlinkKafkaSink > -

[jira] [Commented] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260938#comment-17260938 ] xx chai commented on FLINK-20870: - !1610072517(1).jpg! > FlinkKafkaSink > ---

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Attachment: 1610072517(1).jpg > FlinkKafkaSink > -- > > Key: FLINK-20870 >

[GitHub] [flink] flinkbot edited a comment on pull request #14576: [FLINK-20860][core][config] Separate managed memory consumer `DATAPROC` into `OPERATOR` and `STATE_BACKEND`

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14576: URL: https://github.com/apache/flink/pull/14576#issuecomment-756025393 ## CI report: * 5d56eacea0f401a4a3e9eff05eede70170cc186d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-07 Thread GitBox
flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * b87220ccdee330380bc015427b9f4b445173e324 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   >