[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis: [CANCELED](https://travis-ci.

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033420#comment-17033420 ] Till Rohrmann commented on FLINK-12122: --- I guess this depends a bit on how fast yo

[jira] [Commented] (FLINK-15924) Detect and log blocking main thread operations

[ https://issues.apache.org/jira/browse/FLINK-15924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033414#comment-17033414 ] Till Rohrmann commented on FLINK-15924: --- This sounds like a good idea if we manage

[GitHub] [flink] flinkbot edited a comment on issue #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode.

flinkbot edited a comment on issue #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode. URL: https://github.com/apache/flink/pull/11045#issuecomment-583987124 ## CI report: * cdbff85e56a1d0982efadd2d827fa84331afadf8 Travis: [FAILURE](http

[GitHub] [flink] flinkbot commented on issue #11046: [hotfix][docs] Fix Readme Description in the State Machine Example

flinkbot commented on issue #11046: [hotfix][docs] Fix Readme Description in the State Machine Example URL: https://github.com/apache/flink/pull/11046#issuecomment-583996030 ## CI report: * e3029e2dadeeef6f32ed04c34000547136f08a36 UNKNOWN Bot commands The @flinkbo

[jira] [Updated] (FLINK-15963) Reuse the same ByteBuf while writing the BufferResponse header

[ https://issues.apache.org/jira/browse/FLINK-15963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15963: - Description: On sender side while writing the BufferResponse message, it always allocates the new direc

[jira] [Updated] (FLINK-15963) Reuse the same ByteBuf while writing the BufferResponse header

[ https://issues.apache.org/jira/browse/FLINK-15963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15963: - Description: On sender side while writing the BufferResponse message, it always allocates the new direc

[jira] [Assigned] (FLINK-15964) Getting previous stage in notFollowedBy may throw exception

[ https://issues.apache.org/jira/browse/FLINK-15964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-15964: Assignee: shuai.xu > Getting previous stage in notFollowedBy may throw exception > --

[GitHub] [flink] becketqin commented on issue #11046: [hotfix][docs] Fix Readme Description in the State Machine Example

becketqin commented on issue #11046: [hotfix][docs] Fix Readme Description in the State Machine Example URL: https://github.com/apache/flink/pull/11046#issuecomment-583991818 @flinkbot approve all This is an automated message

[GitHub] [flink] docete commented on issue #11021: [FLINK-15546][table-planner-blink] Fix obscure error message from Sca…

docete commented on issue #11021: [FLINK-15546][table-planner-blink] Fix obscure error message from Sca… URL: https://github.com/apache/flink/pull/11021#issuecomment-583991670 Azure fails for unstable test and fixed in https://issues.apache.org/jira/browse/FLINK-15811

[GitHub] [flink] becketqin merged pull request #11046: [hotfix][docs] Fix Readme Description in the State Machine Example

becketqin merged pull request #11046: [hotfix][docs] Fix Readme Description in the State Machine Example URL: https://github.com/apache/flink/pull/11046 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] docete edited a comment on issue #11021: [FLINK-15546][table-planner-blink] Fix obscure error message from Sca…

docete edited a comment on issue #11021: [FLINK-15546][table-planner-blink] Fix obscure error message from Sca… URL: https://github.com/apache/flink/pull/11021#issuecomment-583991670 @wuchong Azure fails for unstable test and fixed in https://issues.apache.org/jira/browse/FLINK-15811 ---

[jira] [Commented] (FLINK-15941) ConfluentSchemaRegistryCoder should not perform HTTP requests for all request

[ https://issues.apache.org/jira/browse/FLINK-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033411#comment-17033411 ] Dawid Wysakowicz commented on FLINK-15941: -- I assigned you the ticket [~swhelan

[jira] [Assigned] (FLINK-15941) ConfluentSchemaRegistryCoder should not perform HTTP requests for all request

[ https://issues.apache.org/jira/browse/FLINK-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-15941: Assignee: Stephen Whelan > ConfluentSchemaRegistryCoder should not perform HTTP r

[jira] [Created] (FLINK-15964) Getting previous stage in notFollowedBy may throw exception

shuai.xu created FLINK-15964: Summary: Getting previous stage in notFollowedBy may throw exception Key: FLINK-15964 URL: https://issues.apache.org/jira/browse/FLINK-15964 Project: Flink Issue Ty

[jira] [Assigned] (FLINK-15962) Reduce the default chunk size in netty stack

[ https://issues.apache.org/jira/browse/FLINK-15962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-15962: Assignee: Yun Gao > Reduce the default chunk size in netty stack > --

[jira] [Assigned] (FLINK-15912) Add Context to improve TableSourceFactory and TableSinkFactory

[ https://issues.apache.org/jira/browse/FLINK-15912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15912: --- Assignee: Jingsong Lee > Add Context to improve TableSourceFactory and TableSinkFactory >

[jira] [Created] (FLINK-15963) Reuse the same ByteBuf while writing the BufferResponse header

zhijiang created FLINK-15963: Summary: Reuse the same ByteBuf while writing the BufferResponse header Key: FLINK-15963 URL: https://issues.apache.org/jira/browse/FLINK-15963 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #11046: [hotfix][docs] Fix Readme Description in the State Machine Example

flinkbot commented on issue #11046: [hotfix][docs] Fix Readme Description in the State Machine Example URL: https://github.com/apache/flink/pull/11046#issuecomment-583989732 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] curcur opened a new pull request #11046: [hotfix][docs] Fix Readme Description in the State Machine Example

curcur opened a new pull request #11046: [hotfix][docs] Fix Readme Description in the State Machine Example URL: https://github.com/apache/flink/pull/11046 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] docete commented on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

docete commented on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-583988903 @wuchong pls take another look. This is an autom

[GitHub] [flink] docete commented on a change in pull request #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

docete commented on a change in pull request #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#discussion_r376897708 ## File path: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdb

[GitHub] [flink] flinkbot commented on issue #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode.

flinkbot commented on issue #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode. URL: https://github.com/apache/flink/pull/11045#issuecomment-583987124 ## CI report: * cdbff85e56a1d0982efadd2d827fa84331afadf8 UNKNOWN Bot command

[GitHub] [flink] flinkbot edited a comment on issue #11031: [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs

flinkbot edited a comment on issue #11031: [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs URL: https://github.com/apache/flink/pull/11031#issuecomment-582869867 ## CI report: * 80543b67036d2b2d589bfc677e583199b96e4a61 Travis:

[jira] [Created] (FLINK-15962) Reduce the default chunk size in netty stack

zhijiang created FLINK-15962: Summary: Reduce the default chunk size in netty stack Key: FLINK-15962 URL: https://issues.apache.org/jira/browse/FLINK-15962 Project: Flink Issue Type: Improvement

[GitHub] [flink] docete commented on a change in pull request #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

docete commented on a change in pull request #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#discussion_r376894169 ## File path: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdb

[jira] [Comment Edited] (FLINK-15948) Resource will be wasted when the task manager memory is not a multiple of Yarn minimum allocation

[ https://issues.apache.org/jira/browse/FLINK-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033407#comment-17033407 ] Xintong Song edited comment on FLINK-15948 at 2/10/20 7:05 AM: ---

[jira] [Commented] (FLINK-15948) Resource will be wasted when the task manager memory is not a multiple of Yarn minimum allocation

[ https://issues.apache.org/jira/browse/FLINK-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033407#comment-17033407 ] Xintong Song commented on FLINK-15948: -- Hi [~fly_in_gis], I'm not sure about overw

[GitHub] [flink] docete commented on a change in pull request #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

docete commented on a change in pull request #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#discussion_r376893098 ## File path: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdb

[jira] [Commented] (FLINK-15912) Add Context to improve TableSourceFactory and TableSinkFactory

[ https://issues.apache.org/jira/browse/FLINK-15912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033406#comment-17033406 ] Jingsong Lee commented on FLINK-15912: -- [~jark] Can you assign this to me? > Add

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

zhijiangW 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_r376890778 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] flinkbot commented on issue #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode.

flinkbot commented on issue #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode. URL: https://github.com/apache/flink/pull/11045#issuecomment-583981179 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

[jira] [Updated] (FLINK-15579) Support UpsertStreamTableSink on Blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15579: --- Labels: pull-request-available (was: ) > Support UpsertStreamTableSink on Blink batch mode

[GitHub] [flink] nezhazheng opened a new pull request #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode.

nezhazheng opened a new pull request #11045: [FLINK-15579][table-planner-blink] Support UpsertStreamTableSink on Blink batch mode. URL: https://github.com/apache/flink/pull/11045 ## What is the purpose of the change Blink batch mode do not support jdbc sink right now . Becuse

[GitHub] [flink] flinkbot edited a comment on issue #11031: [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs

flinkbot edited a comment on issue #11031: [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs URL: https://github.com/apache/flink/pull/11031#issuecomment-582869867 ## CI report: * 80543b67036d2b2d589bfc677e583199b96e4a61 Travis:

[jira] [Updated] (FLINK-15778) SQL Client end-to-end test for Kafka 0.10 nightly run hung on travis

[ https://issues.apache.org/jira/browse/FLINK-15778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15778: -- Fix Version/s: (was: 1.10.0) > SQL Client end-to-end test for Kafka 0.10 nightly run hung on travis >

[jira] [Updated] (FLINK-15772) Shaded Hadoop S3A with credentials provider end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15772: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Shaded Hadoop S3A with credentials provider end-t

[jira] [Updated] (FLINK-15178) TaskExecutor crashes due to mmap allocation failure for BLOCKING shuffle

[ https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15178: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > TaskExecutor crashes du

[jira] [Updated] (FLINK-15861) Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15861: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Change TableEnvironmentImpl to StreamTableaEnviro

[jira] [Updated] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

[ https://issues.apache.org/jira/browse/FLINK-15474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15474: -- Fix Version/s: (was: 1.10.0) 1.11.0 > In TypeSerializerUpgradeTestBase, create serializ

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15471: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > HA e2e check for empty

[jira] [Updated] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14816: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Add thread dump feature for taskmanager > ---

[jira] [Updated] (FLINK-14685) ZooKeeperCheckpointIDCounter forever broken if once loss connection with ZK

[ https://issues.apache.org/jira/browse/FLINK-14685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14685: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > ZooKeeperCheckpointIDCo

[jira] [Updated] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

[ https://issues.apache.org/jira/browse/FLINK-14592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14592: -- Fix Version/s: (was: 1.10.0) 1.11.0 > FlinkKafkaInternalProducerITCase fails with Bind

[jira] [Updated] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14223: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > Kafka010ProducerITCase>

[jira] [Updated] (FLINK-14369) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14369: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > KafkaProducerAtLeastOnc

[jira] [Updated] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14159: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > flink rocksdb StreamCom

[jira] [Updated] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar

[ https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12148: -- Fix Version/s: (was: 1.10.0) 1.11.0 1.10.1 > Give precedence to spec

[jira] [Updated] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12546: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Base Docker images on `library/flink` > -

[GitHub] [flink] zhijiangW commented on issue #11031: [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs

zhijiangW commented on issue #11031: [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs URL: https://github.com/apache/flink/pull/11031#issuecomment-583971866 Thanks for the review @pnowojski . I have updated the codes for supplementing the

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/10/20 6:08 AM:

[jira] [Updated] (FLINK-11911) KafkaTopicPartition is not a valid POJO

[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-11911: -- Fix Version/s: (was: 1.10.0) 1.11.0 > KafkaTopicPartition is not a valid POJO > ---

[jira] [Updated] (FLINK-11911) KafkaTopicPartition is not a valid POJO

[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-11911: -- Fix Version/s: 1.10.1 > KafkaTopicPartition is not a valid POJO > --- > >

[jira] [Commented] (FLINK-10725) Support for Java 11 (LTS)

[ https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033386#comment-17033386 ] Yu Li commented on FLINK-10725: --- [~chesnay] Since the fix version of this feature is 1.10.

[GitHub] [flink] flinkbot edited a comment on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1

flinkbot edited a comment on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1 URL: https://github.com/apache/flink/pull/7579#issuecomment-583947053 ## CI report: * d737dfd230d36adf1a5c5c2c0c960d3fd3c5a30e Travis: [SUCCESS](https://travis-c

[jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests

[ https://issues.apache.org/jira/browse/FLINK-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14920: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Set up environment to run performance e2e tests >

[jira] [Updated] (FLINK-14918) Add performance e2e test module and scripts

[ https://issues.apache.org/jira/browse/FLINK-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14918: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Add performance e2e test module and scripts > ---

[jira] [Updated] (FLINK-14919) Add performance e2e test suite for basic operations

[ https://issues.apache.org/jira/browse/FLINK-14919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14919: -- Fix Version/s: (was: 1.10.0) 1.11.0 > Add performance e2e test suite for basic operatio

[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: [FAILURE](https://t

[GitHub] [flink] flinkbot edited a comment on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner

flinkbot edited a comment on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner URL: https://github.com/apache/flink/pull/11044#issuecomment-583941299 ## CI report: * 507d7bb6076e4bc176c46f52e823762d264f3c28 Travis: [SUCCESS](https

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

zhijiangW 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_r376870439 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/10/20 5:01 AM:

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033373#comment-17033373 ] Caizhi Weng commented on FLINK-14807: - Hi dear Flink community, I'm digging this up

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14807: Attachment: table-collect.png > Add Table#collect api for fetching data to client > --

[GitHub] [flink] flinkbot edited a comment on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1

flinkbot edited a comment on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1 URL: https://github.com/apache/flink/pull/7579#issuecomment-583947053 ## CI report: * d737dfd230d36adf1a5c5c2c0c960d3fd3c5a30e Travis: [PENDING](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart

flinkbot edited a comment on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart URL: https://github.com/apache/flink/pull/11043#issuecomment-583936083 ## CI report: * 25c818413a98636ba23f6eff51374b91ad1d9fd3 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/bu

[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: [FAILURE](https://t

[GitHub] [flink] flinkbot commented on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1

flinkbot commented on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1 URL: https://github.com/apache/flink/pull/7579#issuecomment-583947053 ## CI report: * d737dfd230d36adf1a5c5c2c0c960d3fd3c5a30e UNKNOWN Bot commands The @

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

gaoyunhaii 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-583945495 Hi @zhijiangW Very thanks for the review! I have modified the codes accordingly, and the chan

[GitHub] [flink] flinkbot edited a comment on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner

flinkbot edited a comment on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner URL: https://github.com/apache/flink/pull/11044#issuecomment-583941299 ## CI report: * 507d7bb6076e4bc176c46f52e823762d264f3c28 Travis: [PENDING](https

[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: [FAILURE](https://t

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

gaoyunhaii commented 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-583945495 Hi @zhijiangW Very thanks for the review! I have modified the codes accordingly, and the change to t

[jira] [Commented] (FLINK-15955) Split RemoteFunction into GRPC Function/HttpFunction

[ https://issues.apache.org/jira/browse/FLINK-15955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033359#comment-17033359 ] Tzu-Li (Gordon) Tai commented on FLINK-15955: - Merged to {{master}} via {{11

[jira] [Closed] (FLINK-15954) Introduce a PersistedTable to the SDK

[ https://issues.apache.org/jira/browse/FLINK-15954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-15954. --- Fix Version/s: statefun-1.1 Resolution: Fixed > Introduce a PersistedTable to

[jira] [Closed] (FLINK-15955) Split RemoteFunction into GRPC Function/HttpFunction

[ https://issues.apache.org/jira/browse/FLINK-15955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-15955. --- Fix Version/s: statefun-1.1 Resolution: Fixed > Split RemoteFunction into GRP

[jira] [Commented] (FLINK-15954) Introduce a PersistedTable to the SDK

[ https://issues.apache.org/jira/browse/FLINK-15954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033358#comment-17033358 ] Tzu-Li (Gordon) Tai commented on FLINK-15954: - Merged to {{master}} via 65ed

[GitHub] [flink-statefun] tzulitai closed pull request #17: [FLINK-15954] Add a PersistedTable to the SDK

tzulitai closed pull request #17: [FLINK-15954] Add a PersistedTable to the SDK URL: https://github.com/apache/flink-statefun/pull/17 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-statefun] tzulitai closed pull request #18: [FLINK-15955] Split RemoteFunction into gRPC/HTTP

tzulitai closed pull request #18: [FLINK-15955] Split RemoteFunction into gRPC/HTTP URL: https://github.com/apache/flink-statefun/pull/18 This is an automated message from the Apache Git Service. To respond to the message, p

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

zhijiangW 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_r376857296 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] flinkbot commented on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner

flinkbot commented on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner URL: https://github.com/apache/flink/pull/11044#issuecomment-583941299 ## CI report: * 507d7bb6076e4bc176c46f52e823762d264f3c28 UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart

flinkbot edited a comment on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart URL: https://github.com/apache/flink/pull/11043#issuecomment-583936083 ## CI report: * 25c818413a98636ba23f6eff51374b91ad1d9fd3 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/bu

[GitHub] [flink] zhijiangW commented on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1

zhijiangW commented on issue #7579: [FLINK-9142] Lower the minimum number of buffers for incoming channels to 1 URL: https://github.com/apache/flink/pull/7579#issuecomment-583939379 @kisimple are you still available for adjusting this PR? If not, I would take over it because we are focusin

[GitHub] [flink] flinkbot commented on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner

flinkbot commented on issue #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner URL: https://github.com/apache/flink/pull/11044#issuecomment-583937848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[GitHub] [flink] HuangXingBo opened a new pull request #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner

HuangXingBo opened a new pull request #11044: [FLINK-15913][python] Add Python Table Function Runner And Operator In Blink Planner URL: https://github.com/apache/flink/pull/11044 ## What is the purpose of the change *This pull request add Python Table Function Runner and Operator for

[GitHub] [flink] flinkbot commented on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart

flinkbot commented on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart URL: https://github.com/apache/flink/pull/11043#issuecomment-583936083 ## CI report: * 25c818413a98636ba23f6eff51374b91ad1d9fd3 UNKNOWN Bot commands The @flinkbot bot supports t

[jira] [Updated] (FLINK-15950) Remove registration of TableSource/TableSink in Table Env and ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15950: --- Description: This ticket would track the removal of direct TableSource/TableSink registration to Ta

[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_r376850031 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[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_r376849678 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[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_r376848988 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[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_r376848845 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[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_r376848826 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] hequn8128 commented on issue #11020: [FLINK-15913][python] Add Python TableFunction Runner and Operator in old planner

hequn8128 commented on issue #11020: [FLINK-15913][python] Add Python TableFunction Runner and Operator in old planner URL: https://github.com/apache/flink/pull/11020#issuecomment-583930209 It seems the test failure has nothing to do with this PR. I will merge this. ---

[GitHub] [flink] hequn8128 merged pull request #11020: [FLINK-15913][python] Add Python TableFunction Runner and Operator in old planner

hequn8128 merged pull request #11020: [FLINK-15913][python] Add Python TableFunction Runner and Operator in old planner URL: https://github.com/apache/flink/pull/11020 This is an automated message from the Apache Git Service

[jira] [Updated] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

[ https://issues.apache.org/jira/browse/FLINK-15961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15961: - Summary: Introduce Python Physical Correlate RelNodes which are containers for Python TableFunc

[jira] [Created] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python Python TableFunction

Huang Xingbo created FLINK-15961: Summary: Introduce Python Physical Correlate RelNodes which are containers for Python Python TableFunction Key: FLINK-15961 URL: https://issues.apache.org/jira/browse/FLINK-15961

[GitHub] [flink] flinkbot commented on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart

flinkbot commented on issue #11043: [hotfix] Remove deadcode in ExecutionGraph#restart URL: https://github.com/apache/flink/pull/11043#issuecomment-583928381 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reque

[GitHub] [flink] TisonKun opened a new pull request #11043: [hotfix] Remove deadcode in ExecutionGraph#restart

TisonKun opened a new pull request #11043: [hotfix] Remove deadcode in ExecutionGraph#restart URL: https://github.com/apache/flink/pull/11043 Remove dead code. This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

  1   2   >