[GitHub] [flink] flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API

flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API URL: https://github.com/apache/flink/pull/11061#issuecomment-584620778 ## CI report: * 06ba58a8738f28535d4858b5a5efc863cda620f9 Travis:

[GitHub] [flink] godfreyhe commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource

godfreyhe commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource URL: https://github.com/apache/flink/pull/10005#issuecomment-587044898 sorry for the late reply. the changes looks good to me. I have a minor question: It's

[GitHub] [flink] flinkbot edited a comment on issue #11092: [FLINK-15999] Extract “Concepts” material from API/Library sections and start proper concepts section

flinkbot edited a comment on issue #11092: [FLINK-15999] Extract “Concepts” material from API/Library sections and start proper concepts section URL: https://github.com/apache/flink/pull/11092#issuecomment-586205307 ## CI report: * c67d117a5d7d1ef8bc7e3c07b1611b554a3c821e

[jira] [Commented] (FLINK-16065) Unignore FileUtilsTest.testDeleteDirectoryConcurrently()

[ https://issues.apache.org/jira/browse/FLINK-16065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038446#comment-17038446 ] Robert Metzger commented on FLINK-16065: Is this ticket resolved through

[jira] [Updated] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16051: -- Priority: Minor (was: Major) > Subtask ID in Overview-Subtasks should start from 1 >

[jira] [Created] (FLINK-16123) Add routable Kafka connector

Igal Shilman created FLINK-16123: Summary: Add routable Kafka connector Key: FLINK-16123 URL: https://issues.apache.org/jira/browse/FLINK-16123 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038508#comment-17038508 ] Stephan Ewen commented on FLINK-16030: -- The original network stack philosophy was that failures are

[GitHub] [flink] flinkbot commented on issue #11113: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint

flinkbot commented on issue #3: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/3#issuecomment-587037976 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] libenchao commented on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private

libenchao commented on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private URL: https://github.com/apache/flink/pull/11080#issuecomment-587041431 @wuchong fixed check style problem. will do the check before pushing code to github next time.

[jira] [Comment Edited] (FLINK-16006) Add host blacklist support for Flink YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-16006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038435#comment-17038435 ] Robert Metzger edited comment on FLINK-16006 at 2/17/20 3:21 PM: - This

[jira] [Commented] (FLINK-16006) Add host blacklist support for Flink YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-16006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038435#comment-17038435 ] Robert Metzger commented on FLINK-16006: What's the scope of this ticket? Are you suggesting to

[GitHub] [flink] flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private

flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private URL: https://github.com/apache/flink/pull/11080#issuecomment-585612191 ## CI report: * 8bed2dbf577c649ad3e6b411730763c90a898a5d Travis:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r380292049 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

[GitHub] [flink] yanghua opened a new pull request #11113: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint

yanghua opened a new pull request #3: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/3 ## What is the purpose of the change *This pull request updates CEPMigrationTest to restore from 1.10 savepoint*

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038512#comment-17038512 ] Zhijiang commented on FLINK-16030: -- Considering the direction of "richer exception handling" [~sewen] 

[GitHub] [flink] flinkbot commented on issue #11113: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint

flinkbot commented on issue #3: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/3#issuecomment-587050451 ## CI report: * b9170333187848755d9122fca45e1ce7a5cf0483 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

flinkbot edited a comment on issue #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#issuecomment-587035354 ## CI report: * dba261b36b56aedec766097042dbe40858e5fc8c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11110: [FLINK-16111][k8s] Fix Kubernetes deployment not respecting 'taskmanager.cpu.cores'.

flinkbot edited a comment on issue #0: [FLINK-16111][k8s] Fix Kubernetes deployment not respecting 'taskmanager.cpu.cores'. URL: https://github.com/apache/flink/pull/0#issuecomment-586973533 ## CI report: * c330e78bc64b398d2ff483ab3f996db3958ec2fd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11113: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint

flinkbot edited a comment on issue #3: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/3#issuecomment-587050451 ## CI report: * b9170333187848755d9122fca45e1ce7a5cf0483 Travis:

[GitHub] [flink] StephanEwen commented on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

StephanEwen commented on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-587100971 Thanks you for the reviews. Merging this...

[jira] [Commented] (FLINK-16115) Aliyun oss filesystem could not work with plugin mechanism

[ https://issues.apache.org/jira/browse/FLINK-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038534#comment-17038534 ] Bowen Li commented on FLINK-16115: -- [~fly_in_gis] can you help find OSS people to fix this bug? Also

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis:

[GitHub] [flink] StephanEwen closed pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

StephanEwen closed pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095 This is an automated message from the Apache Git Service. To

[jira] [Resolved] (FLINK-16113) ExpressionReducer shouldn't escape the reduced string value

[ https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16113. - Resolution: Fixed Fixed in - master(1.11.0): 22899a153c774bd7d491b569e26c1a2e9fd8cd85 - 1.10.1:

[GitHub] [flink] flinkbot commented on issue #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

flinkbot commented on issue #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#issuecomment-587035354 ## CI report: * dba261b36b56aedec766097042dbe40858e5fc8c UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[GitHub] [flink] StephanEwen commented on a change in pull request #11048: [FLINK-15966][runtime] Capture callstacks for RPC ask() calls to improve exceptions.

StephanEwen commented on a change in pull request #11048: [FLINK-15966][runtime] Capture callstacks for RPC ask() calls to improve exceptions. URL: https://github.com/apache/flink/pull/11048#discussion_r380311882 ## File path:

[jira] [Created] (FLINK-16122) build system: transfer.sh uploads are unstable (February 2020)

Robert Metzger created FLINK-16122: -- Summary: build system: transfer.sh uploads are unstable (February 2020) Key: FLINK-16122 URL: https://issues.apache.org/jira/browse/FLINK-16122 Project: Flink

[GitHub] [flink] rkhachatryan commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

rkhachatryan commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-587055715 Thanks for pointing it out. Previously, `CFRO` **was** chained using `HEAD` strategy (see

[GitHub] [flink] flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private

flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private URL: https://github.com/apache/flink/pull/11080#issuecomment-585612191 ## CI report: * 8bed2dbf577c649ad3e6b411730763c90a898a5d Travis:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r380292049 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k…

flinkbot edited a comment on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k… URL: https://github.com/apache/flink/pull/11101#issuecomment-586719516 ## CI report: * 994704592f9aa725e5370210c6df1c6de0c2ddc8 Travis:

[jira] [Commented] (FLINK-15982) 'Quickstarts Java nightly end-to-end test' is failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038442#comment-17038442 ] Robert Metzger commented on FLINK-15982: Should be fixed now in

[jira] [Resolved] (FLINK-15982) 'Quickstarts Java nightly end-to-end test' is failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-15982. Resolution: Fixed > 'Quickstarts Java nightly end-to-end test' is failed on travis >

[GitHub] [flink] flinkbot edited a comment on issue #11113: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint

flinkbot edited a comment on issue #3: [FLINK-15709] Update CEPMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/3#issuecomment-587050451 ## CI report: * b9170333187848755d9122fca45e1ce7a5cf0483 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

flinkbot edited a comment on issue #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#issuecomment-587035354 ## CI report: * dba261b36b56aedec766097042dbe40858e5fc8c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[jira] [Updated] (FLINK-16115) Aliyun oss filesystem could not work with plugin mechanism

[ https://issues.apache.org/jira/browse/FLINK-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16115: - Priority: Critical (was: Major) > Aliyun oss filesystem could not work with plugin mechanism >

[GitHub] [flink] flinkbot edited a comment on issue #11110: [FLINK-16111][k8s] Fix Kubernetes deployment not respecting 'taskmanager.cpu.cores'.

flinkbot edited a comment on issue #0: [FLINK-16111][k8s] Fix Kubernetes deployment not respecting 'taskmanager.cpu.cores'. URL: https://github.com/apache/flink/pull/0#issuecomment-586973533 ## CI report: * c330e78bc64b398d2ff483ab3f996db3958ec2fd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k…

flinkbot edited a comment on issue #11101: [FLINK-16068][table-planner-blink] Fix computed column with escaped k… URL: https://github.com/apache/flink/pull/11101#issuecomment-586719516 ## CI report: * 994704592f9aa725e5370210c6df1c6de0c2ddc8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11110: [FLINK-16111][k8s] Fix Kubernetes deployment not respecting 'taskmanager.cpu.cores'.

flinkbot edited a comment on issue #0: [FLINK-16111][k8s] Fix Kubernetes deployment not respecting 'taskmanager.cpu.cores'. URL: https://github.com/apache/flink/pull/0#issuecomment-586973533 ## CI report: * c330e78bc64b398d2ff483ab3f996db3958ec2fd Travis:

[jira] [Comment Edited] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/17/20 4:31 PM: -- Root cause

[jira] [Commented] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise commented on FLINK-16014: - Preliminary assessment: Root cause is a bug in JDK8.

[jira] [Comment Edited] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/17/20 4:43 PM: -- Root cause

[GitHub] [flink] StephanEwen commented on a change in pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

StephanEwen commented on a change in pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#discussion_r380308235 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

StephanEwen commented on a change in pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#discussion_r380308275 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private

flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private URL: https://github.com/apache/flink/pull/11080#issuecomment-585612191 ## CI report: * 8bed2dbf577c649ad3e6b411730763c90a898a5d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests

flinkbot edited a comment on issue #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests URL: https://github.com/apache/flink/pull/11096#issuecomment-586300012 ## CI report: * 6f1f37ee8baceee6d08b4c4d2439d46f2c144688 Travis:

[jira] [Updated] (FLINK-15709) Update CEPMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15709: --- Labels: pull-request-available (was: ) > Update CEPMigrationTest to restore from 1.10

[GitHub] [flink] flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API

flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API URL: https://github.com/apache/flink/pull/11061#issuecomment-584620778 ## CI report: * 06ba58a8738f28535d4858b5a5efc863cda620f9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API

flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API URL: https://github.com/apache/flink/pull/11061#issuecomment-584620778 ## CI report: * 06ba58a8738f28535d4858b5a5efc863cda620f9 Travis:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r380294652 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r380294890 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r380294401 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis:

[jira] [Commented] (FLINK-15835) OSS filesystems bundles entire hadoop-common

[ https://issues.apache.org/jira/browse/FLINK-15835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038615#comment-17038615 ] Andrey Zagrebin commented on FLINK-15835: - Is it also to be merged into 1.9 and 1.10? > OSS

[jira] [Commented] (FLINK-15835) OSS filesystems bundles entire hadoop-common

[ https://issues.apache.org/jira/browse/FLINK-15835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038657#comment-17038657 ] Chesnay Schepler commented on FLINK-15835: -- This is a fairly invasive dependency change that I

[GitHub] [flink] StephanEwen commented on a change in pull request #11048: [FLINK-15966][runtime] Capture callstacks for RPC ask() calls to improve exceptions.

StephanEwen commented on a change in pull request #11048: [FLINK-15966][runtime] Capture callstacks for RPC ask() calls to improve exceptions. URL: https://github.com/apache/flink/pull/11048#discussion_r380322869 ## File path:

[jira] [Updated] (FLINK-15349) add "create catalog" DDL support

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15349: - Summary: add "create catalog" DDL support (was: add "create catalog DDL support in FLIP-69) > add

[jira] [Updated] (FLINK-15349) add "create catalog DDL support in FLIP-69

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15349: - Summary: add "create catalog DDL support in FLIP-69 (was: add Catalog DDL support in FLIP-69) > add

[GitHub] [flink] pnowojski merged pull request #11111: [FLINK-16118][table-planner-blink] Ignore order for FunctionITCase.testDynamicTableFunction

pnowojski merged pull request #1: [FLINK-16118][table-planner-blink] Ignore order for FunctionITCase.testDynamicTableFunction URL: https://github.com/apache/flink/pull/1 This is an automated message from the Apache

[jira] [Closed] (FLINK-16118) testDynamicTableFunction fails

[ https://issues.apache.org/jira/browse/FLINK-16118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16118. -- Fix Version/s: 1.11.0 Resolution: Fixed merged commit e099310 >

[GitHub] [flink] zentol commented on issue #5399: [FLINK-6206] [runtime] Use LOG.error() when logging failure state changes

zentol commented on issue #5399: [FLINK-6206] [runtime] Use LOG.error() when logging failure state changes URL: https://github.com/apache/flink/pull/5399#issuecomment-587130019 Subsumed by #11042. This is an automated

[GitHub] [flink] zentol closed pull request #5399: [FLINK-6206] [runtime] Use LOG.error() when logging failure state changes

zentol closed pull request #5399: [FLINK-6206] [runtime] Use LOG.error() when logging failure state changes URL: https://github.com/apache/flink/pull/5399 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] bowenli86 commented on issue #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i…

bowenli86 commented on issue #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i… URL: https://github.com/apache/flink/pull/11093#issuecomment-587118599 Hi @lirui-apache thanks for the PR, but I'm not sure about it. If we are concerned about the input function

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private

flinkbot edited a comment on issue #11080: [FLINK-15988][json] Make JsonRowSerializationSchema's constructor private URL: https://github.com/apache/flink/pull/11080#issuecomment-585612191 ## CI report: * 8bed2dbf577c649ad3e6b411730763c90a898a5d Travis:

[GitHub] [flink] rkhachatryan commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

rkhachatryan commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-587133618 CI failure on travis was caused by https://issues.apache.org/jira/browse/FLINK-16118

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis:

[GitHub] [flink] bowenli86 edited a comment on issue #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i…

bowenli86 edited a comment on issue #11093: [FLINK-16055][hive] Avoid catalog functions when listing Hive built-i… URL: https://github.com/apache/flink/pull/11093#issuecomment-587118599 Hi @lirui-apache thanks for the PR, but I'm not sure about it. If concerned about argument of the

[GitHub] [flink-statefun] sjwiesman edited a comment on issue #22: [FLINK-16002][statefun][testutil] Add stateful functions test utilities

sjwiesman edited a comment on issue #22: [FLINK-16002][statefun][testutil] Add stateful functions test utilities URL: https://github.com/apache/flink-statefun/pull/22#issuecomment-587144546 Gordon, this package game out of a need to unit test the functions for my statefun workshop. If it

[GitHub] [flink-statefun] sjwiesman commented on issue #22: [FLINK-16002][statefun][testutil] Add stateful functions test utilities

sjwiesman commented on issue #22: [FLINK-16002][statefun][testutil] Add stateful functions test utilities URL: https://github.com/apache/flink-statefun/pull/22#issuecomment-587144546 Gordon, this package game out of a need to unit test the functions for my statefun workshop. If it helps,

[jira] [Assigned] (FLINK-15349) add Catalog DDL support in FLIP-69

[ https://issues.apache.org/jira/browse/FLINK-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15349: Assignee: Bowen Li (was: Kurt Young) > add Catalog DDL support in FLIP-69 >

[jira] [Commented] (FLINK-16115) Aliyun oss filesystem could not work with plugin mechanism

[ https://issues.apache.org/jira/browse/FLINK-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038660#comment-17038660 ] Chesnay Schepler commented on FLINK-16115: -- ping [~AHeise]; we had the same problem with S3

[jira] [Commented] (FLINK-16006) Add host blacklist support for Flink YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-16006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038672#comment-17038672 ] Zhenqiu Huang commented on FLINK-16006: --- [~rmetzger] Thanks for the feedback. blocklist should be

[jira] [Commented] (FLINK-16117) Avoid register source in TableTestBase#addTableSource

[ https://issues.apache.org/jira/browse/FLINK-16117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038729#comment-17038729 ] Zhenghua Gao commented on FLINK-16117: -- Most of these tests are plan tests and there is no input

[jira] [Commented] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

[ https://issues.apache.org/jira/browse/FLINK-14649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038746#comment-17038746 ] Jiangjie Qin commented on FLINK-14649: -- It looks that the patch changed the {{zookeeper.connect}}

[jira] [Created] (FLINK-16125) Make zookeeper.connect optional for Kafka connectors

Jiangjie Qin created FLINK-16125: Summary: Make zookeeper.connect optional for Kafka connectors Key: FLINK-16125 URL: https://issues.apache.org/jira/browse/FLINK-16125 Project: Flink Issue

[jira] [Commented] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038770#comment-17038770 ] Yang Wang commented on FLINK-16005: --- [~ZhenqiuHuang] This inspires me that maybe we could add a

[GitHub] [flink] flinkbot commented on issue #11116: [FLINK-15349] add 'create catalog' DDL to blink planner

flinkbot commented on issue #6: [FLINK-15349] add 'create catalog' DDL to blink planner URL: https://github.com/apache/flink/pull/6#issuecomment-587279527 ## CI report: * 7d09ea38e74e801907d3f1da660c41f5cf739a29 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #11115: [FLINK-15710] Update BucketingSinkMigrationTest to restore from 1.10 savepoint

flinkbot edited a comment on issue #5: [FLINK-15710] Update BucketingSinkMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/5#issuecomment-587272600 ## CI report: * 6dc4e6aa324cff1a51061ac1db4add02e346ef9d Travis:

[jira] [Commented] (FLINK-16125) Make zookeeper.connect optional for Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-16125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038796#comment-17038796 ] Jiangjie Qin commented on FLINK-16125: -- Given this is an accidental unexpected change, I'd suggest

[jira] [Created] (FLINK-16133) Translate "Azure Blob Storage" page of "File Systems" into Chinese

Jark Wu created FLINK-16133: --- Summary: Translate "Azure Blob Storage" page of "File Systems" into Chinese Key: FLINK-16133 URL: https://issues.apache.org/jira/browse/FLINK-16133 Project: Flink

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038842#comment-17038842 ] Rafi Aroch commented on FLINK-14881:  [~sewen] are there any concerns in adding this? If there are

[GitHub] [flink] zgq25302111 opened a new pull request #11114: translate some into Chinese

zgq25302111 opened a new pull request #4: translate some into Chinese URL: https://github.com/apache/flink/pull/4 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way

[GitHub] [flink] flinkbot commented on issue #11114: translate some into Chinese

flinkbot commented on issue #4: translate some into Chinese URL: https://github.com/apache/flink/pull/4#issuecomment-587208532 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

[jira] [Assigned] (FLINK-16124) Add a AWS Kinesis Stateful Functions Ingress

[ https://issues.apache.org/jira/browse/FLINK-16124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-16124: --- Assignee: Tzu-Li (Gordon) Tai > Add a AWS Kinesis Stateful Functions

[jira] [Updated] (FLINK-16124) Add a AWS Kinesis Stateful Functions Ingress

[ https://issues.apache.org/jira/browse/FLINK-16124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-16124: Description: AWS Kinesis is also a popularly used sources for Apache Flink

[jira] [Created] (FLINK-16124) Add a AWS Kinesis Stateful Functions Ingress

Tzu-Li (Gordon) Tai created FLINK-16124: --- Summary: Add a AWS Kinesis Stateful Functions Ingress Key: FLINK-16124 URL: https://issues.apache.org/jira/browse/FLINK-16124 Project: Flink

[GitHub] [flink] buptljy commented on issue #11104: [FLINK-16051] Subtask ID in Overview-Subtasks should start from 1

buptljy commented on issue #11104: [FLINK-16051] Subtask ID in Overview-Subtasks should start from 1 URL: https://github.com/apache/flink/pull/11104#issuecomment-587245879 > I remember a similar discussion in the past (can't find it right now), with the conclusion being that the only

[GitHub] [flink] buptljy closed pull request #11104: [FLINK-16051] Subtask ID in Overview-Subtasks should start from 1

buptljy closed pull request #11104: [FLINK-16051] Subtask ID in Overview-Subtasks should start from 1 URL: https://github.com/apache/flink/pull/11104 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] wangxiyuan commented on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

wangxiyuan commented on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-587245600 Thanks for your review. Just fixed the merge conflic. @zentol can you take a look? Thank you.

  1   2   3   4   5   >