[jira] [Closed] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18776. --- Resolution: Fixed Fixed via 34f63be897bf328cbef79051a934328b0b383ab7 > "compile_cron_scala212" failed to co

[jira] [Commented] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168441#comment-17168441 ] Dian Fu commented on FLINK-16945: - [~SleePy] OK. Thanks a lot for the work! > Execute C

[jira] [Commented] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

2020-07-30 Thread Biao Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168439#comment-17168439 ] Biao Liu commented on FLINK-16945: -- [~dian.fu], yes, I'm working on this. It depends on

[GitHub] [flink] dianfu closed pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
dianfu closed pull request #13032: URL: https://github.com/apache/flink/pull/13032 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 3d89fc037c6cf7b1dfe19514ff831af4a4d33b50 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

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

[jira] [Commented] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168428#comment-17168428 ] Dian Fu commented on FLINK-16945: - It seems that there is no follow-up after we revert t

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * f80ff802ee1f126a58b1617ab4ca82c3f1a40ba8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168424#comment-17168424 ] Dian Fu commented on FLINK-15611: - Should we close this ticket as it seems that it doesn

[jira] [Comment Edited] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168424#comment-17168424 ] Dian Fu edited comment on FLINK-15611 at 7/31/20, 6:22 AM: --- Sh

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * f80ff802ee1f126a58b1617ab4ca82c3f1a40ba8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13033: [FLINK-18777][catalog] Supports schema registry catalog

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

[GitHub] [flink] flinkbot edited a comment on pull request #13034: [FLINK-9992][tests] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13034: URL: https://github.com/apache/flink/pull/13034#issuecomment-666932731 ## CI report: * f9f773fd1a15b875596ab294ca90db912b2dd2c0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-07-30 Thread tao wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168415#comment-17168415 ] tao wang edited comment on FLINK-18748 at 7/31/20, 5:41 AM:

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-07-30 Thread tao wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168415#comment-17168415 ] tao wang commented on FLINK-18748: -- [~klion26] Ok, I have read the doc, thanks. I have

[GitHub] [flink] flinkbot commented on pull request #13034: [FLINK-9992][tests] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path

2020-07-30 Thread GitBox
flinkbot commented on pull request #13034: URL: https://github.com/apache/flink/pull/13034#issuecomment-666932731 ## CI report: * f9f773fd1a15b875596ab294ca90db912b2dd2c0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-07-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18756: Priority: Critical (was: Blocker) > Support IF NOT EXISTS for CREATE TABLE statement > --

[GitHub] [flink] flinkbot edited a comment on pull request #13033: [FLINK-18777][catalog] Supports schema registry catalog

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13033: URL: https://github.com/apache/flink/pull/13033#issuecomment-666927378 ## CI report: * f40e57384a1aff20df20d9163b536593970d9615 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-18779) Support the SupportsFilterPushDown interface for ScanTableSource.

2020-07-30 Thread Jark Wu (Jira)
Jark Wu created FLINK-18779: --- Summary: Support the SupportsFilterPushDown interface for ScanTableSource. Key: FLINK-18779 URL: https://issues.apache.org/jira/browse/FLINK-18779 Project: Flink Issu

[jira] [Commented] (FLINK-16993) Support SupportsComputedColumnPushDown in planner

2020-07-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168409#comment-17168409 ] Jark Wu commented on FLINK-16993: - Hi [~jackylau], what about to do FLINK-18778 or FLINK

[jira] [Created] (FLINK-18778) Support the SupportsProjectionPushDown interface for LookupTableSource

2020-07-30 Thread Jark Wu (Jira)
Jark Wu created FLINK-18778: --- Summary: Support the SupportsProjectionPushDown interface for LookupTableSource Key: FLINK-18778 URL: https://issues.apache.org/jira/browse/FLINK-18778 Project: Flink

[GitHub] [flink] klion26 commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-07-30 Thread GitBox
klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r463409277 ## File path: docs/learn-flink/streaming_analytics.zh.md ## @@ -425,37 +366,31 @@ stream .reduce() {% endhighlight %} -You might expect Flink's ru

