[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r749404919 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * d92a19145e61625839818fe04696b272294ba80e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * dc414e8aa4b414009c10018bf33726140d7f087c Azure:

[jira] [Commented] (FLINK-24886) flink flame args bug, may we need to modify TimeUtils to supports m

[ https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443878#comment-17443878 ] jackylau commented on FLINK-24886: -- hi [~jark] , do you have time to review it ? > flink flame args

[GitHub] [flink] flinkbot edited a comment on pull request #17797: [FLINK-21639][docs] docs still state that AsyncWaitOperator is not chainable

flinkbot edited a comment on pull request #17797: URL: https://github.com/apache/flink/pull/17797#issuecomment-969004662 ## CI report: * 55862aa9e0b2d976eb07e6ad02bc83e16fbfd864 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the num

flinkbot edited a comment on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-961748638 ## CI report: * a392282483107bb6b985d9ff724d65d602a86a73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * cb411ae6f687391370ca07427b3ae6dd4d8b1967 Azure:

[GitHub] [flink] flinkbot commented on pull request #17798: [hotfix] Fix typos

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

[GitHub] [flink] RocMarshal commented on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number o

RocMarshal commented on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-969035044 > The situation is a bit odd. I think we shouldn't have a cache on top of rocks DB at all. We could think about having a cache in rocks DB itself. > > Nevertheless,

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * c6e82ed54863e765cbc2fdc4d51939f786304723 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 41c81e48ce73e222c75053cc12dea02fd58523a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * af723a27ce9cc6f837254b09e123fafed0114ed0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[GitHub] [flink] dannycranmer commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

dannycranmer commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r749468520 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #17799: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for topics containing periods

flinkbot edited a comment on pull request #17799: URL: https://github.com/apache/flink/pull/17799#issuecomment-969089865 ## CI report: * 075ae2263d7cc68a9bcd4d6e336494c104d670a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] alpreu commented on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

alpreu commented on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-969125593 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the num

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * 7032a0368a429ea76d974928f4eb6598160d3a10 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #17796: [FLINK-24846][streaming] Closing the mailbox only after it drains all mails including recursive ones

flinkbot edited a comment on pull request #17796: URL: https://github.com/apache/flink/pull/17796#issuecomment-968991176 ## CI report: * bd21067aaa801072a6672e16a34348fe69eab604 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17768: [FLINK-24776][table] Clarify DecodingFormat and introduce ProjectableDecodingFormat

flinkbot edited a comment on pull request #17768: URL: https://github.com/apache/flink/pull/17768#issuecomment-966372865 ## CI report: * b5a517a450886f61b1877af9a43bc4a9d839fadd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * d92a19145e61625839818fe04696b272294ba80e Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r749407124 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java ## @@

[GitHub] [flink] flinkbot commented on pull request #17797: [FLINK-21639][docs] docs still state that AsyncWaitOperator is not chainable

flinkbot commented on pull request #17797: URL: https://github.com/apache/flink/pull/17797#issuecomment-969003714 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 #17797: [FLINK-21639][docs] docs still state that AsyncWaitOperator is not chainable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17798: [hotfix] Fix typos

flinkbot edited a comment on pull request #17798: URL: https://github.com/apache/flink/pull/17798#issuecomment-969009481 ## CI report: * 08868d4ebca9f0ac4d6a33a6b4b4c9d4fc5753fb Azure:

[GitHub] [flink] akalash commented on a change in pull request #17701: [FLINK-24294][streaming] Register all stream task resources to one cl…

akalash commented on a change in pull request #17701: URL: https://github.com/apache/flink/pull/17701#discussion_r749432560 ## File path: flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java ## @@ -43,145 +39,15 @@ * @param Type for potential meta

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443924#comment-17443924 ] Leonard Xu commented on FLINK-19830: [~MartijnVisser]Yes, I'm work on this ticket. Do you any idea

[GitHub] [flink] flinkbot edited a comment on pull request #17782: [BP-1.14][FLINK-22419] Wait unlimited in RpcEndpointTest.testCallAsyncTimeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * c6e82ed54863e765cbc2fdc4d51939f786304723 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17798: [hotfix] Fix typos

flinkbot edited a comment on pull request #17798: URL: https://github.com/apache/flink/pull/17798#issuecomment-969009481 ## CI report: * 08868d4ebca9f0ac4d6a33a6b4b4c9d4fc5753fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[jira] [Closed] (FLINK-24869) flink-core should be provided in flink-file-sink-common

[ https://issues.apache.org/jira/browse/FLINK-24869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24869. - Resolution: Fixed Fixed via e40b4b7626556bf5026ccb2a318de653b2981e75 > flink-core should be

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * d757a82683771b14280957e6b63c4ca8c21383b4 Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

slinkydeveloper commented on a change in pull request #17786: URL: https://github.com/apache/flink/pull/17786#discussion_r749572744 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/MapAndMultisetToStringCastRule.java

[GitHub] [flink] snuyanzin edited a comment on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

snuyanzin edited a comment on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-968992577 Hi @slinkydeveloper thanks for letting know about mentioned refactoring. I've rebased branch to latest master and added a rule for multiset based on map as multiset

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r749403980 ## File path:

[GitHub] [flink] matriv commented on pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

matriv commented on pull request #17771: URL: https://github.com/apache/flink/pull/17771#issuecomment-968993409 > Hi, thanks for you to review my code, @matriv :) .I want to do some responses to your review. > > 1. `LogicalTypeCasts ` seems useless in the case "SELECT 1 = '1' FROM

[GitHub] [flink] snuyanzin commented on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

snuyanzin commented on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-968992577 Hi @slinkydeveloper thanks for letting know about mentioned refactoring. I've added a rule for multiset based on map as multiset is a `map` as also mentioned in

[GitHub] [flink] sjwiesman commented on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

sjwiesman commented on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-969043083 @MartijnVisser I have an umbrella ticket, FLINK-24635, for cleaning up the examples. You can open that as another subtask though I think the entire README could use a

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[GitHub] [flink] slinkydeveloper commented on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors

slinkydeveloper commented on pull request #17368: URL: https://github.com/apache/flink/pull/17368#issuecomment-969064389 Moved to https://github.com/apache/flink-web/pull/480 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] slinkydeveloper closed pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors

slinkydeveloper closed pull request #17368: URL: https://github.com/apache/flink/pull/17368 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * Unknown: [CANCELED](TBD) * d757a82683771b14280957e6b63c4ca8c21383b4 Azure:

[GitHub] [flink-web] slinkydeveloper opened a new pull request #480: [hotfix] Add some guide to debug planner and code generator

slinkydeveloper opened a new pull request #480: URL: https://github.com/apache/flink-web/pull/480 From https://github.com/apache/flink/pull/17368 this adds some details to debug flink-table-planner Signed-off-by: slinkydeveloper -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * Unknown: [CANCELED](TBD) * d757a82683771b14280957e6b63c4ca8c21383b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * f047a04dfebb1cc10cc98c381e0fe5b271cf0c1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[jira] [Updated] (FLINK-24781) Port from string casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24781: --- Labels: pull-request-available (was: ) > Port from string casting logic to CastRule >

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * c6e82ed54863e765cbc2fdc4d51939f786304723 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-24864][metrics] Release TaskManagerJobMetricGroup with the last slot rather than task

flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 5687d3421ac109903b1317ab84d06ed97f046699 Azure:

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443949#comment-17443949 ] Arseniy Tashoyan commented on FLINK-24897: -- [~bgeng777] there is a similar ticket for the Job

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * 7032a0368a429ea76d974928f4eb6598160d3a10 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

flinkbot edited a comment on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-967495270 ## CI report: * 15187283b333ccabbe52773128dd11032e12934e Azure:

[jira] [Updated] (FLINK-22419) testScheduleRunAsync fail

[ https://issues.apache.org/jira/browse/FLINK-22419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22419: -- Priority: Critical (was: Major) > testScheduleRunAsync fail > - > >

[GitHub] [flink] tillrohrmann closed pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

tillrohrmann closed pull request #17698: URL: https://github.com/apache/flink/pull/17698 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

flinkbot edited a comment on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 1fbb914233fb5651384a0c8ff979efc86e475d22 Azure:

[GitHub] [flink] flinkbot commented on pull request #17796: [FLINK-24846][streaming] Closing the mailbox only after it drains all mails including recursive ones

flinkbot commented on pull request #17796: URL: https://github.com/apache/flink/pull/17796#issuecomment-968991402 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 edited a comment on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

flinkbot edited a comment on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-967495270 ## CI report: * 15187283b333ccabbe52773128dd11032e12934e Azure:

[jira] [Assigned] (FLINK-24903) AdaptiveSchedulerTest.testJobStatusListenerNotifiedOfJobStatusChanges unstable

[ https://issues.apache.org/jira/browse/FLINK-24903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24903: Assignee: Chesnay Schepler >

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * d92a19145e61625839818fe04696b272294ba80e Azure:

[jira] [Created] (FLINK-24906) Improve CSV format handling and support

Martijn Visser created FLINK-24906: -- Summary: Improve CSV format handling and support Key: FLINK-24906 URL: https://issues.apache.org/jira/browse/FLINK-24906 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24703) Add support for reading CSV files based on StreamFormat (new file source API)

[ https://issues.apache.org/jira/browse/FLINK-24703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24703: --- Parent: FLINK-24906 Issue Type: Sub-task (was: Improvement) > Add support for

[jira] [Commented] (FLINK-24884) flink flame graph webui bug

[ https://issues.apache.org/jira/browse/FLINK-24884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443884#comment-17443884 ] jackylau commented on FLINK-24884: -- hi [~airblader] [~junhany] , when will you merge it ? > flink

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * d92a19145e61625839818fe04696b272294ba80e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 41c81e48ce73e222c75053cc12dea02fd58523a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[GitHub] [flink] flinkbot edited a comment on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

flinkbot edited a comment on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-948566240 ## CI report: * 0e6fea8d800cee8771cdafd718ea585be64dc7f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17701: [FLINK-24294][streaming] Register all stream task resources to one cl…

flinkbot edited a comment on pull request #17701: URL: https://github.com/apache/flink/pull/17701#issuecomment-962009686 ## CI report: * aa5c9222e87b0ff7ae990593cb2162cb83442257 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * Unknown: [CANCELED](TBD) * d757a82683771b14280957e6b63c4ca8c21383b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[GitHub] [flink] flinkbot commented on pull request #17799: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for topics containing periods

flinkbot commented on pull request #17799: URL: https://github.com/apache/flink/pull/17799#issuecomment-969088984 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 edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17782: [BP-1.14][FLINK-22419] Wait unlimited in RpcEndpointTest.testCallAsyncTimeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * c6e82ed54863e765cbc2fdc4d51939f786304723 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 00ba4e6b86979ef8494bfcab61192f47375963a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

flinkbot edited a comment on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-967495270 ## CI report: * 15187283b333ccabbe52773128dd11032e12934e Azure:

[GitHub] [flink] tillrohrmann commented on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

tillrohrmann commented on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-969191361 Thanks a lot @ysymi. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

flinkbot edited a comment on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-967495270 ## CI report: * 0716bba52cfd2e93ba65efc9a8de1ae5eea206ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

flinkbot edited a comment on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-967495270 ## CI report: * 0716bba52cfd2e93ba65efc9a8de1ae5eea206ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 553a3fc38d803f8addb31f639b868d5bbd7518dd Azure:

[jira] [Updated] (FLINK-24905) KDS implementation of Async Sink Table API

[ https://issues.apache.org/jira/browse/FLINK-24905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24905: --- Description: h2. Motivation *User stories:* As a Flink user, I’d like to use the Table API for the

[GitHub] [flink] flinkbot commented on pull request #17796: [FLINK-24846][streaming] Closing the mailbox only after it drains all mails including recursive ones

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

[GitHub] [flink] flinkbot commented on pull request #17798: [hotfix] Fix typos

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

[jira] [Updated] (FLINK-24905) KDS implementation of Async Sink Table API

[ https://issues.apache.org/jira/browse/FLINK-24905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24905: --- Component/s: Connectors / Kinesis (was: Connectors / Common) > KDS

[jira] [Updated] (FLINK-24905) KDS implementation of Async Sink Table API

[ https://issues.apache.org/jira/browse/FLINK-24905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24905: --- Labels: (was: pull-request-available) > KDS implementation of Async Sink Table API >

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262 @twalthr @Airblader @AHeise @tisonkun @gaoyunhaii Excuse me, Could you help me to check it if you have free time ? Thanks a lot. -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 41c81e48ce73e222c75053cc12dea02fd58523a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

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

[GitHub] [flink] flinkbot edited a comment on pull request #17735: [FLINK-24775][coordination] move JobStatus-related metrics out of ExecutionGraph

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

  1   2   3   4   5   6   7   8   >