[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * b3fd51b309c78d9dd5056eed35dc2fe388665899 UNKNOWN * 2838b871958d80b1ea22c5ccd550505895e98e60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12317: [FLINK-17819][yarn] Fix error msg for yarn deployments when hadoop not in classpath

flinkbot edited a comment on pull request #12317: URL: https://github.com/apache/flink/pull/12317#issuecomment-633460641 ## CI report: * 284e50d0f89d2ad4647a2f22ab68ec10459cf612 Azure:

[GitHub] [flink] flinkbot commented on pull request #12321: Add document for writing Avro files with StreamingFileSink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

flinkbot edited a comment on pull request #12314: URL: https://github.com/apache/flink/pull/12314#issuecomment-633403476 ## CI report: * b7a68f0f07ab9bb2abc3182d72c0dc80ed59dda1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12281: [FLINK-17456][hive][test] Update hive connector tests to execute DDL …

flinkbot edited a comment on pull request #12281: URL: https://github.com/apache/flink/pull/12281#issuecomment-632080083 ## CI report: * 7191ad3180c71592f79ff55ea00a4c5f55cdf64e Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429918956 ## File path: tools/azure-pipelines/build-python-wheels.yml ## @@ -24,7 +24,6 @@ jobs: # Compile - script: |

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429918192 ## File path: tools/ci/test_controller.sh ## @@ -0,0 +1,127 @@ +#!/usr/bin/env bash

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429918097 ## File path: tools/ci/test_controller.sh ## @@ -0,0 +1,127 @@ +#!/usr/bin/env bash

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429917886 ## File path: tools/ci/maven-utils.sh ## @@ -73,7 +73,7 @@ function collect_coredumps { echo "Searching for .dump, .dumpstream and related files

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

twentyworld commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r429916242 ## File path: docs/training/streaming_analytics.zh.md ## @@ -3,7 +3,7 @@ title: Streaming Analytics nav-id: analytics nav-pos: 4 nav-title:

[GitHub] [flink] flinkbot commented on pull request #12321: Add document for writing Avro files with StreamingFileSink

flinkbot commented on pull request #12321: URL: https://github.com/apache/flink/pull/12321#issuecomment-633554264 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 #12320: [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory

flinkbot commented on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-633554289 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-17927) Default value of "sink.partition-commit.trigger" should be "process-time"

Jingsong Lee created FLINK-17927: Summary: Default value of "sink.partition-commit.trigger" should be "process-time" Key: FLINK-17927 URL: https://issues.apache.org/jira/browse/FLINK-17927 Project:

[GitHub] [flink] gaoyunhaii opened a new pull request #12321: Add document for writing Avro files with StreamingFileSink

gaoyunhaii opened a new pull request #12321: URL: https://github.com/apache/flink/pull/12321 ## What is the purpose of the change This PR add documents for the newly added `Avro` writers introduced in [Flink-11395](https://issues.apache.org/jira/browse/FLINK-11395). ## Brief

[jira] [Updated] (FLINK-17887) Improve interface of ScanFormatFactory and SinkFormatFactory

[ https://issues.apache.org/jira/browse/FLINK-17887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17887: --- Labels: pull-request-available (was: ) > Improve interface of ScanFormatFactory and

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429914110 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -1068,8 +1067,8 @@ public static void teardown() throws

[GitHub] [flink] wuchong opened a new pull request #12320: [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory

wuchong opened a new pull request #12320: URL: https://github.com/apache/flink/pull/12320 ## What is the purpose of the change This pull request is for improving current ScanForamtFactory and SinkFormatFactory interfaces with the following problems: 1)

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

twentyworld commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r429912783 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc} -##

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429912828 ## File path: tools/azure-pipelines/build-python-wheels.yml ## @@ -33,14 +32,13 @@ jobs: name: set_version - script: | - cd

[jira] [Commented] (FLINK-17926) Can't build flink-web docker image because of EOL of Ubuntu:18.10

