[jira] [Created] (FLINK-25553) Remove MapR filesystem

Martijn Visser created FLINK-25553: -- Summary: Remove MapR filesystem Key: FLINK-25553 URL: https://issues.apache.org/jira/browse/FLINK-25553 Project: Flink Issue Type: Technical Debt

[jira] [Assigned] (FLINK-25553) Remove MapR filesystem

[ https://issues.apache.org/jira/browse/FLINK-25553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25553: -- Assignee: Martijn Visser > Remove MapR filesystem > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

flinkbot edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006052028 ## CI report: * 5596d541d1f2514696020408cace4cffbaadeb87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18261: [hotfix][docs] Fix the doc content in the createFieldGetter method of RowData

flinkbot edited a comment on pull request #18261: URL: https://github.com/apache/flink/pull/18261#issuecomment-1004646772 ## CI report: * 34a1f33bd217d3c2e99b06a64c9ccbd1ab2d6e45 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: * Unknown: [CANCELED](TBD) * 1d829d8cc9e1ba51cf2c0dbfe8fa3c8587fd0e43 UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Created] (FLINK-25552) Support MinMaxScaler in FlinkML

weibo zhao created FLINK-25552: -- Summary: Support MinMaxScaler in FlinkML Key: FLINK-25552 URL: https://issues.apache.org/jira/browse/FLINK-25552 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469754#comment-17469754 ] 刘方奇 commented on FLINK-25360: - [~yunta] THX for your reply, do you mean that I should write a proposal in

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

flinkbot edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006052028 ## CI report: * 5596d541d1f2514696020408cace4cffbaadeb87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18261: [hotfix][docs] Fix the doc content in the createFieldGetter method of RowData

flinkbot edited a comment on pull request #18261: URL: https://github.com/apache/flink/pull/18261#issuecomment-1004646772 ## CI report: * 34a1f33bd217d3c2e99b06a64c9ccbd1ab2d6e45 Azure:

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

PatrickRen commented on a change in pull request #18266: URL: https://github.com/apache/flink/pull/18266#discussion_r779358249 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java

[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: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469749#comment-17469749 ] Fabian Paul commented on FLINK-25021: - Thanks for the detailed proposal. I have one last question.

[GitHub] [flink] flinkbot edited a comment on pull request #18277: [FLINK-18508][table] support source parallelism

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

[GitHub] [flink] flinkbot edited a comment on pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

flinkbot edited a comment on pull request #18280: URL: https://github.com/apache/flink/pull/18280#issuecomment-1006315144 ## CI report: * f85be1f8e65beb9a3a2cf52f9c7325f5f3400840 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18255: [FLINK-25228][table] Introduce flink-table-test-utils

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

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

flinkbot edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006052028 ## CI report: * 5596d541d1f2514696020408cace4cffbaadeb87 Azure:

[GitHub] [flink] chenzihao5 commented on pull request #18261: [hotfix][docs] Fix the doc content in the createFieldGetter method of RowData

chenzihao5 commented on pull request #18261: URL: https://github.com/apache/flink/pull/18261#issuecomment-1006349633 @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

[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: * Unknown: [CANCELED](TBD) * 1d829d8cc9e1ba51cf2c0dbfe8fa3c8587fd0e43 UNKNOWN Bot commands The @flinkbot bot supports the

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

ashulin commented on a change in pull request #18266: URL: https://github.com/apache/flink/pull/18266#discussion_r779354166 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ##

[GitHub] [flink] hililiwei commented on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTimeForm

hililiwei commented on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-1006348426 @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

[GitHub] [flink] dianfu commented on a change in pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

dianfu commented on a change in pull request #18280: URL: https://github.com/apache/flink/pull/18280#discussion_r779336639 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -1436,10 +1436,12 @@ def close(self): self._close_func()

[GitHub] [flink] flinkbot edited a comment on pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

flinkbot edited a comment on pull request #18280: URL: https://github.com/apache/flink/pull/18280#issuecomment-1006315144 ## CI report: * f85be1f8e65beb9a3a2cf52f9c7325f5f3400840 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18255: [FLINK-25228][table] Introduce flink-table-test-utils

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

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

flinkbot edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006052028 ## CI report: * 5596d541d1f2514696020408cace4cffbaadeb87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * ccc3e6296e921c93e9b9a31f225e268240adee4c 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: * 44dc3e2b8f8384c4bd7ef71865e2a4f4da45c0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

flinkbot edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006052028 ## CI report: * 5596d541d1f2514696020408cace4cffbaadeb87 Azure:

[GitHub] [flink] slinkydeveloper commented on pull request #18255: [FLINK-25228][table] Introduce flink-table-test-utils

slinkydeveloper commented on pull request #18255: URL: https://github.com/apache/flink/pull/18255#issuecomment-1006344135 @twalthr ready for another pass -- 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

[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: * 44dc3e2b8f8384c4bd7ef71865e2a4f4da45c0ff Azure:

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

PatrickRen commented on a change in pull request #18266: URL: https://github.com/apache/flink/pull/18266#discussion_r779337802 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java

[GitHub] [flink] flinkbot edited a comment on pull request #18281: [FLINK-25519][Connectors] Promote StreamExecutionEnvironment#fromSour…

flinkbot edited a comment on pull request #18281: URL: https://github.com/apache/flink/pull/18281#issuecomment-1006339898 ## CI report: * a3051c150def59626367bb0e4bec90e90f1d7e39 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: * 44dc3e2b8f8384c4bd7ef71865e2a4f4da45c0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] flinkbot commented on pull request #18281: [FLINK-25519][Connectors] Promote StreamExecutionEnvironment#fromSour…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

flinkbot edited a comment on pull request #18280: URL: https://github.com/apache/flink/pull/18280#issuecomment-1006315144 ## CI report: * f85be1f8e65beb9a3a2cf52f9c7325f5f3400840 Azure:

[GitHub] [flink] rmetzger edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

rmetzger edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006076985 CI Run with DL logs: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28990=results --> didn't provide much insight grpc version pinning:

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

hililiwei edited a comment on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-1006339087 > Thanks @hililiwei for the update, looks generally good to me, I only left two minor comments. And I think we need to rebase master and fix the compile error which

[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: * 144c48908a1c8139142bd7090111db5169b93a3d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] hililiwei commented on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTimeForm

hililiwei commented on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-1006339087 > Thanks @hililiwei for the update, looks generally good to me, I only left two minor comments. And I think we need to rebase master and fix the compile error which due to

[GitHub] [flink] flinkbot commented on pull request #18281: [FLINK-25519][Connectors] Promote StreamExecutionEnvironment#fromSour…

flinkbot commented on pull request #18281: URL: https://github.com/apache/flink/pull/18281#issuecomment-1006338740 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] hililiwei commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify

hililiwei commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r779344192 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/PartitionTimeCommitPredicate.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

flinkbot edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006052028 ## CI report: * 5596d541d1f2514696020408cace4cffbaadeb87 Azure:

[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 ] ASF GitHub Bot updated FLINK-25519: --- Labels: pull-request-available (was: ) > Promote StreamExecutionEnvironment#fromSource()

[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: * 144c48908a1c8139142bd7090111db5169b93a3d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] MartijnVisser opened a new pull request #18281: [FLINK-25519][Connectors] Promote StreamExecutionEnvironment#fromSour…

MartijnVisser opened a new pull request #18281: URL: https://github.com/apache/flink/pull/18281 …ce() from @Experimental to @PublicEvolving ## What is the purpose of the change * Promotes StreamExecutionEnvironment#fromSource() from @Experimental to @PublicEvolving ##

[GitHub] [flink] flinkbot edited a comment on pull request #18276: [FLINK-25536] Minor Fix: Adjust the order of variable declaration and…

flinkbot edited a comment on pull request #18276: URL: https://github.com/apache/flink/pull/18276#issuecomment-1006230279 ## CI report: * 374e16b016529c231a4d03500e6cad9f1b0f6482 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 3b77ef5449acad53555add69956a0cb884f0adf8 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-1006333083 @imaffe You did rebase on the latest master, right? -- 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 #18277: [FLINK-18508][table] support source parallelism

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] dianfu commented on a change in pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

dianfu commented on a change in pull request #18280: URL: https://github.com/apache/flink/pull/18280#discussion_r779336639 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -1436,10 +1436,12 @@ def close(self): self._close_func()

[GitHub] [flink] flinkbot edited a comment on pull request #18277: [FLINK-18508][table] support source parallelism

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

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] jinyaqia commented on pull request #18277: [FLINK-18508][table] support source parallelism

jinyaqia commented on pull request #18277: URL: https://github.com/apache/flink/pull/18277#issuecomment-1006327520 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] rmetzger edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

rmetzger edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006076985 CI Run with DL logs: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28990=results --> didn't provide much insight grpc version pinning:

[GitHub] [flink] rmetzger edited a comment on pull request #18275: [FLINK-11838] please ignore this PR

rmetzger edited a comment on pull request #18275: URL: https://github.com/apache/flink/pull/18275#issuecomment-1006076985 CI Run with DL logs: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28990=results --> didn't provide much insight -- This is an

[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[jira] [Assigned] (FLINK-25536) Minor Fix: Adjust the order of variable declaration and comment in StateAssignmentOperation

[ https://issues.apache.org/jira/browse/FLINK-25536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-25536: Assignee: Junfan Zhang > Minor Fix: Adjust the order of variable declaration and comment in >

[jira] [Commented] (FLINK-25536) Minor Fix: Adjust the order of variable declaration and comment in StateAssignmentOperation

[ https://issues.apache.org/jira/browse/FLINK-25536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469694#comment-17469694 ] Yun Tang commented on FLINK-25536: -- [~zuston] I think the PR is easy for review. Please remember to

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[jira] [Assigned] (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 reassigned FLINK-25513: --- Assignee: chendan > CoFlatMapFunction requires both two flat_maps to yield something >

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469693#comment-17469693 ] Yun Tang commented on FLINK-25360: -- [~liufangqi] I think we could at least to write a discuss email for

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

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

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

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

ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r779325869 ## 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 #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

flinkbot edited a comment on pull request #18280: URL: https://github.com/apache/flink/pull/18280#issuecomment-1006315144 ## CI report: * f85be1f8e65beb9a3a2cf52f9c7325f5f3400840 Azure:

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

ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r779320247 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java

[GitHub] [flink] flinkbot commented on pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

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

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * b5804c8b8810086275acfa3272aab1d2d981fd80 Azure:

[GitHub] [flink] flinkbot commented on pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

flinkbot commented on pull request #18280: URL: https://github.com/apache/flink/pull/18280#issuecomment-1006314579 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 #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

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

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

[jira] [Updated] (FLINK-25539) Create a connector with the batch tableenvironment of flick to read OSS files. The parallelism is set to 16. When reading, there are sometimes thread errors: null IO str

[ https://issues.apache.org/jira/browse/FLINK-25539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王康 updated FLINK-25539: --- Attachment: screenshot-1.png > Create a connector with the batch tableenvironment of flick to read OSS > files.

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * b5804c8b8810086275acfa3272aab1d2d981fd80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[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 ] ASF GitHub Bot updated FLINK-25513: --- Labels: pull-request-available (was: ) > CoFlatMapFunction requires both two flat_maps to

[GitHub] [flink] atptour2017 opened a new pull request #18280: [FLINK-25513] Allow flat_map and map in ConnectedStream to yield nothing

atptour2017 opened a new pull request #18280: URL: https://github.com/apache/flink/pull/18280 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[jira] [Updated] (FLINK-25539) Create a connector with the batch tableenvironment of flick to read OSS files. The parallelism is set to 16. When reading, there are sometimes thread errors: null IO str

[ https://issues.apache.org/jira/browse/FLINK-25539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王康 updated FLINK-25539: --- Description: English: Null IO stream: use the Flink version 1.13.2, and use the connector to read OSS files,

[jira] [Commented] (FLINK-25539) Create a connector with the batch tableenvironment of flick to read OSS files. The parallelism is set to 16. When reading, there are sometimes thread errors: null IO s

[ https://issues.apache.org/jira/browse/FLINK-25539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469691#comment-17469691 ] 王康 commented on FLINK-25539: Hello, it has been changed to English > Create a connector with the batch

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * b5804c8b8810086275acfa3272aab1d2d981fd80 Azure:

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

ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r779320247 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java

[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: * 370177fd5828a1093284e82d85a28e99bccf0957 Azure:

[jira] [Commented] (FLINK-25539) 用flink的BatchTableEnvironment创建连接器去读取oss文件，并行度设为16，读数时有时会出现线程报错：Null IO stream

[ https://issues.apache.org/jira/browse/FLINK-25539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469688#comment-17469688 ] Martijn Visser commented on FLINK-25539: [~名蒸蛋] Can you please translate your ticket to English?

[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 #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] 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] imaffe commented on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

imaffe commented on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-1006302766 @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 #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] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1006302562 Added more test cases about newly introduced components. @tillrohrmann -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-25530) Support Pulsar source connector in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469680#comment-17469680 ] Dian Fu commented on FLINK-25530: - [~ana4] Thanks a lot! Have assigned it to you~ > Support Pulsar

[jira] [Assigned] (FLINK-25530) Support Pulsar source connector in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-25530: --- Assignee: Ada Wong > Support Pulsar source connector in Python DataStream API. >

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469679#comment-17469679 ] RocMarshal commented on FLINK-25420: I'm interested in this jira. May I get the ticket

  1   2   3   4   5   >