[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r425552869 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java ## @@ -210,7

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r425552834 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/ResourceInformationReflectorTest.java ## @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

flinkbot edited a comment on pull request #12158: URL: https://github.com/apache/flink/pull/12158#issuecomment-628762210 ## CI report: * 0328a87f455afee6923ff2b5bd004801cd73a457 Azure:

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

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * f0bdd24a7d955fb17aadc7c022ab2bd06461f869 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

flinkbot edited a comment on pull request #12143: URL: https://github.com/apache/flink/pull/12143#issuecomment-628420573 ## CI report: * dcd8b8efec513fcfa4d833ab2915e7171eee6ace Azure:

[GitHub] [flink] flinkbot commented on pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

flinkbot commented on pull request #12161: URL: https://github.com/apache/flink/pull/12161#issuecomment-629011624 ## CI report: * fb208fbfdf55bdde668c609a3305d938b8105f95 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zhengcanbin commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

zhengcanbin commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425552656 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[GitHub] [flink] flinkbot edited a comment on pull request #12119: [FLINK-17649][table-planner-blink] Generated hash aggregate code may …

flinkbot edited a comment on pull request #12119: URL: https://github.com/apache/flink/pull/12119#issuecomment-628150518 ## CI report: * f2ab38fb3fd70e6fa9f9de2350dfb9b6bb4a477c Azure:

[GitHub] [flink] wangyang0918 commented on pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on pull request #11010: URL: https://github.com/apache/flink/pull/11010#issuecomment-629011294 @zhengcanbin @tillrohrmann I have added a `fixup` commit to address the comments. Please have a look at your convenience.

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11385: [FLINK-11395][formats] Support for Avro StreamingFileSink

flinkbot edited a comment on pull request #11385: URL: https://github.com/apache/flink/pull/11385#issuecomment-597956562 ## CI report: * 9e1bbeafa1a4d0f673ebba7f87ef9032253a29f0 UNKNOWN * 55bbaced3ca77aecde372a75505363cceb280fb6 Azure:

[GitHub] [flink] klion26 commented on a change in pull request #12112: [FLINK-16075][docs-zh] Translate "The Broadcast State Pattern" page into Chinese

klion26 commented on a change in pull request #12112: URL: https://github.com/apache/flink/pull/12112#discussion_r425539914 ## File path: docs/dev/stream/state/broadcast_state.zh.md ## @@ -136,66 +118,50 @@ public abstract class KeyedBroadcastProcessFunction { } {%

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425551475 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107902#comment-17107902 ] Zhu Zhu commented on FLINK-17645: - [~sewen] I think this specific fix is valid because the root cause is

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r425550221 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/ResourceInformationReflector.java ## @@ -0,0 +1,162 @@ +/* + * Licensed to the Apache

[GitHub] [flink] Myasuka commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425549498 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ## @@

[GitHub] [flink] zhengcanbin commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

zhengcanbin commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425549169 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[GitHub] [flink] KurtYoung commented on a change in pull request #12076: [FLINK-15950][table] Remove registration of TableSource/TableSink in Table Env

KurtYoung commented on a change in pull request #12076: URL: https://github.com/apache/flink/pull/12076#discussion_r425547315 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/utils/TableEnvUtils.java ## @@ -0,0 +1,135 @@ +/* + * Licensed to

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r425548306 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java ## @@ -0,0 +1,120 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17710: Labels: pull-request-available test-stability (was: pull-request-available) >

[jira] [Assigned] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17710: --- Assignee: Nicholas Jiang > StreamSqlTests.test_execute_sql test is not stable >

[GitHub] [flink] flinkbot commented on pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

flinkbot commented on pull request #12161: URL: https://github.com/apache/flink/pull/12161#issuecomment-629007368 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-17450) Implement function & catalog DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17450: --- Labels: pull-request-available (was: ) > Implement function & catalog DDLs for Hive

[GitHub] [flink] lirui-apache opened a new pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

lirui-apache opened a new pull request #12161: URL: https://github.com/apache/flink/pull/12161 ## What is the purpose of the change To implement FUNCTION & CATALOG DDLs for Hive dialect. ## Brief change log - Implement the syntax - Add test cases

[GitHub] [flink] wangyang0918 commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

wangyang0918 commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425546588 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -96,9 +98,10 @@ * Watch the

[GitHub] [flink] godfreyhe commented on a change in pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

godfreyhe commented on a change in pull request #12025: URL: https://github.com/apache/flink/pull/12025#discussion_r425546227 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormat.java ## @@ -0,0

[GitHub] [flink] zhijiangW commented on a change in pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

zhijiangW commented on a change in pull request #11948: URL: https://github.com/apache/flink/pull/11948#discussion_r425544862 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -469,7 +469,9 @@ public

[GitHub] [flink] zhijiangW commented on a change in pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

zhijiangW commented on a change in pull request #11948: URL: https://github.com/apache/flink/pull/11948#discussion_r425544862 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -469,7 +469,9 @@ public

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107890#comment-17107890 ] Xintong Song commented on FLINK-17493: -- bq. Repeat step2 and step3, the direct memory buffers used

[GitHub] [flink] zhengcanbin commented on pull request #12105: [FLINK-16624][k8s] Support user-specified annotations for the rest Service

zhengcanbin commented on pull request #12105: URL: https://github.com/apache/flink/pull/12105#issuecomment-629002655 Thanks for your review @TisonKun! @tillrohrmann could you also have a look? This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

flinkbot edited a comment on pull request #12143: URL: https://github.com/apache/flink/pull/12143#issuecomment-628420573 ## CI report: * dcd8b8efec513fcfa4d833ab2915e7171eee6ace Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * b62fcd03a583ef204f21a313f6969c8aaa4ee61d Azure:

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

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 190d48b9cf54b6e7a53c5de43f4edbb927bf0c8e Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12074: [FLINK-17606][table] Introduce DataGenerator connector in table

flinkbot edited a comment on pull request #12074: URL: https://github.com/apache/flink/pull/12074#issuecomment-626543188 ## CI report: * 62f441198c518458511ce8b6b013e878c3e9f156 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

flinkbot edited a comment on pull request #12025: URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121 ## CI report: * 04db04d8d1b41ca05618c5b09b83b3031bf7ee11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 731dff0812f1abb16193f7a2fe6f54b3ef65ae2d UNKNOWN * b90556c18fabe5fcfc3e93ba8c6b6a44b0d21f88 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN *

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Description: The DefaultExecutionSlotAllocator should allocate slot in bulks, that means the bulks of

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Description: The DefaultExecutionSlotAllocator should allocate slot in bulks, that means the bulks of

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Summary: DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing (was:

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Summary: DefaultExecutionSlotAllocator allocates slots in bulks (was: Use Bulk Slot Allocation in

[jira] [Commented] (FLINK-17584) disableAutoTypeRegistration option does not work with Streaming API, only with Batch

[ https://issues.apache.org/jira/browse/FLINK-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107882#comment-17107882 ] Guowei Ma commented on FLINK-17584: --- Thanks for opening this issue. 1. I think the

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r425540650 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java ## @@ -210,7

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r425540467 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ExternalResourceOptions.java ## @@ -0,0 +1,75 @@ +/* + * Licensed to the Apache

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r425539972 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java ## @@ -108,6 +109,27 @@ public static boolean getBoolean(Properties

[GitHub] [flink] JingsongLi commented on a change in pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

JingsongLi commented on a change in pull request #12025: URL: https://github.com/apache/flink/pull/12025#discussion_r425536040 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ConsumeOrder.java ## @@ -0,0 +1,59 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

flinkbot edited a comment on pull request #12152: URL: https://github.com/apache/flink/pull/12152#issuecomment-628617951 ## CI report: * 4ddbfe93c3b83b22ffc9f3417983a493cab5e6f3 Azure:

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

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 190d48b9cf54b6e7a53c5de43f4edbb927bf0c8e Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

flinkbot edited a comment on pull request #12158: URL: https://github.com/apache/flink/pull/12158#issuecomment-628762210 ## CI report: * 6a096afc2b4ca4c15b15e911bfde9e764ef17adb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12074: [FLINK-17606][table] Introduce DataGenerator connector in table

flinkbot edited a comment on pull request #12074: URL: https://github.com/apache/flink/pull/12074#issuecomment-626543188 ## CI report: * 62f441198c518458511ce8b6b013e878c3e9f156 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12134: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12134: URL: https://github.com/apache/flink/pull/12134#issuecomment-628151544 ## CI report: * 7e9dbd86c8018a69c87df7bbf79503ee3705f4dd UNKNOWN * 3f2560a207c9da843c6dce5fe1f70bc68b7bea3e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12092: [FLINK-17596][python] Move the Python UDF runner script out of the jar of flink-python

flinkbot edited a comment on pull request #12092: URL: https://github.com/apache/flink/pull/12092#issuecomment-627157672 ## CI report: * a9c696fd00358fc2e142f0546524ce5d30d8f7e8 UNKNOWN * 8d309a011dbda867a22a92215bf0de5001c90eb5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 731dff0812f1abb16193f7a2fe6f54b3ef65ae2d UNKNOWN * b90556c18fabe5fcfc3e93ba8c6b6a44b0d21f88 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

flinkbot edited a comment on pull request #12025: URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121 ## CI report: * 04db04d8d1b41ca05618c5b09b83b3031bf7ee11 Azure:

[jira] [Closed] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17710. --- Resolution: Fixed > StreamSqlTests.test_execute_sql test is not stable >

[jira] [Updated] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17710: Fix Version/s: 1.11.0 > StreamSqlTests.test_execute_sql test is not stable >

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * b62fcd03a583ef204f21a313f6969c8aaa4ee61d Azure:

[jira] [Commented] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107872#comment-17107872 ] Hequn Cheng commented on FLINK-17710: - Fixed in 1.11.0 via be9779df4a817697788ed44fc618900595b248d8

[GitHub] [flink] hequn8128 edited a comment on pull request #12160: [FLINK-17710][python][hotfix] StreamSqlTests.test_execute_sql test is…

hequn8128 edited a comment on pull request #12160: URL: https://github.com/apache/flink/pull/12160#issuecomment-628994678 It is strange that the test has not been triggered due to some "Bad credentials" problem.

[GitHub] [flink] docete commented on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

docete commented on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-628996370 > Hi @docete , the change looks good to me. Could you rebase and resolve the conflicts and open another pull request for 1.10 branch? rebased. Will open another pr for

[GitHub] [flink] wangyang0918 commented on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

wangyang0918 commented on pull request #12143: URL: https://github.com/apache/flink/pull/12143#issuecomment-628995582 rebase latest master This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-17711) Support hadoop OutputCommitter based file committer

Yun Gao created FLINK-17711: --- Summary: Support hadoop OutputCommitter based file committer Key: FLINK-17711 URL: https://issues.apache.org/jira/browse/FLINK-17711 Project: Flink Issue Type:

[GitHub] [flink] hequn8128 commented on pull request #12160: [FLINK-17710][python][hotfix] StreamSqlTests.test_execute_sql test is…

hequn8128 commented on pull request #12160: URL: https://github.com/apache/flink/pull/12160#issuecomment-628994678 It is wired that the test has not been triggered due to some "Bad credentials" problem.

[jira] [Updated] (FLINK-17594) Support Hadoop path-based PartFileWriter with renaming committer

[ https://issues.apache.org/jira/browse/FLINK-17594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17594: Description: To support streaming hive connector with StreamingFileSink, we need to support path-based

[jira] [Updated] (FLINK-17594) Support Hadoop path-based PartFileWriter with renaming committer

[ https://issues.apache.org/jira/browse/FLINK-17594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17594: Summary: Support Hadoop path-based PartFileWriter with renaming committer (was: Support Hadoop

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107866#comment-17107866 ] Jiangjie Qin commented on FLINK-17575: -- [~rmetzger] The ugly part of  KafkaConsumer is that if

[GitHub] [flink] TsReaper edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

TsReaper edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-628991931 Rebased onto master. This PR is now ready for merging. This is an automated message from the Apache Git

[GitHub] [flink] TsReaper commented on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

TsReaper commented on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-628991931 Rebased onto master. This PR is now ready for merge. This is an automated message from the Apache Git Service.

[GitHub] [flink] JingsongLi commented on a change in pull request #12134: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

JingsongLi commented on a change in pull request #12134: URL: https://github.com/apache/flink/pull/12134#discussion_r425533256 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/committer/HadoopRenameFileCommitter.java ##

[GitHub] [flink] JingsongLi commented on a change in pull request #12134: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

JingsongLi commented on a change in pull request #12134: URL: https://github.com/apache/flink/pull/12134#discussion_r425532602 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/committer/HadoopRenameFileCommitter.java ##

[GitHub] [flink] hequn8128 merged pull request #12160: [FLINK-17710][python][hotfix] StreamSqlTests.test_execute_sql test is…

hequn8128 merged pull request #12160: URL: https://github.com/apache/flink/pull/12160 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] JingsongLi commented on a change in pull request #12134: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

JingsongLi commented on a change in pull request #12134: URL: https://github.com/apache/flink/pull/12134#discussion_r425531470 ## File path: flink-core/src/main/java/org/apache/flink/api/common/serialization/PathBasedBulkWriter.java ## @@ -0,0 +1,69 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #12160: [FLINK-17710][python][hotfix] StreamSqlTests.test_execute_sql test is…

flinkbot commented on pull request #12160: URL: https://github.com/apache/flink/pull/12160#issuecomment-628984987 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] SteNicholas opened a new pull request #12160: [FLINK-17710][python][hotfix] StreamSqlTests.test_execute_sql test is…

SteNicholas opened a new pull request #12160: URL: https://github.com/apache/flink/pull/12160 ## What is the purpose of the change *`StreamSqlTests#test_execute_sql` test method is not stable because this method verify the `JobStatus` state for the returned `JobClient`, which state

[jira] [Updated] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17710: --- Labels: pull-request-available (was: ) > StreamSqlTests.test_execute_sql test is not

[GitHub] [flink] JingsongLi commented on pull request #12074: [FLINK-17606][table] Introduce DataGenerator connector in table

JingsongLi commented on pull request #12074: URL: https://github.com/apache/flink/pull/12074#issuecomment-628983591 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Comment Edited] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107846#comment-17107846 ] Hequn Cheng edited comment on FLINK-17710 at 5/15/20, 2:05 AM: --- CC

[GitHub] [flink] flinkbot edited a comment on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

flinkbot edited a comment on pull request #12158: URL: https://github.com/apache/flink/pull/12158#issuecomment-628762210 ## CI report: * 6a096afc2b4ca4c15b15e911bfde9e764ef17adb Azure:

[jira] [Commented] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107846#comment-17107846 ] Hequn Cheng commented on FLINK-17710: - CC [~nicholasjiang]. I think we should not assertFalse for

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

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 4d9d19dd8a1bcaa317dc8f0550186bba13f7c103 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

flinkbot edited a comment on pull request #12152: URL: https://github.com/apache/flink/pull/12152#issuecomment-628617951 ## CI report: * 81d1f17f7dad4bed004616df23aa37a0e700b96a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN *

[GitHub] [flink] godfreyhe commented on pull request #12145: [FLINK-16364] [table-planner-blink] supports projection push down on new table source interface in blink planner

godfreyhe commented on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628981339 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Comment Edited] (FLINK-12717) Add windows support for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101491#comment-17101491 ] Dian Fu edited comment on FLINK-12717 at 5/15/20, 1:56 AM: --- Merged to master

[GitHub] [flink] dianfu closed pull request #12125: [FLINK-12717][python] Remove unnecessary 'pyflink-gateway-server.sh'.

dianfu closed pull request #12125: URL: https://github.com/apache/flink/pull/12125 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

[jira] [Updated] (FLINK-13811) Support converting flink table to pandas dataframe

[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13811: Affects Version/s: (was: 1.9.0) > Support converting flink table to pandas dataframe >

[jira] [Closed] (FLINK-17146) Support conversion between PyFlink Table and Pandas DataFrame

[ https://issues.apache.org/jira/browse/FLINK-17146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17146. --- Resolution: Resolved > Support conversion between PyFlink Table and Pandas DataFrame >

[jira] [Closed] (FLINK-13811) Support converting flink table to pandas dataframe

[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-13811. --- Resolution: Resolved Merged to master via d41788999ac8f9f3b9444fb11ebcfdd8a6cb253c > Support converting

[GitHub] [flink] dianfu closed pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

dianfu closed pull request #12148: URL: https://github.com/apache/flink/pull/12148 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

[jira] [Commented] (FLINK-17706) Clarify licensing situation

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107834#comment-17107834 ] Xintong Song commented on FLINK-17706: -- I'm good with the license change to my contributions. >

[jira] [Created] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

Hequn Cheng created FLINK-17710: --- Summary: StreamSqlTests.test_execute_sql test is not stable Key: FLINK-17710 URL: https://issues.apache.org/jira/browse/FLINK-17710 Project: Flink Issue Type:

[GitHub] [flink] dianfu commented on pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

dianfu commented on pull request #12148: URL: https://github.com/apache/flink/pull/12148#issuecomment-628977487 @WeiZhong94 Thanks for the review. The test failures are instable cases of Kafka which are not related to this PR. Merging...

[jira] [Closed] (FLINK-17387) Implement LookupableTableSource for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-17387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17387. Fix Version/s: 1.11.0 Resolution: Implemented master: 

[GitHub] [flink] flinkbot edited a comment on pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

flinkbot edited a comment on pull request #12152: URL: https://github.com/apache/flink/pull/12152#issuecomment-628617951 ## CI report: * 81d1f17f7dad4bed004616df23aa37a0e700b96a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 09465d2623a839311aa67ddfac4059f525f2b62c Azure:

[GitHub] [flink] JingsongLi merged pull request #11990: [FLINK-17387][hive] Implement LookupableTableSource for Hive connector

JingsongLi merged pull request #11990: URL: https://github.com/apache/flink/pull/11990 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-statefun] sjwiesman edited a comment on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

sjwiesman edited a comment on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-628974226 Thank you for working on this feature! I haven't taken a look at the code, Igal or Gordon are more qualified to look at this part of the code base, but I wanted

[GitHub] [flink-statefun] sjwiesman edited a comment on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

sjwiesman edited a comment on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-628974226 Thank you for working on this feature! I haven't taken a look at the code, Igal or Gordon are more qualified to look at this part of the code base, but I wanted

[GitHub] [flink-statefun] sjwiesman edited a comment on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

sjwiesman edited a comment on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-628974226 Thank you for working on this feature! I haven't taken a look at the code, Igal or Gordon are more qualified to look at this part of the code base, but I wanted

[GitHub] [flink-statefun] sjwiesman edited a comment on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

sjwiesman edited a comment on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-628974226 Thank you for working on this feature! I haven't taken a look at the code, Igal or Gordon are more qualified to look at this part of the code base, but I wanted

<    1   2   3   4   5   6   7   8   9   10   >