[jira] [Assigned] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-07-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18756: --- Assignee: Leonard Xu (was: Jark Wu) > Support IF NOT EXISTS for CREATE TABLE statement > -

[jira] [Assigned] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-07-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18756: --- Assignee: Jark Wu > Support IF NOT EXISTS for CREATE TABLE statement >

[jira] [Comment Edited] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168378#comment-17168378 ] Dian Fu edited comment on FLINK-9992 at 7/31/20, 5:19 AM: -- It se

[GitHub] [flink] flinkbot commented on pull request #13034: [FLINK-9992][tests] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path

2020-07-30 Thread GitBox
flinkbot commented on pull request #13034: URL: https://github.com/apache/flink/pull/13034#issuecomment-666928462 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

[jira] [Commented] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168403#comment-17168403 ] Dian Fu commented on FLINK-9992: Have submitted a PR by introducing retries when generati

[jira] [Updated] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI

2020-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9992: -- Labels: pull-request-available test-stability (was: test-stability) > FsStorageLocationReferen

[GitHub] [flink] dianfu opened a new pull request #13034: [FLINK-9992] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path

2020-07-30 Thread GitBox
dianfu opened a new pull request #13034: URL: https://github.com/apache/flink/pull/13034 ## What is the purpose of the change *Not all the characters could be used in the hostname: https://stackoverflow.com/questions/28568188/java-net-uri-get-host-with-underscores. For example,

[GitHub] [flink] flinkbot commented on pull request #13033: [FLINK-18777][catalog] Supports schema registry catalog

2020-07-30 Thread GitBox
flinkbot commented on pull request #13033: URL: https://github.com/apache/flink/pull/13033#issuecomment-666927378 ## CI report: * f40e57384a1aff20df20d9163b536593970d9615 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * f80ff802ee1f126a58b1617ab4ca82c3f1a40ba8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #13033: [FLINK-18777][catalog] Supports schema registry catalog

2020-07-30 Thread GitBox
flinkbot commented on pull request #13033: URL: https://github.com/apache/flink/pull/13033#issuecomment-666923544 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] danny0405 commented on a change in pull request #13033: [FLINK-18777][catalog] Supports schema registry catalog

2020-07-30 Thread GitBox
danny0405 commented on a change in pull request #13033: URL: https://github.com/apache/flink/pull/13033#discussion_r463406589 ## File path: flink-formats/flink-avro-confluent-registry/pom.xml ## @@ -33,7 +33,7 @@ under the License. 2.4.1 -

[jira] [Updated] (FLINK-18777) Supports schema registry catalog

2020-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18777: --- Labels: pull-request-available (was: ) > Supports schema registry catalog > ---

[GitHub] [flink] danny0405 opened a new pull request #13033: [FLINK-18777][catalog] Supports schema registry catalog

2020-07-30 Thread GitBox
danny0405 opened a new pull request #13033: URL: https://github.com/apache/flink/pull/13033 ## What is the purpose of the change Supports a catalog that can read the kafka topics flexibly. The demo code: ```java String schemaRegistryURL = ...; Map kafkaProp

[jira] [Created] (FLINK-18777) Supports schema registry catalog

2020-07-30 Thread Danny Chen (Jira)
Danny Chen created FLINK-18777: -- Summary: Supports schema registry catalog Key: FLINK-18777 URL: https://issues.apache.org/jira/browse/FLINK-18777 Project: Flink Issue Type: Bug Compon

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * f80ff802ee1f126a58b1617ab4ca82c3f1a40ba8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168378#comment-17168378 ] Dian Fu edited comment on FLINK-9992 at 7/31/20, 4:55 AM: -- It se

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 3d89fc037c6cf7b1dfe19514ff831af4a4d33b50 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-30 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168391#comment-17168391 ] Zhijiang edited comment on FLINK-18695 at 7/31/20, 4:40 AM:

