[GitHub] [flink] dianfu commented on a change in pull request #12841: [FLINK-18490][python] Extract the implementation logic of Beam in AbstractPythonFunctionOperator

2020-07-08 Thread GitBox
dianfu commented on a change in pull request #12841: URL: https://github.com/apache/flink/pull/12841#discussion_r451938393 ## File path: flink-python/src/main/java/org/apache/flink/python/env/ProcessEnvironment.java ## @@ -0,0 +1,45 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] klion26 commented on a change in pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-08 Thread GitBox
klion26 commented on a change in pull request #12420: URL: https://github.com/apache/flink/pull/12420#discussion_r451970665 ## File path: docs/dev/table/streaming/joins.zh.md ## @@ -300,25 +285,26 @@ FROM ON r.currency = o.currency {% endhighlight %} -Each record from

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

2020-07-08 Thread GitBox
klion26 commented on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-655904944 @RocMarshal thanks for the quick fix, as the change is too big, I'll give response asap. This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12856: URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024 ## CI report: * fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12858: [FLINK-18534][kafka][table] Fix unstable KafkaTableITCase.testKafkaDebeziumChangelogSource

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12858: URL: https://github.com/apache/flink/pull/12858#issuecomment-655892754 ## CI report: * f0b3ee3b40e8f357d0e02f35e2486865648eda3c Azure:

[GitHub] [flink] flinkbot commented on pull request #12858: [FLINK-18534][kafka][table] Fix unstable KafkaTableITCase.testKafkaDebeziumChangelogSource

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

[GitHub] [flink] flinkbot edited a comment on pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12856: URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024 ## CI report: * fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:

[GitHub] [flink] wuchong commented on a change in pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

2020-07-08 Thread GitBox
wuchong commented on a change in pull request #12756: URL: https://github.com/apache/flink/pull/12756#discussion_r451954436 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java ## @@ -502,9 +516,17 @@ private void

[GitHub] [flink] wuchong commented on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

2020-07-08 Thread GitBox
wuchong commented on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-655888642 Others looks good to me. Could you please fix the `thrown` problem? This is an automated message from the

[GitHub] [flink] wuchong commented on a change in pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-08 Thread GitBox
wuchong commented on a change in pull request #12805: URL: https://github.com/apache/flink/pull/12805#discussion_r451951070 ## File path: docs/dev/table/connectors/kafka.md ## @@ -207,6 +214,19 @@ However, it will cause a lot of network connections between all the Flink

[GitHub] [flink] wuchong commented on a change in pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-08 Thread GitBox
wuchong commented on a change in pull request #12805: URL: https://github.com/apache/flink/pull/12805#discussion_r451950734 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java ## @@ -222,8

[GitHub] [flink] flinkbot commented on pull request #12858: [FLINK-18534][kafka][table] Fix unstable KafkaTableITCase.testKafkaDebeziumChangelogSource

2020-07-08 Thread GitBox
flinkbot commented on pull request #12858: URL: https://github.com/apache/flink/pull/12858#issuecomment-655884468 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-18534) KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists"

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

[GitHub] [flink] wuchong opened a new pull request #12858: [FLINK-18534][kafka][table] Fix unstable KafkaTableITCase.testKafkaDebeziumChangelogSource

2020-07-08 Thread GitBox
wuchong opened a new pull request #12858: URL: https://github.com/apache/flink/pull/12858 ## What is the purpose of the change This fix the unstable test with "Topic 'changelog_topic' already exists" exception. ## Brief change log Currently

[GitHub] [flink] wuchong commented on pull request #12858: [FLINK-18534][kafka][table] Fix unstable KafkaTableITCase.testKafkaDebeziumChangelogSource

2020-07-08 Thread GitBox
wuchong commented on pull request #12858: URL: https://github.com/apache/flink/pull/12858#issuecomment-655884001 Could you help to review this @leonardBang ? This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-18534) KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists"

2020-07-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18534: --- Assignee: Jark Wu > KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic >

[GitHub] [flink] godfreyhe commented on pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-08 Thread GitBox
godfreyhe commented on pull request #12851: URL: https://github.com/apache/flink/pull/12851#issuecomment-655857964 @liuyongvs @wuchong I will review this today This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-18533) AccumulatorLiveITCase.testStreaming hangs

2020-07-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154137#comment-17154137 ] Dian Fu commented on FLINK-18533: - Another instance:

[jira] [Updated] (FLINK-18534) KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists"

2020-07-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18534: Labels: test-stability (was: ) > KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic >

[jira] [Created] (FLINK-18534) KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists"

