leijurv opened a new pull request, #329:
URL: https://github.com/apache/flink-statefun/pull/329
The example string provided in the documentation does not actually parse. It
causes an exception: `Unable to parse date string for startup position:
2020-02-01 04:15:00.00 Z; the date should
[
https://issues.apache.org/jira/browse/FLINK-31673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31673:
---
Labels: pull-request-available (was: )
> Add E2E tests for flink jdbc driver
>
[
https://issues.apache.org/jira/browse/FLINK-32148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32148.
--
Fix Version/s: kubernetes-operator-1.6.0
Resolution: Fixed
merged to main
[
https://issues.apache.org/jira/browse/FLINK-32147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32147.
--
Resolution: Fixed
merged to main 57974b61590e1976785fbdd4a40dafa975fc9521
> Deduplicate scaling
gyfora merged PR #608:
URL: https://github.com/apache/flink-kubernetes-operator/pull/608
--
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:
[
https://issues.apache.org/jira/browse/FLINK-32147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32147:
---
Labels: pull-request-available (was: )
> Deduplicate scaling report messages
>
xuzhiwen1255 commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1208764798
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -65,33 +71,46 @@ public void open(
WencongLiu commented on PR #22579:
URL: https://github.com/apache/flink/pull/22579#issuecomment-1566589461
@snuyanzin Do you have any other suggestions?
--
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
[
https://issues.apache.org/jira/browse/FLINK-31673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31673:
--
Assignee: Fang Yong
> Add E2E tests for flink jdbc driver
>
reswqa commented on code in PR #22579:
URL: https://github.com/apache/flink/pull/22579#discussion_r1208865416
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/SemiJoinITCase.scala:
##
@@ -470,7 +469,7 @@ class
leijurv commented on PR #329:
URL: https://github.com/apache/flink-statefun/pull/329#issuecomment-1566269417
Appears to have been added here
loserwang1024 commented on code in PR #28:
URL:
https://github.com/apache/flink-connector-kafka/pull/28#discussion_r1208763810
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java:
##
@@ -22,18 +22,69 @@
import
xuzhiwen1255 commented on PR #22010:
URL: https://github.com/apache/flink/pull/22010#issuecomment-1566386306
> > I think about it, the change of parallelism already exists in the
existing unit test, I think we don't need to add the test, because it already
includes the complete generated
flinkbot commented on PR #22670:
URL: https://github.com/apache/flink/pull/22670#issuecomment-1566409752
## CI report:
* f580c138ec78894c8058daf86993d63ca615647d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
libenchao commented on PR #22583:
URL: https://github.com/apache/flink/pull/22583#issuecomment-1566533577
@FangYongs By saying "e2e test", I mean the tests in
`flink-end-to-end-tests` module. What do you think about adding it there?
--
This is an automated message from the Apache Git
jiangxin369 opened a new pull request, #22670:
URL: https://github.com/apache/flink/pull/22670
## What is the purpose of the change
Triggers an immediate checkpoint after all sinks are finished to advance the
timing of bounded jobs finished.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28386:
---
Labels: pull-request-available (was: )
> Trigger an immediate checkpoint after all sources
1996fanrui commented on PR #22560:
URL: https://github.com/apache/flink/pull/22560#issuecomment-1566406137
@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
LadyForest commented on PR #22539:
URL: https://github.com/apache/flink/pull/22539#issuecomment-1565947626
By the way, you can evaluate the param `table.resources.download-dir` by the
command `SET;` to verify that the remote plan is downloaded under this dir and
is cleaned up when the
curcur commented on code in PR #22590:
URL: https://github.com/apache/flink/pull/22590#discussion_r1208271576
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManager.java:
##
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the Apache
WencongLiu commented on PR #22579:
URL: https://github.com/apache/flink/pull/22579#issuecomment-1566142552
Thanks for the careful review from @reswqa and @TanYuxin-tyx . I've made a
round of changes.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726933#comment-17726933
]
Feifan Wang commented on FLINK-29913:
-
Thanks for your information [~klion26] , I would like to add
WencongLiu commented on code in PR #22579:
URL: https://github.com/apache/flink/pull/22579#discussion_r1208550805
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/SemiJoinITCase.scala:
##
@@ -470,7 +469,7 @@ class
23 matches
Mail list logo