[jira] [Assigned] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-30 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18695: Assignee: Yun Gao > Allow NettyBufferPool to allocate heap buffers >

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-30 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168391#comment-17168391 ] Zhijiang commented on FLINK-18695: -- {quot} How problematic would it be to backport this

[GitHub] [flink] flinkbot edited a comment on pull request #13005: Feature/flink 18661 efo de registration

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

[jira] [Commented] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168378#comment-17168378 ] Dian Fu commented on FLINK-9992: It seems that not all the characters could be used in th

[GitHub] [flink] flinkbot edited a comment on pull request #13005: Feature/flink 18661 efo de registration

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

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * f80ff802ee1f126a58b1617ab4ca82c3f1a40ba8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yumeng Zhang updated FLINK-18706: - Component/s: Runtime / Checkpointing > Stop with savepoint cannot guarantee exactly-once for kaf

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * f80ff802ee1f126a58b1617ab4ca82c3f1a40ba8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463386948 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutStreamInf

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463386867 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutStreamInf

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463386695 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutStreamInf

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463385790 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutStreamInf

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463385433 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutStreamInf

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463385345 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPub

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463385236 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2.java ## @@ -2

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463385155 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2.java ## @@ -2

[GitHub] [flink] dianfu commented on pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
dianfu commented on pull request #13032: URL: https://github.com/apache/flink/pull/13032#issuecomment-666891397 Thanks @danny0405 for the review. Will merge the PR after the test turns green. This is an automated message fro

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463385042 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2.java ## @@ -2

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463384942 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2.java ## @@ -2

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463384576 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AwsV2Util.java ## @@ -248,4 +

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13005: Feature/flink 18661 efo de registration

2020-07-30 Thread GitBox
xiaolong-sn commented on a change in pull request #13005: URL: https://github.com/apache/flink/pull/13005#discussion_r463384647 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2.java ## @@ -2

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-07-30 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168357#comment-17168357 ] Congxian Qiu(klion26) commented on FLINK-18748: --- [~roman_khachatryan] coul

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13032: URL: https://github.com/apache/flink/pull/13032#issuecomment-666883718 ## CI report: * bdc1a20863e3d0b9044894d07b763de569d4fa1a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * 4c7e79256616e62e216b5c87f0cfff6896b32287 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
flinkbot commented on pull request #13032: URL: https://github.com/apache/flink/pull/13032#issuecomment-666883718 ## CI report: * bdc1a20863e3d0b9044894d07b763de569d4fa1a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 2cb0d813bfc779b913096c3cd6e646ac2d4f64e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
flinkbot commented on pull request #13032: URL: https://github.com/apache/flink/pull/13032#issuecomment-666881872 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] dianfu commented on pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
dianfu commented on pull request #13032: URL: https://github.com/apache/flink/pull/13032#issuecomment-666881431 cc @danny0405 Could you help take a look at this PR? This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18776: --- Labels: pull-request-available test-stability (was: test-stability) > "compile_cron_scala21

[jira] [Comment Edited] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168343#comment-17168343 ] Yumeng Zhang edited comment on FLINK-18706 at 7/31/20, 2:41 AM: --

[jira] [Comment Edited] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168343#comment-17168343 ] Yumeng Zhang edited comment on FLINK-18706 at 7/31/20, 2:40 AM: --

[GitHub] [flink] dianfu opened a new pull request #13032: [FLINK-18776][avro] Avoid hardcoded scala version

2020-07-30 Thread GitBox
dianfu opened a new pull request #13032: URL: https://github.com/apache/flink/pull/13032 ## What is the purpose of the change *This pull request fixed the hardcoded scala version in the module of flink-avro-confluent-registry* ## Verifying this change This change is a t

[jira] [Assigned] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18776: --- Assignee: Dian Fu > "compile_cron_scala212" failed to compile > ---