2020-07-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-18534: --- Summary: KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists" Key: FLINK-18534 URL: https://issues.apache.org/jira/browse/FLINK-18534

[GitHub] [flink] wuchong commented on pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-08 Thread GitBox
wuchong commented on pull request #12851: URL: https://github.com/apache/flink/pull/12851#issuecomment-655853748 Hi @godfreyhe , do you have time to review this? This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-18533) AccumulatorLiveITCase.testStreaming hangs

2020-07-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18533: Labels: test-stability (was: ) > AccumulatorLiveITCase.testStreaming hangs >

[jira] [Created] (FLINK-18533) AccumulatorLiveITCase.testStreaming hangs

2020-07-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-18533: --- Summary: AccumulatorLiveITCase.testStreaming hangs Key: FLINK-18533 URL: https://issues.apache.org/jira/browse/FLINK-18533 Project: Flink Issue Type: Test

[jira] [Resolved] (FLINK-18525) Running yarn-session.sh occurs error

2020-07-08 Thread zhangyunyun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangyunyun resolved FLINK-18525. - Resolution: Done > Running yarn-session.sh occurs error >

[jira] [Commented] (FLINK-18525) Running yarn-session.sh occurs error

2020-07-08 Thread zhangyunyun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154124#comment-17154124 ] zhangyunyun commented on FLINK-18525: - It resolved! Thank [~fly_in_gis]  > Running yarn-session.sh

[jira] [Commented] (FLINK-18525) Running yarn-session.sh occurs error

2020-07-08 Thread zhangyunyun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154121#comment-17154121 ] zhangyunyun commented on FLINK-18525: - I configured \{{fs.default-scheme}} to a hdfs url. Let me

[jira] [Comment Edited] (FLINK-16795) End to end tests timeout on Azure

2020-07-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154117#comment-17154117 ] Dian Fu edited comment on FLINK-16795 at 7/9/20, 1:51 AM: --

[jira] [Comment Edited] (FLINK-16795) End to end tests timeout on Azure

2020-07-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154117#comment-17154117 ] Dian Fu edited comment on FLINK-16795 at 7/9/20, 1:51 AM: --

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

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

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

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

[GitHub] [flink] liuyongvs commented on pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-08 Thread GitBox
liuyongvs commented on pull request #12851: URL: https://github.com/apache/flink/pull/12851#issuecomment-655842803 hi @wuchong , azure passed, could you speed some of time reviewing this PR? This is an automated message from

[jira] [Commented] (FLINK-18525) Running yarn-session.sh occurs error

2020-07-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154111#comment-17154111 ] Yang Wang commented on FLINK-18525: --- It is strange that the

[GitHub] [flink] miaogr86 commented on pull request #12848: Release 1.11 java.lang.IllegalStateException: No ExecutorFactory found to execute the application.

2020-07-08 Thread GitBox
miaogr86 commented on pull request #12848: URL: https://github.com/apache/flink/pull/12848#issuecomment-655831527 @haijohn thx This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-18498) Update Flink Playgrounds to 1.11

2020-07-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154015#comment-17154015 ] Seth Wiesman commented on FLINK-18498: -- Fixed in master: a18385d7202f39cd3eb5e4ae7c0c91fdb6243c2c

[jira] [Resolved] (FLINK-18498) Update Flink Playgrounds to 1.11

2020-07-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-18498. -- Resolution: Fixed > Update Flink Playgrounds to 1.11 > > >

[GitHub] [flink-playgrounds] sjwiesman closed pull request #15: [FLINK-18498] Update playgrounds for 1.11 release

2020-07-08 Thread GitBox
sjwiesman closed pull request #15: URL: https://github.com/apache/flink-playgrounds/pull/15 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

[jira] [Updated] (FLINK-18510) Job Listener Interface failed

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18510: - Priority: Major (was: Blocker) > Job Listener Interface failed >

[jira] [Closed] (FLINK-18510) Job Listener Interface failed

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18510. Resolution: Duplicate > Job Listener Interface failed > -- >

[jira] [Comment Edited] (FLINK-18097) History server doesn't clean all job json files

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153865#comment-17153865 ] Chesnay Schepler edited comment on FLINK-18097 at 7/8/20, 7:11 PM: ---

[jira] [Comment Edited] (FLINK-18097) History server doesn't clean all job json files

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153865#comment-17153865 ] Chesnay Schepler edited comment on FLINK-18097 at 7/8/20, 7:11 PM: ---

[jira] [Closed] (FLINK-18097) History server doesn't clean all job json files

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18097. Fix Version/s: 1.11.1 1.12.0 1.10.2

