[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * dbfc56e38aa3cfb18adc52fa3740547ece76e54f Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r778594547 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemConnectorOptions.java ## @@

[jira] [Assigned] (FLINK-25521) The composition description of 'INTERVAL DAY TO SECOND' in the Data Type is incorrect

[ https://issues.apache.org/jira/browse/FLINK-25521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25521: -- Assignee: Zongwen Li > The composition description of 'INTERVAL DAY TO SECOND' in

[jira] [Commented] (FLINK-25521) The composition description of 'INTERVAL DAY TO SECOND' in the Data Type is incorrect

[ https://issues.apache.org/jira/browse/FLINK-25521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469089#comment-17469089 ] Martijn Visser commented on FLINK-25521: [~Ashulin] I've assigned it to you > The composition

[GitHub] [flink] flinkbot edited a comment on pull request #18260: [DO NOT MERGE] Trigger the CI for FLINK-25085

flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * 219b1c1f1d63400d6215898d9026481052e88dbb Azure:

[jira] [Commented] (FLINK-25515) flink-kafka-consumer

[ https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469087#comment-17469087 ] Martijn Visser commented on FLINK-25515: [~chenyu.mr] If the data is truncated in Flink 1.11 but

[GitHub] [flink] ashulin commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

ashulin commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r777856618 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18242: [hotfix][doc]Fixed the problem that the Windows document Window Assig…

flinkbot edited a comment on pull request #18242: URL: https://github.com/apache/flink/pull/18242#issuecomment-1002848538 ## CI report: * e3dacf8acae4a808e9a00c1b07ddbff10af83b71 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

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

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hbase] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14fbcbb6d049e0b6c3f471f1bac480208b9aa231 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

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

[GitHub] [flink] wangqinghuan closed pull request #17590: [FLINK-24672] diffrentiate consumer client id when consumers having same group id

wangqinghuan closed pull request #17590: URL: https://github.com/apache/flink/pull/17590 -- 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 #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 618b8cf331eb392c93755973d23512123a1fedd4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 618b8cf331eb392c93755973d23512123a1fedd4 Azure:

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r778563145 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-25513) CoFlatMapFunction requires both two flat_maps to yield something

[ https://issues.apache.org/jira/browse/FLINK-25513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-25513: Affects Version/s: 1.13.0 (was: 1.13.3) > CoFlatMapFunction requires both two

[jira] [Commented] (FLINK-25513) CoFlatMapFunction requires both two flat_maps to yield something

[ https://issues.apache.org/jira/browse/FLINK-25513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469027#comment-17469027 ] Dian Fu commented on FLINK-25513: - [~atptour2017] Thanks for reporting this issue. Would you like to

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r778051063 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1195,53 +1189,72 @@ private ApplicationReport

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r778048091 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/ApplicationReportProviderImpl.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

flinkbot edited a comment on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-995378571 ## CI report: * f980d9084d916f3354067aa4119e2705f44c596a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

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

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * b7a75d465d4169404b115e8f500f30c4e038a0c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

flinkbot edited a comment on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-989489342 ## CI report: * 3357aed4112d1cd3f3c24b2f91f1385ea52a Azure:

[GitHub] [flink] liufangqi commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

liufangqi commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-1005371562 @dmvk I read all the file contains "hadoop" content, and try to update the Hadoop version that should be updated (PS: some docs's Hadoop version that is specially

[GitHub] [flink] flinkbot edited a comment on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

flinkbot edited a comment on pull request #18201: URL: https://github.com/apache/flink/pull/18201#issuecomment-1000767373 ## CI report: * b106d3f7ba04cd518efbb4552de331e80ff9be57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

flinkbot edited a comment on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-989489342 ## CI report: * 3357aed4112d1cd3f3c24b2f91f1385ea52a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

flinkbot edited a comment on pull request #18201: URL: https://github.com/apache/flink/pull/18201#issuecomment-1000767373 ## CI report: * b106d3f7ba04cd518efbb4552de331e80ff9be57 Azure:

[GitHub] [flink] zuston commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

zuston commented on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-1005363690 Gentle ping @gaoyunhaii. Could you help review it? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * ebbb76310ec8058e28ca677a38b22d4305ba40ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * ebbb76310ec8058e28ca677a38b22d4305ba40ed Azure:

[jira] [Updated] (FLINK-25521) The composition description of 'INTERVAL DAY TO SECOND' in the Data Type is incorrect

[ https://issues.apache.org/jira/browse/FLINK-25521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zongwen Li updated FLINK-25521: --- Priority: Minor (was: Major) > The composition description of 'INTERVAL DAY TO SECOND' in the Data

[GitHub] [flink] flinkbot edited a comment on pull request #18260: [DO NOT MERGE] Trigger the CI for FLINK-25085

flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * 3e773c994e2db7801f2a0ccb318607cbd2e9a252 Azure:

[GitHub] [flink] wgzhao commented on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

wgzhao commented on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-1005355160 > @MartijnVisser I'd like to, @wgzhao could you fix the test failure and doc failure before we start review it ? OK -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-25515) flink-kafka-consumer

[ https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 宇宙先生 updated FLINK-25515: - Description: my flink version flink 1.11.2,the data in  kafka !image-2022-01-04-17-55-54-810.png! program

[jira] [Updated] (FLINK-25515) flink-kafka-consumer

[ https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 宇宙先生 updated FLINK-25515: - Attachment: image-2022-01-05-11-27-28-247.png Description: my flink version flink 1.11.2,the data in 

[GitHub] [flink] flinkbot edited a comment on pull request #18260: [DO NOT MERGE] Trigger the CI for FLINK-25085

flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * 3e773c994e2db7801f2a0ccb318607cbd2e9a252 Azure:

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469003#comment-17469003 ] Yao Zhang commented on FLINK-25471: --- Hi [~zhangzihan] , For Flink 1.13.3 even though we use batch

[jira] [Created] (FLINK-25521) The composition description of 'INTERVAL DAY TO SECOND' in the Data Type is incorrect

Zongwen Li created FLINK-25521: -- Summary: The composition description of 'INTERVAL DAY TO SECOND' in the Data Type is incorrect Key: FLINK-25521 URL: https://issues.apache.org/jira/browse/FLINK-25521

[GitHub] [flink] liyubin117 removed a comment on pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database

liyubin117 removed a comment on pull request #18146: URL: https://github.com/apache/flink/pull/18146#issuecomment-1004559229 @Airblader Is there anything else to do with this? please have a look, Thanks! -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-1005352498 @MartijnVisser Can this PR be moved forward and reviewd by someone so that this work can be done sooner? -- This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469002#comment-17469002 ] Yubin Li commented on FLINK-25369: -- Hi, [~jark] [~lzljs3620320] [~yunta]  , Looking forward to hearing

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468999#comment-17468999 ] zhangzh commented on FLINK-25471: - hi [~twalthr] , who can assign this issue ? > wrong result if table

[GitHub] [flink] flinkbot edited a comment on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

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

[GitHub] [flink] flinkbot edited a comment on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

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

[GitHub] [flink] flinkbot commented on pull request #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

flinkbot commented on pull request #18266: URL: https://github.com/apache/flink/pull/18266#issuecomment-1005344350 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 #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

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

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468995#comment-17468995 ] zhangzh commented on FLINK-25471: - @ [~paul8263]  i tested with Flink 1.13.3 , in batch mode ,output

[GitHub] [flink] flinkbot commented on pull request #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

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

[jira] [Updated] (FLINK-25510) Add test cases for KafkaPartitionSplitReader

[ https://issues.apache.org/jira/browse/FLINK-25510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25510: --- Labels: pull-request-available (was: ) > Add test cases for KafkaPartitionSplitReader >

[GitHub] [flink] ashulin opened a new pull request #18266: [FLINK-25510][Connectors / Kafka][tests] Add using committed offsets test cases for KafkaPartitionSplitReader

ashulin opened a new pull request #18266: URL: https://github.com/apache/flink/pull/18266 ## What is the purpose of the change KafkaPartitionSplitReaderTest is missing the test case when startingOffset is COMMITTED_OFFSET. ## Brief change log Add using

[jira] [Commented] (FLINK-25507) ElasticsearchWriterITCase#testWriteOnBulkFlush test failed

[ https://issues.apache.org/jira/browse/FLINK-25507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468971#comment-17468971 ] ranqiqiang commented on FLINK-25507: Thanks, I don't know have some documents ？ It's could be easy 

[GitHub] [flink] flinkbot edited a comment on pull request #18242: [hotfix][doc]Fixed the problem that the Windows document Window Assig…

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

[GitHub] [flink] meng1222 commented on pull request #18214: [hotfix][doc]Fixed an issue where clicking Window Assigner and Window…

meng1222 commented on pull request #18214: URL: https://github.com/apache/flink/pull/18214#issuecomment-1005330467 > > @meng1222 thanks for the fix I verified that the links now work. Can you also open a PR to fix this on the master branch? > > yes,this is the pr for the master, can

[GitHub] [flink] sky-walking commented on pull request #18172: [hotfix][docs] Fix incorrect Python tableEnvironment attribute reference

sky-walking commented on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-1005330414 @fapaul Could you please help me review my commit? Thank you very much -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] meng1222 commented on pull request #18214: [hotfix][doc]Fixed an issue where clicking Window Assigner and Window…

meng1222 commented on pull request #18214: URL: https://github.com/apache/flink/pull/18214#issuecomment-1005330319 > @meng1222 thanks for the fix I verified that the links now work. Can you also open a PR to fix this on the master branch? yes,this is the pr for the master, can you

[GitHub] [flink] flinkbot edited a comment on pull request #18242: [hotfix][doc]Fixed the problem that the Windows document Window Assig…

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

[GitHub] [flink] liufangqi commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

liufangqi commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-1005329107 > Hi @liufangqi, there have been no objections from the community [1] and there is a consensus on making 2.8.5 the minimal supported version. > > We should remove the

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hbase] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * b7b218e7dd8d241e45c8f879cc9b2dfd71dd2635 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hbase] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * b7b218e7dd8d241e45c8f879cc9b2dfd71dd2635 Azure:

[jira] [Commented] (FLINK-25464) Python tests hangs on install dependencies

[ https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468961#comment-17468961 ] Huang Xingbo commented on FLINK-25464: -- [~trohrmann] Because all hanging installation occurs in

[GitHub] [flink] leonardBang commented on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

leonardBang commented on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-1005323985 @MartijnVisser I'd like to, @wgzhao could you fix the test failure and doc failure before we start review it ? -- This is an automated message from the Apache Git

[jira] [Closed] (FLINK-25183) Optimize changelog normalize for the managed table upsert mode

[ https://issues.apache.org/jira/browse/FLINK-25183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25183. Resolution: Fixed master: c1b2e427160cabf8d811984e58ed3fb2e2f9efbf > Optimize changelog

[GitHub] [flink] JingsongLi merged pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…

JingsongLi merged pull request #18199: URL: https://github.com/apache/flink/pull/18199 -- 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] JingsongLi commented on a change in pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…

JingsongLi commented on a change in pull request #18199: URL: https://github.com/apache/flink/pull/18199#discussion_r778497196 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicityTest.scala ##

[GitHub] [flink] JingsongLi commented on a change in pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

JingsongLi commented on a change in pull request #18219: URL: https://github.com/apache/flink/pull/18219#discussion_r778496834 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/TableSinkTest.scala ## @@ -623,6 +623,32

[jira] [Updated] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-25176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25176: - Summary: Introduce "ALTER TABLE ... COMPACT" SQL syntax (was: Introduce "ALTER TABLE ...

[jira] [Closed] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL

[ https://issues.apache.org/jira/browse/FLINK-25176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25176. Resolution: Fixed master: 5f69c84468220e52557c0ac65706d1b79e946d3b

[jira] [Created] (FLINK-25520) Implement "ALTER TABLE ... COMPACT" SQL

Jingsong Lee created FLINK-25520: Summary: Implement "ALTER TABLE ... COMPACT" SQL Key: FLINK-25520 URL: https://issues.apache.org/jira/browse/FLINK-25520 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL

[ https://issues.apache.org/jira/browse/FLINK-25176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468941#comment-17468941 ] Jingsong Lee commented on FLINK-25176: -- Created FLINK-25520 for implementation. > Introduce "ALTER

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468932#comment-17468932 ] Yao Zhang commented on FLINK-25471: --- It should be a bug. Could anyone assign this to me please? >

[jira] [Updated] (FLINK-6098) Cassandra sink freezes after write error

[ https://issues.apache.org/jira/browse/FLINK-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6098: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6115: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6081: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6116: -- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6109: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6114: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6118) Chained operators forward watermark without checking

[ https://issues.apache.org/jira/browse/FLINK-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6118: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6140) Add ability to dynamically start jobs-within-jobs (e.g. turning a DataSet into an out-of-memory Map, to be accessed by another mapper function)

[ https://issues.apache.org/jira/browse/FLINK-6140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6140: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6082: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6131) Add side inputs for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-6131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6131: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * bd512793fc9f8b19873cf39521ef9b9f98aa5022 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 242c03371e963d6f3e7ed701beb2c43177580d71 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 242c03371e963d6f3e7ed701beb2c43177580d71 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

MartijnVisser commented on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-1005178288 @imaffe The ticket has been resolved, if you rebase the CI should pass -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] tashoyan commented on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

tashoyan commented on pull request #17765: URL: https://github.com/apache/flink/pull/17765#issuecomment-1005146965 LGTM -- 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

[jira] [Updated] (FLINK-25519) Promote StreamExecutionEnvironment#fromSource() from @Experimental to next phase

[ https://issues.apache.org/jira/browse/FLINK-25519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25519: -- Priority: Blocker (was: Major) > Promote StreamExecutionEnvironment#fromSource() from

[GitHub] [flink] flinkbot edited a comment on pull request #18265: [FLINK-24444][runtime] OperatorCoordinatorSchedulerTest: Wait until c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18237: [DRAFT][FLINK-XXXX] Use working directory to persist local state

flinkbot edited a comment on pull request #18237: URL: https://github.com/apache/flink/pull/18237#issuecomment-1002663160 ## CI report: * bb084756733a3ea3221cedf20206aef8882fc078 Azure:

[jira] [Updated] (FLINK-25106) Allow specifying specific offsets for each partition for Upsert Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25106: --- Description: The Flink Kafka connector allows you to specify the specific offsets for each

[jira] [Updated] (FLINK-25106) Allow specifying specific offsets for each partition for Upsert-Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25106: --- Description: Currently, FLINK's "kafka" connector ignores all the tombstone messages,

[jira] [Updated] (FLINK-25106) Allow specifying specific offsets for each partition for Upsert Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25106: --- Summary: Allow specifying specific offsets for each partition for Upsert Kafka connector

[jira] [Updated] (FLINK-25106) Allow specifying specific offsets for each partition for Upsert-Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25106: --- Description: Currently, FLINK's "kafka" connector ignores all the tombstone messages,

[jira] [Updated] (FLINK-25106) Allow specifying specific offsets for each partition for Upsert-Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25106: --- Summary: Allow specifying specific offsets for each partition for Upsert-Kafka connector

[GitHub] [flink] MartijnVisser commented on pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

MartijnVisser commented on pull request #18105: URL: https://github.com/apache/flink/pull/18105#issuecomment-1005093678 Would this test now also detect any ClassNotFoundException situations and fail when that happens? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 4390d75502395f2898e0838827e466b35f45a50f Azure:

[jira] [Created] (FLINK-25519) Promote StreamExecutionEnvironment#fromSource() from @Experimental to next phase

Martijn Visser created FLINK-25519: -- Summary: Promote StreamExecutionEnvironment#fromSource() from @Experimental to next phase Key: FLINK-25519 URL: https://issues.apache.org/jira/browse/FLINK-25519

[GitHub] [flink] flinkbot edited a comment on pull request #18265: [FLINK-24444][runtime] OperatorCoordinatorSchedulerTest: Wait until c…

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

[GitHub] [flink] flinkbot commented on pull request #18265: [FLINK-24444][runtime] OperatorCoordinatorSchedulerTest: Wait until c…

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

[GitHub] [flink] flinkbot commented on pull request #18265: [FLINK-24444][runtime] OperatorCoordinatorSchedulerTest: Wait until c…

flinkbot commented on pull request #18265: URL: https://github.com/apache/flink/pull/18265#issuecomment-1005059018 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

  1   2   3   4   >