[jira] [Comment Edited] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168343#comment-17168343 ] Yumeng Zhang edited comment on FLINK-18706 at 7/31/20, 2:37 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 2cb0d813bfc779b913096c3cd6e646ac2d4f64e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Thesharing commented on a change in pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
Thesharing commented on a change in pull request #12917: URL: https://github.com/apache/flink/pull/12917#discussion_r462896285 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImplTest.java ## @@ -0,0 +1,155 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-16993) Support SupportsComputedColumnPushDown in planner

2020-07-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168344#comment-17168344 ] jackylau commented on FLINK-16993: -- Hi [~jark]  Could it also assign to me? > Support

[GitHub] [flink-web] sunjincheng121 commented on pull request #364: Add blog post for Pandas support in PyFlink.

2020-07-30 Thread GitBox
sunjincheng121 commented on pull request #364: URL: https://github.com/apache/flink-web/pull/364#issuecomment-666877830 > Ah! I was trying it out in PyCharm! 🐍 Maybe we could add an annotation that makes that clear, then? In case someone also does it elsewhere. We can add more an

[jira] [Comment Edited] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168343#comment-17168343 ] Yumeng Zhang edited comment on FLINK-18706 at 7/31/20, 2:28 AM: --

[jira] [Comment Edited] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168343#comment-17168343 ] Yumeng Zhang edited comment on FLINK-18706 at 7/31/20, 2:27 AM: --

[jira] [Commented] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Yumeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168343#comment-17168343 ] Yumeng Zhang commented on FLINK-18706: -- Kostas Kloudas Yes, I see. But this exactly

[jira] [Updated] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18776: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > "compile_cron_scala212" failed to compile

[jira] [Updated] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18776: Priority: Blocker (was: Critical) > "compile_cron_scala212" failed to compile > -

[GitHub] [flink] Thesharing commented on a change in pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
Thesharing commented on a change in pull request #12917: URL: https://github.com/apache/flink/pull/12917#discussion_r462825355 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/TestingSlotPoolImpl.java ## @@ -83,4 +93,52 @@ boolean isBatchSl

[jira] [Updated] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18776: Labels: test-stability (was: ) > "compile_cron_scala212" failed to compile >

[jira] [Updated] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18776: Priority: Critical (was: Major) > "compile_cron_scala212" failed to compile > ---

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 2cb0d813bfc779b913096c3cd6e646ac2d4f64e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168337#comment-17168337 ] Dian Fu commented on FLINK-18776: - I think it should be caused by commit: https://githu

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * 4c7e79256616e62e216b5c87f0cfff6896b32287 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] Thesharing edited a comment on pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect

2020-07-30 Thread GitBox
Thesharing edited a comment on pull request #12038: URL: https://github.com/apache/flink/pull/12038#issuecomment-666282343 Hi, Mr. Pompermaier! Recently I'm focusing on the progress of SQL Server connector. I'm wondering how's the progress going? Do you need any assistance? --

[jira] [Commented] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]"

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168335#comment-17168335 ] Dian Fu commented on FLINK-18771: - Thanks [~kkl0u], the problem should have been address

[jira] [Comment Edited] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168332#comment-17168332 ] Dian Fu edited comment on FLINK-18776 at 7/31/20, 2:08 AM: --- e2

[jira] [Commented] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168332#comment-17168332 ] Dian Fu commented on FLINK-18776: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Created] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-18776: --- Summary: "compile_cron_scala212" failed to compile Key: FLINK-18776 URL: https://issues.apache.org/jira/browse/FLINK-18776 Project: Flink Issue Type: Bug Affects V

[jira] [Updated] (FLINK-18776) "compile_cron_scala212" failed to compile

2020-07-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18776: Component/s: Tests > "compile_cron_scala212" failed to compile > -

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-30 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * 4c7e79256616e62e216b5c87f0cfff6896b32287 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

2020-07-30 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18775: Description: Since the release of Flink 1.11, users of PyFlink have continued to grow. According

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

2020-07-30 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18775: Description: Since the release of Flink 1.11, users of PyFlink have continued to grow. According

  1   2   3   4   >