[jira] [Updated] (FLINK-16463) CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16463: - Issue Type: Bug (was: Wish) > CodeGenUtils generates code that has two semicolons for

[GitHub] [flink] flinkbot edited a comment on pull request #12857: [FLINK-18520][table] Fix unresolvable catalog table functions

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12857: URL: https://github.com/apache/flink/pull/12857#issuecomment-655543169 ## CI report: * d52c63e8e43456629c23a571eefcb60bd26a11be Azure:

[jira] [Updated] (FLINK-15617) Remove useless JobRetrievalException

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15617: - Issue Type: Improvement (was: Wish) > Remove useless JobRetrievalException >

[jira] [Updated] (FLINK-15601) Remove useless constant field NUM_STOP_CALL_TRIES in Execution

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15601: - Issue Type: Improvement (was: Wish) > Remove useless constant field

[jira] [Updated] (FLINK-15558) Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15558: - Issue Type: Improvement (was: Wish) > Bump Elasticsearch version from 7.3.2 to 7.5.1

[jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14351: - Fix Version/s: (was: 1.11.0) 1.12.0 > Refactor MetricRegistry

[jira] [Updated] (FLINK-12336) Add HTTPS support to InfluxDB reporter

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12336: - Fix Version/s: (was: 1.11.0) 1.12.0 > Add HTTPS support to

[jira] [Comment Edited] (FLINK-16795) End to end tests timeout on Azure

2020-07-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153821#comment-17153821 ] Dawid Wysakowicz edited comment on FLINK-16795 at 7/8/20, 6:03 PM: ---

[jira] [Reopened] (FLINK-16795) End to end tests timeout on Azure

2020-07-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-16795: -- > End to end tests timeout on Azure > - > >

[jira] [Updated] (FLINK-16795) End to end tests timeout on Azure

2020-07-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16795: - Affects Version/s: 1.12.0 > End to end tests timeout on Azure >

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

2020-07-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153821#comment-17153821 ] Dawid Wysakowicz commented on FLINK-16795: -- New instances:

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

2020-07-08 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153813#comment-17153813 ] Thomas Weise commented on FLINK-16510: -- We are not able to reliably run our applications on k8s

[GitHub] [flink] flinkbot edited a comment on pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12856: URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024 ## CI report: * fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:

[jira] [Created] (FLINK-18532) Remove Beta tag from MATCH_RECOGNIZE docs

2020-07-08 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18532: Summary: Remove Beta tag from MATCH_RECOGNIZE docs Key: FLINK-18532 URL: https://issues.apache.org/jira/browse/FLINK-18532 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18531) Minicluster option to reuse same port if 0 is applied

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18531: - Component/s: Runtime / REST Runtime / Configuration > Minicluster

[jira] [Closed] (FLINK-18531) Minicluster option to reuse same port if 0 is applied

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18531. Resolution: Won't Fix This is not possible. If you want the port to remain stable, you

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

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12851: URL: https://github.com/apache/flink/pull/12851#issuecomment-655384097 ## CI report: * 7a1f2dd7590a3b1816e619db2c80d543cbdcf7d2 UNKNOWN * b79337059dea45b43d88cf3e4b07309dcd711d2b Azure:

[jira] [Updated] (FLINK-18531) Minicluster option to reuse same port if 0 is applied

2020-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18531: - Issue Type: Wish (was: Test) > Minicluster option to reuse same port if 0 is applied >

[jira] [Created] (FLINK-18531) Minicluster option to reuse same port if 0 is applied

2020-07-08 Thread David Chen (Jira)
David Chen created FLINK-18531: -- Summary: Minicluster option to reuse same port if 0 is applied Key: FLINK-18531 URL: https://issues.apache.org/jira/browse/FLINK-18531 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-654978676 ## CI report: * 5b3a4da61a337a80a70a5125ed135d3095def41e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12852: [FLINK-17000][table] Ensure that every logical type can be represented as TypeInformation

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12852: URL: https://github.com/apache/flink/pull/12852#issuecomment-655468923 ## CI report: * 5b8d05081345063348bad6375c2567a0ebf59bed Azure:

[jira] [Commented] (FLINK-18520) New Table Function type inference fails

2020-07-08 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153698#comment-17153698 ] Benchao Li commented on FLINK-18520: [~twalthr] Thanks for your quick fix, I've reviewed the PR. >

[GitHub] [flink] libenchao commented on a change in pull request #12857: [FLINK-18520][table] Fix unresolvable catalog table functions

2020-07-08 Thread GitBox
libenchao commented on a change in pull request #12857: URL: https://github.com/apache/flink/pull/12857#discussion_r451634594 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/FunctionCatalogOperatorTable.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12420: URL: https://github.com/apache/flink/pull/12420#issuecomment-636504607 ## CI report: * d0f0b15cc5289803cdbde65b26bc66f0542da5f1 UNKNOWN * bc4b8b49834d751271c7f0976f62f91923217420 Azure:

[jira] [Updated] (FLINK-18499) Update Flink Exercises to 1.11

2020-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18499: --- Labels: pull-request-available (was: ) > Update Flink Exercises to 1.11 >

[GitHub] [flink-training] alpinegizmo opened a new pull request #12: [FLINK-18499] Update for Flink 1.11: don’t use deprecated forms of keyBy

2020-07-08 Thread GitBox
alpinegizmo opened a new pull request #12: URL: https://github.com/apache/flink-training/pull/12 Clean-up the keyBys for Flink 1.11. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-playgrounds] sjwiesman closed pull request #14: [hotfix][walkthrough] Update Table API Walkthrough

2020-07-08 Thread GitBox
sjwiesman closed pull request #14: URL: https://github.com/apache/flink-playgrounds/pull/14 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

[GitHub] [flink-playgrounds] sjwiesman commented on pull request #14: [hotfix][walkthrough] Update Table API Walkthrough

2020-07-08 Thread GitBox
sjwiesman commented on pull request #14: URL: https://github.com/apache/flink-playgrounds/pull/14#issuecomment-655590061 Thank you This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12856: URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024 ## CI report: * fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12857: [FLINK-18520][table] Fix unresolvable catalog table functions

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12857: URL: https://github.com/apache/flink/pull/12857#issuecomment-655543169 ## CI report: * d52c63e8e43456629c23a571eefcb60bd26a11be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12420: URL: https://github.com/apache/flink/pull/12420#issuecomment-636504607 ## CI report: * d0f0b15cc5289803cdbde65b26bc66f0542da5f1 UNKNOWN * 4dbc7b88a9fdf589c0c339378576cdda755fd77c Azure:

[GitHub] [flink] zentol closed pull request #12844: [FLINK-18519][REST] Propagate exception to client when application fails to execute.

2020-07-08 Thread GitBox
zentol closed pull request #12844: URL: https://github.com/apache/flink/pull/12844 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] authuir commented on a change in pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-08 Thread GitBox
authuir commented on a change in pull request #12420: URL: https://github.com/apache/flink/pull/12420#discussion_r451581064 ## File path: docs/dev/table/streaming/joins.zh.md ## @@ -22,37 +22,38 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #12853: [FLINK-18524][table-common] Fix type inference for Scala varargs

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12853: URL: https://github.com/apache/flink/pull/12853#issuecomment-655469013 ## CI report: * dac055b0d95b136897bd699014290322c4dc22ce Azure:

[GitHub] [flink] flinkbot commented on pull request #12857: [FLINK-18520][table] Fix unresolvable catalog table functions

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

[GitHub] [flink] flinkbot commented on pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12853: [FLINK-18524][table-common] Fix type inference for Scala varargs

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12853: URL: https://github.com/apache/flink/pull/12853#issuecomment-655469013 ## CI report: * dac055b0d95b136897bd699014290322c4dc22ce Azure:

[jira] [Commented] (FLINK-18520) New Table Function type inference fails

2020-07-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153617#comment-17153617 ] Timo Walther commented on FLINK-18520: -- I opened a PR for this problem. [~libenchao] could you

[GitHub] [flink] flinkbot commented on pull request #12857: [FLINK-18520][table] Fix unresolvable catalog table functions

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

[GitHub] [flink] flinkbot commented on pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

2020-07-08 Thread GitBox
flinkbot commented on pull request #12856: URL: https://github.com/apache/flink/pull/12856#issuecomment-655527283 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-18520) New Table Function type inference fails

2020-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18520: --- Labels: pull-request-available (was: ) > New Table Function type inference fails >

[jira] [Updated] (FLINK-18529) Query Hive table and filter by timestamp partition can fail

2020-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18529: --- Labels: pull-request-available (was: ) > Query Hive table and filter by timestamp

[GitHub] [flink] twalthr opened a new pull request #12857: [FLINK-18520][table] Fix unresolvable catalog table functions

2020-07-08 Thread GitBox
twalthr opened a new pull request #12857: URL: https://github.com/apache/flink/pull/12857 ## What is the purpose of the change Improves the validation logic for scalar/table function usage. It made catalog functions unresolvable before. ## Brief change log Remove

[GitHub] [flink] lirui-apache opened a new pull request #12856: [FLINK-18529][hive] Query Hive table and filter by timestamp partitio…

2020-07-08 Thread GitBox
lirui-apache opened a new pull request #12856: URL: https://github.com/apache/flink/pull/12856 …n can fail ## What is the purpose of the change Fix the issue that querying a Hive table and filter by timestamp partition column can fail. ## Brief change log

[jira] [Comment Edited] (FLINK-18502) Add the page 'legacySourceSinks.zh.md' into the directory 'docs/dev/table'

2020-07-08 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153572#comment-17153572 ] Roc Marshal edited comment on FLINK-18502 at 7/8/20, 1:27 PM: -- Hi,[~jark], 

[GitHub] [flink] flinkbot edited a comment on pull request #12855: [FLINK-18526][python][docs] Add configuration of Python UDF to use Ma…

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12855: URL: https://github.com/apache/flink/pull/12855#issuecomment-655500427 ## CI report: * cbd3259908d23c419e97595704e59af2ce970cab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12854: [FLINK-18502][docs] Add the page 'legacySourceSinks.zh.md' into the directory 'docs/dev/table', which contains [FLINK-18505][docs] Co

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12854: URL: https://github.com/apache/flink/pull/12854#issuecomment-655500315 ## CI report: * a343769ca9bec4a73587c55daa0e265f8a3a6ce6 Azure:

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

2020-07-08 Thread GitBox
flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * f1fb24d628f66f3f2929fe4e737a835e8391c0a8 Azure:

[jira] [Commented] (FLINK-18502) Add the page 'legacySourceSinks.zh.md' into the directory 'docs/dev/table'

2020-07-08 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153605#comment-17153605 ] Roc Marshal commented on FLINK-18502: - [~jark] OK. There's nothing better! > Add the page

[GitHub] [flink] twalthr commented on pull request #12853: [FLINK-18524][table-common] Fix type inference for Scala varargs

2020-07-08 Thread GitBox
twalthr commented on pull request #12853: URL: https://github.com/apache/flink/pull/12853#issuecomment-655515610 Thanks @aljoscha. I will merge this once the build is green. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-18530) ParquetAvroWriters can not write data to hdfs

2020-07-08 Thread humengyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] humengyu updated FLINK-18530: - Description: I read data from kafka and write to hdfs by StreamingFileSink: # in version 1.11.0,

