[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 21ff7c2a63f297e124f6040a72991c8438fa95af Azure:

[GitHub] [flink] fsk119 commented on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-15 Thread GitBox
fsk119 commented on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-659150149 @wuchong CC This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 5eb302884e390b6099859abcd7955e7f1c4e034e Azure:

[jira] [Updated] (FLINK-18611) Include `m` as time unit expression for MINUTE in SQL

2020-07-15 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Q Kang updated FLINK-18611: --- Description: According to the documentation of FileSystem SQL Connector, if we try to create a table with

[jira] [Updated] (FLINK-18611) Include `m` as time unit expression for MINUTE in SQL

2020-07-15 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Q Kang updated FLINK-18611: --- Description: According to the documentation of FileSystem SQL Connector, if we try to create a table with

[jira] [Created] (FLINK-18611) Include `m` as time unit expression for MINUTE in SQL

2020-07-15 Thread Q Kang (Jira)
Q Kang created FLINK-18611: -- Summary: Include `m` as time unit expression for MINUTE in SQL Key: FLINK-18611 URL: https://issues.apache.org/jira/browse/FLINK-18611 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 5eb302884e390b6099859abcd7955e7f1c4e034e Azure:

[GitHub] [flink] pyscala commented on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
pyscala commented on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-659135862 > Thanks @pyscala for your contribution. Changes looks good to me overall. But I want to hear from @zentol Thanks @JingsongLi for your reply.

[GitHub] [flink] JingsongLi commented on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
JingsongLi commented on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-659134691 Thanks @pyscala for your contribution. Changes looks good to me overall. But I want to hear from @zentol

[jira] [Assigned] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17789: Assignee: liufangliang > DelegatingConfiguration should remove prefix instead of add

[GitHub] [flink] RocMarshal commented on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

2020-07-15 Thread GitBox
RocMarshal commented on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-659134008 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #12873: [FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12873: URL: https://github.com/apache/flink/pull/12873#issuecomment-656741832 ## CI report: * 24c77b9c54d326b4f6b51a716669df85d6f59a3f Azure:

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-07-15 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158859#comment-17158859 ] liufangliang commented on FLINK-17789: -- Hi [~lzljs3620320] [~chesnay] , Sorry for my irregular

[GitHub] [flink] pyscala commented on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
pyscala commented on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-659118815 Hi @zentol , Thanks for your commits. Can you review this PR for us ? This is an automated message from the

[jira] [Commented] (FLINK-17627) Add support for writing _SUCCESS file with StreamingFileSink

2020-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158845#comment-17158845 ] Jingsong Lee commented on FLINK-17627: -- Hi [~qqibrow], we only support in table/sql level, no API

[GitHub] [flink] flinkbot edited a comment on pull request #12873: [FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12873: URL: https://github.com/apache/flink/pull/12873#issuecomment-656741832 ## CI report: * d348328658445fbc11b8a310f8f0fbd163acf308 Azure:

[jira] [Commented] (FLINK-18594) The link is broken in kafka doc

2020-07-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158844#comment-17158844 ] Dian Fu commented on FLINK-18594: - follow-up fix: 3a7906e9729fa7bf84020502c339c1f76c34f7be > The link

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158843#comment-17158843 ] Jingsong Lee commented on FLINK-17789: -- [~chesnay] I see what you mean. Hi [~liufangliang], for

[jira] [Comment Edited] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158843#comment-17158843 ] Jingsong Lee edited comment on FLINK-17789 at 7/16/20, 2:16 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #12873: [FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12873: URL: https://github.com/apache/flink/pull/12873#issuecomment-656741832 ## CI report: * d348328658445fbc11b8a310f8f0fbd163acf308 Azure:

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2020-07-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158763#comment-17158763 ] Zhenqiu Huang commented on FLINK-14055: --- [~phoenixjiangnan] [~twalthr] I am going to add this

[jira] [Commented] (FLINK-17627) Add support for writing _SUCCESS file with StreamingFileSink

2020-07-15 Thread Lu Niu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158704#comment-17158704 ] Lu Niu commented on FLINK-17627: [~lzljs3620320] We also want StreamingFileSink write _SUCCESS file. Is

[GitHub] [flink] flinkbot edited a comment on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * 150c361060b34a27151efa0654c693898d9372ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * e6d38893b79bcbd786e33592aa4b92f907376b6d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * e6d38893b79bcbd786e33592aa4b92f907376b6d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12909: [FLINK-18608] Fix null handling when converting CAST expression

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12909: URL: https://github.com/apache/flink/pull/12909#issuecomment-658859932 ## CI report: * 63c5517253d8a7a4197dd5ea1b5961b98bccb1f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * e6d38893b79bcbd786e33592aa4b92f907376b6d Azure:

[jira] [Created] (FLINK-18610) Clean up Table connector docs grammar

2020-07-15 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18610: Summary: Clean up Table connector docs grammar Key: FLINK-18610 URL: https://issues.apache.org/jira/browse/FLINK-18610 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-15 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158523#comment-17158523 ] Georg Heiler commented on FLINK-18478: -- [~aljoscha] can I also download a nightly jar snapshot

[jira] [Assigned] (FLINK-18606) Remove generic parameter from SinkFunction.Context

2020-07-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-18606: Assignee: Niels Basjes > Remove generic parameter from SinkFunction.Context >

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

2020-07-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158504#comment-17158504 ] Yun Gao commented on FLINK-10672: - Hi [~ibzib], very sorry to disturb,  do you have any updates from you

[GitHub] [flink] flinkbot commented on pull request #12909: [FLINK-18608] Fix null handling when converting CAST expression

2020-07-15 Thread GitBox
flinkbot commented on pull request #12909: URL: https://github.com/apache/flink/pull/12909#issuecomment-658859932 ## CI report: * 63c5517253d8a7a4197dd5ea1b5961b98bccb1f7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18607) Give the maven modules human readable names.

2020-07-15 Thread weizihan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158499#comment-17158499 ] weizihan commented on FLINK-18607: -- I like this idea 魏子涵 邮箱:wzh1007181...@163.com 签名由 网易邮箱大师 定制

[GitHub] [flink] wtog commented on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

2020-07-15 Thread GitBox
wtog commented on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-658855927 @lirui-apache Thanks for review. I`ve add test to `HiveDialectITCase` This is an automated message from the Apache

[GitHub] [flink] wtog edited a comment on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

2020-07-15 Thread GitBox
wtog edited a comment on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-658855927 @lirui-apache Thanks for review. I added test to `HiveDialectITCase` This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #12909: [FLINK-18608] Fix null handling when converting CAST expression

2020-07-15 Thread GitBox
flinkbot commented on pull request #12909: URL: https://github.com/apache/flink/pull/12909#issuecomment-658849221 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] dawidwys commented on pull request #12909: [FLINK-18608] Fix null handling when converting CAST expression

2020-07-15 Thread GitBox
dawidwys commented on pull request #12909: URL: https://github.com/apache/flink/pull/12909#issuecomment-658848167 Could you have a look @twalthr ? This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dawidwys commented on pull request #12909: [FLINK-18608] Fix null handling when converting CAST expression

2020-07-15 Thread GitBox
dawidwys commented on pull request #12909: URL: https://github.com/apache/flink/pull/12909#issuecomment-658848505 side note: I'd like to cherry-pick the test case into master branch later on. This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * c9e05d742e3c66f494399d67077a8bbac0538803 Azure:

[jira] [Updated] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18608: --- Labels: pull-request-available (was: ) > CustomizedConvertRule#convertCast drops

[GitHub] [flink] dawidwys opened a new pull request #12909: [FLINK-18608] Fix null handling when converting CAST expression

2020-07-15 Thread GitBox
dawidwys opened a new pull request #12909: URL: https://github.com/apache/flink/pull/12909 ## What is the purpose of the change Make the CAST preserve nullability when converting from Expression to RexCall. This has been done in master branch as part of

[jira] [Updated] (FLINK-18572) Flink web UI doesn't display checkpoint configs like unaligned and tolerable-failed-checkpoints and

2020-07-15 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18572: --- Summary: Flink web UI doesn't display checkpoint configs like unaligned and

[GitHub] [flink] flinkbot edited a comment on pull request #12904: [FLINK-18569][table] Support limit() for unordered tables

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12904: URL: https://github.com/apache/flink/pull/12904#issuecomment-658669745 ## CI report: * 40d048a077885f435381c372eab315a276908ad8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-657641584 ## CI report: * 499ff3390c0a93678db520293a475cd7a51c29e5 Azure:

[jira] [Updated] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-18608: --- Description: The following program shows that nullability is not respected during

[jira] [Updated] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

2020-07-15 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18599: - Component/s: (was: API / DataStream) API / Scala > Compile error

[jira] [Commented] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

2020-07-15 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158241#comment-17158241 ] Aljoscha Krettek commented on FLINK-18599: -- There is a quick in the Scala compiler which causes

[jira] [Closed] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

2020-07-15 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18599. Resolution: Not A Bug > Compile error when use windowAll and

[GitHub] [flink-web] sjwiesman merged pull request #360: Introducing the Application Mode blogpost.

2020-07-15 Thread GitBox
sjwiesman merged pull request #360: URL: https://github.com/apache/flink-web/pull/360 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] flinkbot edited a comment on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-658724114 ## CI report: * 09455c5c0c6bd961650e28994a30629e9269c679 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-657641584 ## CI report: * 9bd52062639bd1eacf94f88caa310cd60817599e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658771971 ## CI report: * 1a4e5ee2a2f11ba650a98c1a211cea75736fe79d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12904: [FLINK-18569][table] Support limit() for unordered tables

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12904: URL: https://github.com/apache/flink/pull/12904#issuecomment-658669745 ## CI report: * 4efba99139063f911fb977ad1d1ef8562fe982d3 Azure:

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-15 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158218#comment-17158218 ] Aljoscha Krettek commented on FLINK-18478: -- >From the log you posted in the gist it seems that

[GitHub] [flink] flinkbot edited a comment on pull request #12904: [FLINK-18569][table] Support limit() for unordered tables

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12904: URL: https://github.com/apache/flink/pull/12904#issuecomment-658669745 ## CI report: * 4efba99139063f911fb977ad1d1ef8562fe982d3 Azure:

[GitHub] [flink] aljoscha commented on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

2020-07-15 Thread GitBox
aljoscha commented on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-658793273 Ahh, this discussion now reminded me of this older issue: https://issues.apache.org/jira/browse/FLINK-11654. Can you ask Jiangjie Qin there if he's still working on the issue?

[GitHub] [flink] twalthr commented on pull request #12904: [FLINK-18569][table] Support limit() for unordered tables

2020-07-15 Thread GitBox
twalthr commented on pull request #12904: URL: https://github.com/apache/flink/pull/12904#issuecomment-658782850 Thanks @aljoscha and @KurtYoung. I hope I could address your feedback. I will merge this once the build is green.

[GitHub] [flink] flinkbot edited a comment on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658771971 ## CI report: * 1a4e5ee2a2f11ba650a98c1a211cea75736fe79d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-658724114 ## CI report: * 856e797c0ff602f2e6c7aeb89511218d5dfe2c14 Azure:

[GitHub] [flink] nielsbasjes commented on a change in pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
nielsbasjes commented on a change in pull request #12907: URL: https://github.com/apache/flink/pull/12907#discussion_r455066935 ## File path: flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml ## @@ -29,7 +29,7 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12907: URL: https://github.com/apache/flink/pull/12907#issuecomment-658734085 ## CI report: * bcd598e98411c31d577e8c1ee09c0468decd005a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-658724114 ## CI report: * 856e797c0ff602f2e6c7aeb89511218d5dfe2c14 Azure:

[GitHub] [flink] flinkbot commented on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-15 Thread GitBox
flinkbot commented on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658771971 ## CI report: * 1a4e5ee2a2f11ba650a98c1a211cea75736fe79d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-web] kl0u opened a new pull request #360: Introducing the Application Mode blogpost.

2020-07-15 Thread GitBox
kl0u opened a new pull request #360: URL: https://github.com/apache/flink-web/pull/360 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] flinkbot commented on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-15 Thread GitBox
flinkbot commented on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658758773 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-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18449: --- Labels: pull-request-available (was: ) > Make topic discovery and partition discovery

[GitHub] [flink] fsk119 opened a new pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-15 Thread GitBox
fsk119 opened a new pull request #12908: URL: https://github.com/apache/flink/pull/12908 …ry dynamically in table api ## What is the purpose of the change *Enable Kafka Connector topic discovery & partition discovery in table api.* ## Brief change log

[jira] [Created] (FLINK-18609) The user-defined jdbc-source process before add window ,job finished early.

2020-07-15 Thread ZHangTianLong (Jira)
ZHangTianLong created FLINK-18609: - Summary: The user-defined jdbc-source process before add window ,job finished early. Key: FLINK-18609 URL: https://issues.apache.org/jira/browse/FLINK-18609

[GitHub] [flink] KurtYoung commented on a change in pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
KurtYoung commented on a change in pull request #12907: URL: https://github.com/apache/flink/pull/12907#discussion_r455029781 ## File path: flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml ## @@ -29,7 +29,7 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12907: URL: https://github.com/apache/flink/pull/12907#issuecomment-658734085 ## CI report: * bcd598e98411c31d577e8c1ee09c0468decd005a Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault toler

2020-07-15 Thread GitBox
godfreyhe commented on a change in pull request #12867: URL: https://github.com/apache/flink/pull/12867#discussion_r454930701 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultIterator.java ## @@ -40,18 +43,37 @@

[jira] [Updated] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18608: - Priority: Blocker (was: Major) > CustomizedConvertRule#convertCast drops nullability >

[jira] [Updated] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18608: - Fix Version/s: 1.11.2 > CustomizedConvertRule#convertCast drops nullability >

[GitHub] [flink] flinkbot commented on pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
flinkbot commented on pull request #12907: URL: https://github.com/apache/flink/pull/12907#issuecomment-658734085 ## CI report: * bcd598e98411c31d577e8c1ee09c0468decd005a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-658724114 ## CI report: * 856e797c0ff602f2e6c7aeb89511218d5dfe2c14 Azure:

[GitHub] [flink] flinkbot commented on pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
flinkbot commented on pull request #12907: URL: https://github.com/apache/flink/pull/12907#issuecomment-658731246 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] [Created] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-18608: -- Summary: CustomizedConvertRule#convertCast drops nullability Key: FLINK-18608 URL: https://issues.apache.org/jira/browse/FLINK-18608 Project: Flink

[GitHub] [flink] nielsbasjes commented on pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
nielsbasjes commented on pull request #12907: URL: https://github.com/apache/flink/pull/12907#issuecomment-658728948 Note that all 'pom' modules have a name that ends with `:` because that makes the ordering in the Maven overview in IntelliJ better. Also note that the naming

[GitHub] [flink] nielsbasjes edited a comment on pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
nielsbasjes edited a comment on pull request #12907: URL: https://github.com/apache/flink/pull/12907#issuecomment-658728948 Note that all `pom` modules have a name that ends with `:` because that makes the ordering in the Maven overview in IntelliJ better. Also note that the

[jira] [Updated] (FLINK-18607) Give the maven modules human readable names.

2020-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18607: --- Labels: pull-request-available (was: ) > Give the maven modules human readable names. >

[GitHub] [flink] nielsbasjes opened a new pull request #12907: [FLINK-18607][build] Give the maven module a human readable name

2020-07-15 Thread GitBox
nielsbasjes opened a new pull request #12907: URL: https://github.com/apache/flink/pull/12907 ## What is the purpose of the change Make the build output more human readable for the developers van various situations. ## Brief change log Add or change the `` of each

[jira] [Commented] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158102#comment-17158102 ] Dawid Wysakowicz commented on FLINK-18600: -- Disabled temporarily affected tests * master: **

[GitHub] [flink] flinkbot edited a comment on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * c9e05d742e3c66f494399d67077a8bbac0538803 Azure:

[GitHub] [flink] flinkbot commented on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
flinkbot commented on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-658724114 ## CI report: * 856e797c0ff602f2e6c7aeb89511218d5dfe2c14 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12827: URL: https://github.com/apache/flink/pull/12827#issuecomment-654120002 ## CI report: * 0f39d59075500b5bed9817cc82fc9bf2e097385d Azure:

[jira] [Assigned] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-07-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18602: --- Assignee: Shengkai Fang > Support specific offset for topic list for kafka connector in table api

[jira] [Commented] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-07-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158098#comment-17158098 ] Jark Wu commented on FLINK-18449: - +1 to 'scan.topic-partition-discovery.interval' > Make topic

[GitHub] [flink] flinkbot commented on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
flinkbot commented on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-658715776 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-18606) Remove generic parameter from SinkFunction.Context

2020-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18606: --- Labels: pull-request-available (was: ) > Remove generic parameter from

[GitHub] [flink] flinkbot commented on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot commented on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658715358 ## CI report: * c9e05d742e3c66f494399d67077a8bbac0538803 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] nielsbasjes opened a new pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-15 Thread GitBox
nielsbasjes opened a new pull request #12906: URL: https://github.com/apache/flink/pull/12906 ## What is the purpose of the change The SinkFunction.Context has an unused generic parameter which causes needless warnings in many places. ## Brief change log Remove the

[GitHub] [flink] pyscala commented on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
pyscala commented on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658712259 Hi @JingsongLi , Looking forward to your review, thanks. This is an automated message from the Apache Git

[GitHub] [flink] rkhachatryan commented on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

2020-07-15 Thread GitBox
rkhachatryan commented on pull request #12827: URL: https://github.com/apache/flink/pull/12827#issuecomment-658711550 No, > CI build failure unrelated: https://issues.apache.org/jira/browse/FLINK-18485 (2nd build is PENDING at the moment)

[GitHub] [flink] flinkbot edited a comment on pull request #12904: [FLINK-18569][table] Support limit() for unordered tables

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12904: URL: https://github.com/apache/flink/pull/12904#issuecomment-658669745 ## CI report: * 4efba99139063f911fb977ad1d1ef8562fe982d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

2020-07-15 Thread GitBox
flinkbot edited a comment on pull request #12827: URL: https://github.com/apache/flink/pull/12827#issuecomment-654120002 ## CI report: * a47aa124dba8c4badae4567bb78cbc92d4ef072f Azure:

[GitHub] [flink] flinkbot commented on pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
flinkbot commented on pull request #12905: URL: https://github.com/apache/flink/pull/12905#issuecomment-658707054 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-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17789: --- Labels: pull-request-available (was: ) > DelegatingConfiguration should remove prefix

[jira] [Created] (FLINK-18607) Give the maven modules human readable names.

2020-07-15 Thread Niels Basjes (Jira)
Niels Basjes created FLINK-18607: Summary: Give the maven modules human readable names. Key: FLINK-18607 URL: https://issues.apache.org/jira/browse/FLINK-18607 Project: Flink Issue Type:

[GitHub] [flink] pyscala opened a new pull request #12905: [FLINK-17789][API/Core] DelegatingConfiguration should remove prefix …

2020-07-15 Thread GitBox
pyscala opened a new pull request #12905: URL: https://github.com/apache/flink/pull/12905 ## What is the purpose of the change 1.DelegatingConfiguration should remove prefix instead of add prefix in toMap 2.Make `toMap` consistent with `addAllToProperties` in class

[jira] [Commented] (FLINK-18606) Remove generic parameter from SinkFunction.Context

2020-07-15 Thread Niels Basjes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158074#comment-17158074 ] Niels Basjes commented on FLINK-18606: -- The impact seems very limited. I expect normal user

  1   2   >