[ https://issues.apache.org/jira/browse/FLINK-17926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115992#comment-17115992 ] Congxian Qiu(klion26) commented on FLINK-17926: --- [~rmetzger] what do you think about this,

[jira] [Updated] (FLINK-17924) HBase connector：we can write data to HBase table, but con`t read data from HBase

[ https://issues.apache.org/jira/browse/FLINK-17924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-17924: - Component/s: Connectors / HBase Affects Version/s: 1.10.0 Description:

[GitHub] [flink] flinkbot edited a comment on pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

flinkbot edited a comment on pull request #12296: URL: https://github.com/apache/flink/pull/12296#issuecomment-632902501 ## CI report: * 22bae967d6b59eb8e4c5dcd6a37f5a27fc492ed1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * bb313e40f5a72dbf20cd0a8b48267063fd4f00af UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * b3fd51b309c78d9dd5056eed35dc2fe388665899 UNKNOWN * 2838b871958d80b1ea22c5ccd550505895e98e60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * 7f16b12b9c89b723a6c201da252d65e259a53c84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 69bce2717b0279a894aa66d15cd4b9b72cd5a474 UNKNOWN * 9190d85e2b0e02af9a1062263e25c6f9a23b1c5d Azure:

[jira] [Created] (FLINK-17926) Can't build flink-web docker image because of EOL of Ubuntu:18.10

Congxian Qiu(klion26) created FLINK-17926: - Summary: Can't build flink-web docker image because of EOL of Ubuntu:18.10 Key: FLINK-17926 URL: https://issues.apache.org/jira/browse/FLINK-17926

[jira] [Commented] (FLINK-17907) flink-table-api-java: Compilation failure

[ https://issues.apache.org/jira/browse/FLINK-17907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115989#comment-17115989 ] Chesnay Schepler commented on FLINK-17907: -- All known instances of this issue were related to

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429910310 ## File path: tools/azure-pipelines/jobs-template.yml ## @@ -163,6 +163,7 @@ jobs: IT_CASE_S3_SECRET_KEY: $(SECRET_S3_SECRET_KEY) - task:

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429909137 ## File path: tools/azure-pipelines/jobs-template.yml ## @@ -121,15 +128,34 @@ jobs: continueOnError: true # continue the build even if the cache

[jira] [Assigned] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

[ https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-17912: Assignee: (was: Dawid Wysakowicz) >

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429907884 ## File path: tools/ci/test_controller.sh ## @@ -0,0 +1,127 @@ +#!/usr/bin/env bash

[jira] [Closed] (FLINK-16695) PrometheusReporterEndToEndITCase failed on travis

[ https://issues.apache.org/jira/browse/FLINK-16695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16695. Fix Version/s: (was: 1.11.0) Resolution: Won't Fix Likely just some network

[GitHub] [flink] leonardBang commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

leonardBang commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429903878 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,340 @@ +--- Review comment: Please also add a filesystem.zh.md

[GitHub] [flink] rmetzger commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

rmetzger commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429905990 ## File path: tools/ci/watchdog.sh ## @@ -0,0 +1,122 @@ +#!/usr/bin/env bash

[GitHub] [flink] JingsongLi commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

JingsongLi commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429905623 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,340 @@ +--- +title: "FileSystem Connector" +nav-title: FileSystem Connector

[GitHub] [flink] aljoscha closed pull request #12308: [FLINK-17721][filesystems][test] Fix test instability for AbstractHadoopFileSystemITTest.

aljoscha closed pull request #12308: URL: https://github.com/apache/flink/pull/12308 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] aljoscha commented on pull request #12308: [FLINK-17721][filesystems][test] Fix test instability for AbstractHadoopFileSystemITTest.

aljoscha commented on pull request #12308: URL: https://github.com/apache/flink/pull/12308#issuecomment-633544392 Thanks for the PR! This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17721. Resolution: Fixed release-1.11: 6215e1166aa44ce178ae8c068159eb7efeb53041 master: 

[jira] [Closed] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16636. -- Resolution: Cannot Reproduce Thank you for your feedback. I closed the ticket. Please

[GitHub] [flink] leonardBang commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

leonardBang commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429903878 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,340 @@ +--- Review comment: Please also add a filesystem.zh.md

[GitHub] [flink] aljoscha commented on pull request #12308: [FLINK-17721][filesystems][test] Fix test instability for AbstractHadoopFileSystemITTest.

aljoscha commented on pull request #12308: URL: https://github.com/apache/flink/pull/12308#issuecomment-633542896 Ok, I think that's good to merge then! I'll merge. This is an automated message from the Apache Git Service.

[GitHub] [flink] xintongsong commented on pull request #12308: [FLINK-17721][filesystems][test] Fix test instability for AbstractHadoopFileSystemITTest.

xintongsong commented on pull request #12308: URL: https://github.com/apache/flink/pull/12308#issuecomment-633541577 I've increased it to 30s. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] leonardBang commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

leonardBang commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429900958 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,340 @@ +--- Review comment: please put the file in section 《Table API

[jira] [Updated] (FLINK-17925) Throws unsupported exception when using metastore commit policy for filesystem table

[ https://issues.apache.org/jira/browse/FLINK-17925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17925: - Priority: Critical (was: Major) > Throws unsupported exception when using metastore commit

[jira] [Created] (FLINK-17925) Throws unsupported exception when using metastore commit policy for filesystem table

Jingsong Lee created FLINK-17925: Summary: Throws unsupported exception when using metastore commit policy for filesystem table Key: FLINK-17925 URL: https://issues.apache.org/jira/browse/FLINK-17925

[GitHub] [flink] JingsongLi commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

JingsongLi commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429900328 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,352 @@ +--- +title: "Hadoop FileSystem Connector" +nav-title: Hadoop FileSystem

[jira] [Created] (FLINK-17924) HBase connector：we can write data to HBase table, but con`t read data from HBase

pengnengsong created FLINK-17924: Summary: HBase connector：we can write data to HBase table, but con`t read data from HBase Key: FLINK-17924 URL: https://issues.apache.org/jira/browse/FLINK-17924

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115970#comment-17115970 ] Kurt Young commented on FLINK-16636: +1 to close this for now and reopen this after it shows again.

[GitHub] [flink] zentol commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

zentol commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r429896972 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ## @@ -490,6 +490,13 @@ + "

[GitHub] [flink] zentol commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

zentol commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r429894695 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java ## @@ -265,10 +265,15 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

flinkbot edited a comment on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632492310 ## CI report: * 561af1ce20b0faef29dff2f893db99a20cd38957 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/168043961) Bot

[jira] [Commented] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

[ https://issues.apache.org/jira/browse/FLINK-16057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115957#comment-17115957 ] Roman Khachatryan commented on FLINK-16057: --- I was able to reproduce the above results both

[GitHub] [flink] zentol commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

zentol commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r429893280 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironmentTest.java ## @@ -100,6 +105,27 @@ public void

[GitHub] [flink] zentol commented on a change in pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

zentol commented on a change in pull request #12268: URL: https://github.com/apache/flink/pull/12268#discussion_r429879700 ## File path: tools/ci/watchdog.sh ## @@ -0,0 +1,122 @@ +#!/usr/bin/env bash

[GitHub] [flink] kl0u commented on pull request #12216: [FLINK-17788][scala-shell] scala shell in yarn mode is broken

kl0u commented on pull request #12216: URL: https://github.com/apache/flink/pull/12216#issuecomment-633532732 @zjffdu please check the questions in the JIRA issue. This will help the review process. This is an automated

[GitHub] [flink] leonardBang commented on pull request #12252: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

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

[jira] [Commented] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115951#comment-17115951 ] Kostas Kloudas commented on FLINK-17891: Hi [~tangshangwen], as [~fly_in_gis] said, could you

[GitHub] [flink] zhuzhurk commented on pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

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

[GitHub] [flink] carp84 commented on pull request #12312: [FLINK-15507][state backends] Activate local recovery by default

carp84 commented on pull request #12312: URL: https://github.com/apache/flink/pull/12312#issuecomment-633530920 cc @pnowojski @zhijiangW Dear release managers, I will merge this PR once the e2e test result is double checked and confirmed, FYI.

[jira] [Reopened] (FLINK-17860) Recursively remove channel state directories

[ https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-17860: > Recursively remove channel state directories >

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

freezhan commented on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-633529964 @flinkbot @rmetzger The Azure Failed message is [error log](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_apis/build/builds/2121/logs/70)

[GitHub] [flink] xintongsong commented on pull request #12308: [FLINK-17721][filesystems][test] Fix test instability for AbstractHadoopFileSystemITTest.

xintongsong commented on pull request #12308: URL: https://github.com/apache/flink/pull/12308#issuecomment-633528153 @aljoscha What value do you suggest? Maybe change it back to 30s? This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

flinkbot edited a comment on pull request #12268: URL: https://github.com/apache/flink/pull/12268#issuecomment-631512695 ## CI report: * 76f1c9f6921d3453e476dba3be53860b53a489a6 Azure:

[jira] [Assigned] (FLINK-17920) Add the Python example of Time-windowed join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17920: --- Assignee: Shuiqiang Chen > Add the Python example of Time-windowed join in Table API doc >

[jira] [Commented] (FLINK-17920) Add the Python example of Time-windowed join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115938#comment-17115938 ] Hequn Cheng commented on FLINK-17920: - [~csq] Hi, I have assigned this to you. > Add the Python

[GitHub] [flink] flinkbot edited a comment on pull request #12316: [FLINK-17896][hive] HiveCatalog can not work with new table factory because of is_generic

flinkbot edited a comment on pull request #12316: URL: https://github.com/apache/flink/pull/12316#issuecomment-633419287 ## CI report: * 2dfb5f41be178ba4f03d8f2627894d3cbc2ea519 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12319: [FLINK-17406][doc] Add documentation about dynamic table options

flinkbot edited a comment on pull request #12319: URL: https://github.com/apache/flink/pull/12319#issuecomment-633504575 ## CI report: * 222a7357e97b48ee7b7e3056c75ab60dc6d8d3e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * cce8477d3eae8bad8b4109fa1f85e810220b6d39 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * b3fd51b309c78d9dd5056eed35dc2fe388665899 UNKNOWN * 9ad4d80a2795df3e7920d31660a2dea7fe1d5ee5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12281: [FLINK-17456][hive][test] Update hive connector tests to execute DDL …

flinkbot edited a comment on pull request #12281: URL: https://github.com/apache/flink/pull/12281#issuecomment-632080083 ## CI report: * ed2a4fff3ccc48bc833bc5dbc9244b7063467275 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

flinkbot edited a comment on pull request #12028: URL: https://github.com/apache/flink/pull/12028#issuecomment-625656822 ## CI report: * 5ffb28916f4d997ff9294f2df87389c79a7d1951 Azure:

[jira] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115924#comment-17115924 ] Aljoscha Krettek commented on FLINK-12675: -- Sorry for chiming in this late but I think with

[jira] [Comment Edited] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115923#comment-17115923 ] Piotr Nowojski edited comment on FLINK-17918 at 5/25/20, 10:44 AM: --- We

[jira] [Comment Edited] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115923#comment-17115923 ] Piotr Nowojski edited comment on FLINK-17918 at 5/25/20, 10:44 AM: --- We

[jira] [Commented] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115923#comment-17115923 ] Piotr Nowojski commented on FLINK-17918: We are still evaluating the issue (it's extremely

[jira] [Updated] (FLINK-10740) FLIP-27: Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10740: - Summary: FLIP-27: Refactor Source Interface (was: Refactor Source Interface) >

[GitHub] [flink] flinkbot edited a comment on pull request #12317: [FLINK-17819][yarn] Fix error msg for yarn deployments when hadoop not in classpath

flinkbot edited a comment on pull request #12317: URL: https://github.com/apache/flink/pull/12317#issuecomment-633460641 ## CI report: * 284e50d0f89d2ad4647a2f22ab68ec10459cf612 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

flinkbot edited a comment on pull request #12314: URL: https://github.com/apache/flink/pull/12314#issuecomment-633403476 ## CI report: * b7a68f0f07ab9bb2abc3182d72c0dc80ed59dda1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12309: [FLINK-17889][hive] Hive can not work with filesystem connector

flinkbot edited a comment on pull request #12309: URL: https://github.com/apache/flink/pull/12309#issuecomment-633345845 ## CI report: * f6aec0584d0e5ba97e7b5c4707d93d97465b4704 Azure:

[GitHub] [flink] flinkbot commented on pull request #12319: [FLINK-17406][doc] Add documentation about dynamic table options

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

[GitHub] [flink] flinkbot edited a comment on pull request #12315: [FLINK-17917][yarn] Ignore the external resource with a value of 0 in…

flinkbot edited a comment on pull request #12315: URL: https://github.com/apache/flink/pull/12315#issuecomment-633409833 ## CI report: * 9108fb04b2b8cc0eebc941f7e179fcffed296138 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

flinkbot edited a comment on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632492310 ## CI report: * cda1c81b986bf87f0fd95abfdc60638813a43c0b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/167718532) *

[GitHub] [flink] flinkbot edited a comment on pull request #12281: [FLINK-17456][hive][test] Update hive connector tests to execute DDL …

flinkbot edited a comment on pull request #12281: URL: https://github.com/apache/flink/pull/12281#issuecomment-632080083 ## CI report: * ed2a4fff3ccc48bc833bc5dbc9244b7063467275 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

flinkbot edited a comment on pull request #12288: URL: https://github.com/apache/flink/pull/12288#issuecomment-632456377 ## CI report: * 08bc3bf4a17f2e6a99ce5ff3af91ae1341254391 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

flinkbot edited a comment on pull request #12260: URL: https://github.com/apache/flink/pull/12260#issuecomment-631229314 ## CI report: * a3a71c5920058f4bbbdc5f11022b8b7736b291cf UNKNOWN * cb99a301a3d1625909fbf94e8543e3a7b0726685 Azure:

[jira] [Comment Edited] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlo

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115909#comment-17115909 ] Yang Wang edited comment on FLINK-13009 at 5/25/20, 10:20 AM: -- YARN-7007

[GitHub] [flink] aljoscha commented on pull request #12308: [FLINK-17721][filesystems][test] Fix test instability for AbstractHadoopFileSystemITTest.

aljoscha commented on pull request #12308: URL: https://github.com/apache/flink/pull/12308#issuecomment-633498751 The changes look good! But maybe 5 seconds of deadline is not enough? This is an automated message from the

[jira] [Closed] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-17862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17862. Resolution: Not A Problem > The internal class StreamingRuntimeContext is leaked in >

[jira] [Assigned] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17886: Assignee: Yichao Yang > Update Chinese documentation for new

[jira] [Updated] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15609: - Priority: Critical (was: Major) > Add blink built-in functions from FlinkSqlOperatorTable to

[GitHub] [flink] flinkbot commented on pull request #12319: [FLINK-17406][doc] Add documentation about dynamic table options

flinkbot commented on pull request #12319: URL: https://github.com/apache/flink/pull/12319#issuecomment-633497723 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] aljoscha commented on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

aljoscha commented on pull request #11972: URL: https://github.com/apache/flink/pull/11972#issuecomment-633497246 I agree about nulls in general, but in this case the code was just creating new objects internally, which comes with some overhead.

[GitHub] [flink] flinkbot edited a comment on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

flinkbot edited a comment on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632492310 ## CI report: * cda1c81b986bf87f0fd95abfdc60638813a43c0b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/167718532) *

[GitHub] [flink] flinkbot edited a comment on pull request #12318: [FLINK-17867][hive][test] Add hdfs dependency to hive-3.1.1 test

flinkbot edited a comment on pull request #12318: URL: https://github.com/apache/flink/pull/12318#issuecomment-633479850 ## CI report: * c395d57a1a2a57b8f9970b64d8241e033ecdd295 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * 967561896814c71906c96bb77e7d9ac76fe7fd26 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

flinkbot edited a comment on pull request #12288: URL: https://github.com/apache/flink/pull/12288#issuecomment-632456377 ## CI report: * 08bc3bf4a17f2e6a99ce5ff3af91ae1341254391 Azure:

[jira] [Commented] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots th

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115909#comment-17115909 ] Yang Wang commented on FLINK-13009: --- YARN-7007 has been merged to branch 2.8. However, AFAIK, the

[jira] [Updated] (FLINK-17406) Add documentation about dynamic table options

[ https://issues.apache.org/jira/browse/FLINK-17406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17406: --- Labels: pull-request-available (was: ) > Add documentation about dynamic table options >

[GitHub] [flink] danny0405 opened a new pull request #12319: [FLINK-17406][doc] Add documentation about dynamic table options

danny0405 opened a new pull request #12319: URL: https://github.com/apache/flink/pull/12319 Add documentation for dynamic table options. This is an automated message from the Apache Git Service. To respond to the message,

<    1   2   3   4   5   >