[jira] [Updated] (FLINK-18530) ParquetAvroWriters can not write data to hdfs

2020-07-08 Thread humengyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] humengyu updated FLINK-18530: - Description: I read data from kafka and write to hdfs by StreamingFileSink: # in version 1.11.0,

[jira] [Updated] (FLINK-18529) Query Hive table and filter by timestamp partition can fail

2020-07-08 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18529: --- Description: The following example {code} create table foo (x int) partitioned by (ts timestamp); select x

[jira] [Created] (FLINK-18530) ParquetAvroWriters can not write data to hdfs

2020-07-08 Thread humengyu (Jira)
humengyu created FLINK-18530: Summary: ParquetAvroWriters can not write data to hdfs Key: FLINK-18530 URL: https://issues.apache.org/jira/browse/FLINK-18530 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-18502) Add the page 'legacySourceSinks.zh.md' into the directory 'docs/dev/table'

2020-07-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153589#comment-17153589 ] Jark Wu edited comment on FLINK-18502 at 7/8/20, 1:11 PM: -- It's fine to fix

[jira] [Commented] (FLINK-18502) Add the page 'legacySourceSinks.zh.md' into the directory 'docs/dev/table'

2020-07-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153589#comment-17153589 ] Jark Wu commented on FLINK-18502: - It's fine to fix them in the single PR. > Add the page

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

2020-07-08 Thread GitBox
RocMarshal commented on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-655508679 @klion26 Thank you so much for your efforts in the `review` of this PR whose workload is havey ! It's very significant for the translation of this page. And I

[jira] [Updated] (FLINK-18529) Query Hive table and filter by timestamp partition can fail

2020-07-08 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18529: --- Summary: Query Hive table and filter by timestamp partition can fail (was: Query Hive table and filter by

[GitHub] [flink-playgrounds] alpinegizmo commented on pull request #14: [hotfix][walkthrough] Update Table API Walkthrough

2020-07-08 Thread GitBox
alpinegizmo commented on pull request #14: URL: https://github.com/apache/flink-playgrounds/pull/14#issuecomment-655501681 @sjwiesman I didn't notice this PR (I searched for relevant JIRA tickets, but didn't think to look here before doing the update). This PR wouldn't work anyway, things

  1   2   3   >